Ingérer des données d’Azure Stream Analytics dans Azure Data Explorer

Avant de commencer, vérifiez que vous disposez d’un travail Stream Analytics existant ou créez-en un, puis effectuez les étapes suivantes pour créer votre connexion Azure Data Explorer.

1. Connectez-vous au portail Azure.

2. Dans le portail Azure, ouvrez Toutes les ressources, puis sélectionnez votre travail Stream Analytics.

3. Sous Topologie de la tâche, sélectionnez Sorties.

4. Sélectionnez Ajouter>Azure Data Explorer.

   

5. Remplissez le formulaire de sortie avec les informations suivantes, puis sélectionnez Enregistrer.

   Remarque

   Vous pouvez utiliser les options suivantes pour spécifier votre cluster et votre base de données :

   • Abonnement : sélectionnez Azure Data Explorer dans vos abonnements, sélectionnez votre abonnement, puis choisissez votre cluster et votre base de données.
   • Manuellement : sélectionnez Fournir manuellement les paramètres d’Azure Data Explorer, puis spécifiez l’URI et la base de données du cluster.

   Nom de la propriété	Description
   Alias de sortie	Nom convivial utilisé dans les requêtes pour diriger la sortie de requête vers cette base de données.
   Abonnement	Sélectionnez l’abonnement Azure où réside votre cluster.
   Cluster	Nom unique qui identifie votre cluster. Le nom de domaine [Région].kusto.windows.net est ajouté au nom de cluster que vous fournissez. Le nom doit être uniquement composé de lettres minuscules et de chiffres. Il doit comprendre entre 4 et 22 caractères.
   URI de cluster	URI d’ingestion de données de votre cluster. Vous pouvez spécifier l’URI des points de terminaison d’ingestion de données Azure Data Explorer ou Azure Synapse Data Explorer.
   Base de données	Nom de la base de données où vous envoyez votre sortie. Ce nom de base de données doit être unique dans le cluster.
   Authentification	Identité managée de Microsoft Entra permettant à votre cluster d’accéder facilement à d’autres ressources protégées par Microsoft Entra. Managée par la plateforme Azure, l’identité ne nécessite pas que vous approvisionniez ou permutiez de secrets. La configuration d’une identité managées vous permet d’utiliser des clés gérées par le client pour votre cluster.
   Table	Nom de la table où vous envoyez votre sortie. Les noms de colonnes et les types de données de la sortie Azure Stream Analytics doivent correspondre au schéma de la table Azure Data Explorer.

   

L’exemple suivant montre un modèle Azure Resource Manager pour l’ajout d’un connecteur de sortie Azure Data Explorer. Vous pouvez modifier et déployer le modèle dans le portail Azure pour créer votre connecteur.

{
    "$schema": "http://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "streamingJobName": {
            "type": "string",
            "defaultValue": "streamingjob"
        },
        "eventHubNamespace": {
            "type": "string"
        },
        "eventHubKey": {
            "type": "securestring"
        },
        "eventHubName": {
            "type": "string"
        },
        "eventHubConsumerGroupName": {
            "type": "string"
        },
        "streamingUnits": {
            "type": "int",
            "defaultValue": 3
        },
        "ADXClusterUri": {
            "type": "string"
        },
        "ADXDatabaseName": {
            "type": "string"
        },
        "ADXTableName": {
            "type": "string"
        }
    },
    "resources": [
        {
            "apiVersion": "2017-04-01-preview",
            "name": "[parameters('streamingJobName')]",
            "location": "[resourceGroup().location]",
            "type": "Microsoft.StreamAnalytics/StreamingJobs",
            "identity": {
                "type": "systemAssigned"
            },
            "properties": {
                "sku": {
                    "name": "standard"
                },
                "eventsOutOfOrderPolicy": "drop",
                "eventsOutOfOrderMaxDelayInSeconds": 10,
                "compatibilityLevel": "1.2",
                "outputStartMode": "JobStartTime",
                "inputs": [
                    {
                        "name": "inputEventHub",
                        "properties": {
                            "type": "stream",
                            "serialization": {
                                "type": "JSON",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.ServiceBus/EventHub",
                                "properties": {
                                    "serviceBusNamespace": "[parameters('eventHubNamespace')]",
                                    "sharedAccessPolicyName": "RootManageSharedAccessKey",
                                    "sharedAccessPolicyKey": "[parameters('eventHubKey')]",
                                    "eventHubName": "[parameters('eventHubName')]",
                                    "consumerGroupName": "[parameters('eventHubConsumerGroupName')]"
                                }
                            }
                        }
                    }
                ],
                "transformation": {
                    "name": "ProcessSampleData",
                    "properties": {
                        "streamingUnits": "[int(parameters('streamingUnits'))]",
                        "query": "select * from inputEventHub"
                    }
                },
                "outputs": [
                    {
                        "name": "output",
                        "properties": {
                            "serialization": {
                                "type": "CSV",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.Kusto/clusters/databases",
                                "properties": {
                                    "cluster": "[parameters('ADXClusterUri')]",
                                    "table": "[parameters('ADXTableName')]",
                                    "database": "[parameters('ADXDatabaseName')]",
                                    "authenticationMode": "Msi"
                                }
                            }
                        }
                    }
                ]
            }
        }
    ]
}