Créer une connexion de données Event Grid pour Azure Data Explorer

Cet article vous montre comment ingérer des objets blob de votre compte de stockage vers Azure Data Explorer en utilisant une connexion de données Event Grid. Vous allez créer une connexion de données Event Grid qui définit un abonnement Azure Event Grid. L’abonnement Event Grid route les événements de votre compte de stockage vers Azure Data Explorer via un hub d’événements Azure.

Pour obtenir des informations générales sur l’ingestion dans Azure Data Explorer à partir d’Event Grid, consultez Se connecter à Event Grid.

Remarque

Pour obtenir des performances optimales avec la connexion Event Grid, définissez la propriété d’ingestion rawSizeBytes via les métadonnées du blob. Pour plus d’informations, consultez Propriétés d’ingestion.

Prérequis

• Un abonnement Azure. Créez un compte Azure gratuit.
• Un cluster et une base de données Azure Data Explorer. Créez un cluster et une base de données.
• Une table de destination. Créez une table ou utilisez une table existante.
• Un mappage d’ingestion pour la table.
• Un compte de stockage. Un abonnement aux notifications Event Grid peut être défini sur des comptes de stockage Azure pour BlobStorage, StorageV2 ou Data Lake Storage Gen2.

Créer une connexion de données à Event Grid

Dans cette section, vous allez établir une connexion entre Event Grid et votre table Azure Data Explorer.

Portail : Azure Data Explorer

1. Sous le cluster que vous avez créé, sélectionnez Bases de données>TestDatabase.

   

2. Sélectionnez Ingestion des données>Ajouter la connexion de données.

   

3. Sous Principes de base, sélectionnez le type de connexion Stockage Blob, puis remplissez le formulaire avec les informations suivantes :

   

   Paramètre	Valeur suggérée	Description du champ
   Nom de la connexion de données	test-grid-connection	Nom de la connexion que vous souhaitez créer dans Azure Data Explorer.
   Abonnement du compte de stockage	Votre ID d’abonnement	ID d’abonnement où se trouve votre compte de stockage.
   Compte de stockage	gridteststorage1	Nom du compte de stockage que vous avez créé précédemment.
   Type d'événement	Objet blob créé ou Objet blob renommé	Type d’événement qui déclenche l’ingestion. Le renommage d’objets blob est pris en charge uniquement pour le stockage ADLSv2. Pour renommer un blob, accédez au blob dans le Portail Azure, cliquez dessus avec le bouton droit et sélectionnez Renommer. Types pris en charge : Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed.
   Création de ressources	Automatique	Spécifiez si vous voulez qu’Azure Data Explorer crée un abonnement Event Grid, un espace de noms Event Hubs et des hubs d’événements pour vous. Pour créer manuellement des ressources, consultez Créer manuellement des ressources pour l’ingestion Event Grid.

4. Sélectionnez Paramètres de filtre si vous voulez suivre des sujets spécifiques. Définissez les filtres pour les notifications comme suit :

   • Le champ Préfixe est le préfixe littéral du sujet. Comme le modèle appliqué est startswith, il peut englober plusieurs conteneurs, dossiers ou objets blob. Les caractères génériques ne sont pas autorisés.
     • Pour définir un filtre sur le conteneur d’objets blob, le champ doit être défini comme suit : /blobServices/default/containers/[container prefix].
     • Pour définir un filtre sur un préfixe d’objet blob (ou un dossier dans Azure Data Lake Gen2), le champ doit être défini comme suit : /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • Le champ Suffixe est le suffixe littéral de l’objet blob. Les caractères génériques ne sont pas autorisés.
   • Le champ Sensible à la casse indique si les filtres de préfixe et de suffixe respectent la casse.
   • Pour plus d’informations sur le filtrage des événements, consultez Événements du stockage Blob.

   

5. Sélectionnez Suivant : Propriétés d’ingestion.

6. Renseignez le formulaire avec les informations suivantes. Les noms de table et de mappage sont sensibles à la casse :

   

   Propriétés d’ingestion :

   Paramètre	Valeur suggérée	Description du champ
   Autoriser le routage des données vers d’autres bases de données (connexion de données à plusieurs bases de données)	Ne pas autoriser	Activez cette option si vous voulez remplacer la base de données cible par défaut associée à la connexion de données. Pour plus d’informations sur le routage de base de données, consultez Routage des événements.
   Nom de table	TestTable	Table que vous avez créée dans TestDatabase.
   Format de données	JSON	Les formats pris en charge sont Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW et W3CLOG. Les options de compression prises en charge sont Zip et Gzip.
   Mappage	TestMapping	Le mappage que vous avez créé dans TestDatabase, qui mappe les données entrantes aux noms de colonnes et aux types de données de TestTable. Si ce n’est pas spécifié, un mappage de données d’identité dérivé du schéma de la table est utilisé.
   Paramètres avancés	Mes données comprennent des en-têtes	Ignore les en-têtes. Pris en charge pour les fichiers de type *SV.

   Notes

   Vous n’êtes pas obligé de spécifier tous les paramètres de routage par défaut. Des paramètres partiels sont également acceptés.

7. Sélectionnez Suivant : Vérifier + créer.

8. Sous *Vérifier + créer.

9. Passez en revue les ressources qui ont été créées automatiquement pour vous et sélectionnez Créer.

   

10. Attendez la fin du déploiement. Si votre déploiement a échoué, sélectionnez Détails de l’opération à côté de la phase qui a échoué pour obtenir plus d’informations sur la raison de l’échec. Sélectionnez Redéployer pour retenter de déployer les ressources. Vous pouvez modifier les paramètres avant le déploiement.

    

Portail : Stockage Azure

1. Accédez à votre compte de stockage dans le portail Azure. Dans le menu de gauche, sélectionnez Événements.

2. Dans le volet principal, sélectionnez l’onglet Azure Data Explorer.

   

Le volet Connexion de données s’ouvre avec l’onglet Informations de base sélectionné.

1. Sous Principes de base, renseignez le formulaire avec les informations ci-après :

   

   Paramètre	Valeur suggérée	Description du champ
   Nom de la connexion de données	test-grid-connection	Nom de la connexion que vous souhaitez créer dans Azure Data Explorer.
   Compte de stockage	gridteststorage1	Compte de stockage à partir duquel vous avez accédé à cet Assistant. Rempli automatiquement.
   Type d'événement	Objet blob créé ou Objet blob renommé	Type d’événement qui déclenche l’ingestion. Le renommage d’objets blob est pris en charge uniquement pour le stockage ADLSv2. Pour renommer un blob, accédez au blob dans le Portail Azure, cliquez dessus avec le bouton droit et sélectionnez Renommer. Types pris en charge : Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed.
   Création de ressources	Automatique	Spécifiez si vous voulez qu’Azure Data Explorer crée un abonnement Event Grid, un espace de noms Event Hubs et des hubs d’événements pour vous. Pour créer manuellement des ressources, consultez Créer manuellement des ressources pour l’ingestion Event Grid.

2. Sélectionnez Suivant> Propriétés d’ingestion.

3. Sous Propriétés d’ingestion.

4. Renseignez le formulaire avec les informations suivantes. Les noms de table et de mappage sont sensibles à la casse :

   

   Paramètre	Valeur suggérée	Description du champ
   Abonnement		Votre abonnement Azure Data Explorer.
   Nom du cluster	TestCluster	Nom du cluster dans lequel vous souhaitez ingérer les données.
   Nom de la base de données	TestDatabase	Base de données cible que vous avez créée dans TestCluster.
   Autoriser le routage des données vers d’autres bases de données (connexion de données à plusieurs bases de données)	Ne pas autoriser	Activez cette option si vous voulez remplacer la base de données cible par défaut associée à la connexion de données. Pour plus d’informations sur le routage de base de données, consultez Routage des événements.
   Nom de table	TestTable	Table cible que vous avez créée dans TestDatabase.
   Format de données	JSON	Les formats pris en charge sont Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW et W3CLOG. Les options de compression prises en charge sont Zip et Gzip.
   Mappage	TestMapping	Le mappage que vous avez créé dans TestDatabase, qui mappe les données entrantes aux noms de colonnes et aux types de données de TestTable. Si ce n’est pas spécifié, un mappage de données d’identité dérivé du schéma de la table est utilisé.
   Paramètres avancés	Mes données comprennent des en-têtes	Ignore les en-têtes. Pris en charge pour les fichiers de type *SV.

   Remarque

   Vous n’avez pas à spécifier tous les paramètres de routage des données. Des paramètres partiels sont également acceptés.

5. Sélectionnez Suivant : Vérifier + créer.

6. Sous Vérifier + créer.

7. Passez en revue les ressources qui ont été créées automatiquement pour vous et sélectionnez Créer.

   

8. Attendez la fin du déploiement. Si votre déploiement a échoué, sélectionnez Détails de l’opération à côté de la phase qui a échoué pour obtenir plus d’informations sur la raison de l’échec. Sélectionnez Redéployer pour retenter de déployer les ressources. Vous pouvez modifier les paramètres avant le déploiement.

   

C#

1. Installez le package NuGet Microsoft.Azure.Management.Kusto.

2. Créez un principal d’application Azure AD à utiliser pour l’authentification. Vous aurez besoin de l’ID (de locataire) d’annuaire, de l’ID d’application et de la clé secrète client.

3. Exécutez le code suivant.

   var tenantId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"; //Directory (tenant) ID
   var clientId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"; //Application ID
   var clientSecret = "PlaceholderClientSecret"; //Client Secret
   var subscriptionId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx";
   var authClient = ConfidentialClientApplicationBuilder.Create(clientId)
       .WithAuthority($"https://login.microsoftonline.com/{tenantId}")
       .WithClientSecret(clientSecret)
       .Build();
   var result = authClient.AcquireTokenForClient(new[] { "https://management.core.windows.net/" }).ExecuteAsync().Result;
   var credentials = new TokenCredentials(result.AccessToken, result.TokenType);
   var kustoManagementClient = new KustoManagementClient(credentials) { SubscriptionId = subscriptionId };
   var resourceGroupName = "testrg";
   //The cluster and database that are created as part of the Prerequisites
   var clusterName = "mykustocluster";
   var databaseName = "mykustodatabase";
   var eventGridConnectionName = "myeventgridconnect";
   //The event hub and storage account that are created as part of the Prerequisites
   var eventHubResourceId = "/subscriptions/<storageAccountSubscriptionId>/resourceGroups/<storageAccountResourceGroupName>/providers/Microsoft.Storage/storageAccounts/<storageAccountName>";
   var storageAccountResourceId = "/subscriptions/<eventHubSubscriptionId>/resourceGroups/<eventHubResourceGroupName>/providers/Microsoft.EventHub/namespaces/<eventHubNamespaceName>/eventhubs/<eventHubName>";
   var consumerGroup = "$Default";
   var location = "Central US";
   //The table and column mapping are created as part of the Prerequisites
   var mappingRuleName = "StormEvents_CSV_Mapping";
   var dataFormat = DataFormat.CSV;
   var blobStorageEventType = "Microsoft.Storage.BlobCreated";
   var databaseRouting = "Multi";
   var eventGridConnectionData = new EventGridDataConnection(
       storageAccountResourceId, eventHubResourceId, consumerGroup,
       tableName: tableName, location: location, mappingRuleName: mappingRuleName,
       dataFormat: dataFormat, blobStorageEventType: blobStorageEventType, databaseRouting: databaseRouting
   );
   await kustoManagementClient.DataConnections.CreateOrUpdateAsync(
       resourceGroupName, clusterName, databaseName, eventGridConnectionName, eventGridConnectionData
   );
   

   Paramètre	Valeur suggérée	Description du champ
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Votre ID de client. Également appelé ID de répertoire.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID d’abonnement que vous utilisez pour la création de ressources.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID client de l’application qui peut accéder aux ressources figurant dans votre locataire.
   clientSecret	PlaceholderClientSecret	Secret client de l’application qui peut accéder aux ressources figurant dans votre locataire.
   resourceGroupName	testrg	Nom du groupe de ressources qui contient votre cluster.
   clusterName	mykustocluster	Nom de votre cluster.
   databaseName	mykustodatabase	Nom de la base de données cible dans votre cluster.
   eventGridConnectionName	myeventgridconnect	Nom souhaité de votre connexion de données.
   tableName	StormEvents	Nom de la table cible dans la base de données cible.
   mappingRuleName	StormEvents_CSV_Mapping	Nom de votre mappage de colonnes associé à la table cible.
   dataFormat	csv	Format de données du message.
   eventHubResourceId	ID de ressource	ID de ressource de votre hub d’événements où la grille d’événements est configurée pour envoyer des événements.
   storageAccountResourceId	ID de ressource	ID de ressource de votre compte de stockage qui contient les données à des fins d’ingestion.
   consumerGroup	$Default	Groupe de consommateurs de votre hub d’événements.
   location	USA Centre	Emplacement de la ressource de connexion de données.
   blobStorageEventType	Microsoft.Storage.BlobCreated	Type d’événement qui déclenche l’ingestion. Les événements pris en charge sont : Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed. Le renommage d’objets blob est pris en charge uniquement pour le stockage ADLSv2.
   databaseRouting	Multi ou Single	Routage de la base de données pour la connexion. Si vous définissez la valeur sur Single, la connexion de données est routée vers une base de données unique dans le cluster, comme spécifié dans le paramètre databaseName. Si vous définissez la valeur sur Multi, vous pouvez remplacer la base de données cible par défaut en utilisant la propriété ingestion de la base de données. Pour plus d’informations, consultez Routage des événements.

Python

1. Installez les bibliothèques nécessaires.

   pip install azure-common
   pip install azure-mgmt-kusto
   

2. Créez un principal d’application Azure AD à utiliser pour l’authentification. Vous aurez besoin de l’ID (de locataire) d’annuaire, de l’ID d’application et de la clé secrète client.

3. Exécutez le code suivant.

   from azure.mgmt.kusto import KustoManagementClient
   from azure.mgmt.kusto.models import EventGridDataConnection
   from azure.common.credentials import ServicePrincipalCredentials
   
   #Directory (tenant) ID
   tenant_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
   #Application ID
   client_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
   #Client Secret
   client_secret = "xxxxxxxxxxxxxx"
   subscription_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
   credentials = ServicePrincipalCredentials(
           client_id=client_id,
           secret=client_secret,
           tenant=tenant_id
       )
   kusto_management_client = KustoManagementClient(credentials, subscription_id)
   
   resource_group_name = "testrg"
   #The cluster and database that are created as part of the Prerequisites
   cluster_name = "mykustocluster"
   database_name = "mykustodatabase"
   data_connection_name = "myeventhubconnect"
   #The event hub and storage account that are created as part of the Prerequisites
   event_hub_resource_id = "/subscriptions/xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx/resourceGroups/xxxxxx/providers/Microsoft.EventHub/namespaces/xxxxxx/eventhubs/xxxxxx"
   storage_account_resource_id = "/subscriptions/xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx/resourceGroups/xxxxxx/providers/Microsoft.Storage/storageAccounts/xxxxxx"
   consumer_group = "$Default"
   location = "Central US"
   #The table and column mapping that are created as part of the Prerequisites
   table_name = "StormEvents"
   mapping_rule_name = "StormEvents_CSV_Mapping"
   data_format = "csv"
   database_routing = "Multi"
   blob_storage_event_type = "Microsoft.Storage.BlobCreated"
   
   #Returns an instance of LROPoller, check https://learn.microsoft.com/python/api/msrest/msrest.polling.lropoller?view=azure-python
   poller = kusto_management_client.data_connections.begin_create_or_update(resource_group_name=resource_group_name, cluster_name=cluster_name, database_name=database_name, data_connection_name=data_connection_name,
                                               parameters=EventGridDataConnection(storage_account_resource_id=storage_account_resource_id, event_hub_resource_id=event_hub_resource_id, 
                                                                                   consumer_group=consumer_group, table_name=table_name, location=location, mapping_rule_name=mapping_rule_name, data_format=data_format, database_routing=database_routing,
                                                                                   blob_storage_event_type=blob_storage_event_type))
   # The creation of the connection is async. Validation errors are only visible if you wait for the results.
   poller.wait()
   print(poller.result())
   

   Paramètre	Valeur suggérée	Description du champ
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Votre ID de client. Également appelé ID de répertoire.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID d’abonnement que vous utilisez pour la création de ressources.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID client de l’application qui peut accéder aux ressources figurant dans votre locataire.
   client_secret	xxxxxxxxxxxxxx	Secret client de l’application qui peut accéder aux ressources figurant dans votre locataire.
   resource_group_name	testrg	Nom du groupe de ressources qui contient votre cluster.
   nom_cluster	mykustocluster	Nom de votre cluster.
   database_name	mykustodatabase	Nom de la base de données cible dans votre cluster.
   data_connection_name	myeventhubconnect	Nom souhaité de votre connexion de données.
   table_name	StormEvents	Nom de la table cible dans la base de données cible.
   mapping_rule_name	StormEvents_CSV_Mapping	Nom de votre mappage de colonnes associé à la table cible.
   database_routing	Multi ou Single	Routage de la base de données pour la connexion. Si vous définissez la valeur sur Single, la connexion de données est routée vers une base de données unique dans le cluster, comme spécifié dans le paramètre databaseName. Si vous définissez la valeur sur Multi, vous pouvez remplacer la base de données cible par défaut en utilisant la propriété ingestion de la base de données. Pour plus d’informations, consultez Routage des événements.
   data_format	csv	Format de données du message.
   event_hub_resource_id	ID de ressource	ID de ressource de votre hub d’événements où la grille d’événements est configurée pour envoyer des événements.
   storage_account_resource_id	ID de ressource	ID de ressource de votre compte de stockage qui contient les données à des fins d’ingestion.
   consumer_group	$Default	Groupe de consommateurs de votre hub d’événements.
   location	USA Centre	Emplacement de la ressource de connexion de données.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	Type d’événement qui déclenche l’ingestion. Les événements pris en charge sont : Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed. Le renommage d’objets blob est pris en charge uniquement pour le stockage ADLSv2.

Modèle ARM

L’exemple suivant montre un modèle Azure Resource Manager pour l’ajout d’une connexion de données Event Grid. Vous pouvez modifier et déployer le modèle dans le portail Azure en utilisant le formulaire.

{
    "$schema": "https://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "namespaces_eventhubns_name": {
            "type": "string",
            "defaultValue": "eventhubns",
            "metadata": {
                "description": "Specifies the event hub namespace name."
            }
        },
        "EventHubs_eventhubdemo_name": {
            "type": "string",
            "defaultValue": "eventhubdemo",
            "metadata": {
                "description": "Specifies the event hub name."
            }
        },
        "consumergroup_default_name": {
            "type": "string",
            "defaultValue": "$Default",
            "metadata": {
                "description": "Specifies the consumer group of the event hub."
            }
        },
        "StorageAccounts_storagedemo_name": {
            "type": "string",
            "defaultValue": "storagedemo",
            "metadata": {
                "description": "Specifies the storage account name"
            }
        },
        "Clusters_kustocluster_name": {
            "type": "string",
            "defaultValue": "kustocluster",
            "metadata": {
                "description": "Specifies the name of the cluster"
            }
        },
        "databases_kustodb_name": {
            "type": "string",
            "defaultValue": "kustodb",
            "metadata": {
                "description": "Specifies the name of the database"
            }
        },
        "tables_kustotable_name": {
            "type": "string",
            "defaultValue": "kustotable",
            "metadata": {
                "description": "Specifies the name of the table"
            }
        },
        "mapping_kustomapping_name": {
            "type": "string",
            "defaultValue": "kustomapping",
            "metadata": {
                "description": "Specifies the name of the mapping rule"
            }
        },
        "dataformat_type": {
            "type": "string",
            "defaultValue": "csv",
            "metadata": {
                "description": "Specifies the data format"
            }
        },
             "databaseRouting_type": {
            "type": "string",
            "defaultValue": "Single",
            "metadata": {
                "description": "The database routing for the connection. If you set the value to **Single**, the data connection will be routed to a single database in the cluster as specified in the *databaseName* setting. If you set the value to **Multi**, you can override the default target database using the *Database* EventData property."
            }
        },
        "dataconnections_kustodc_name": {
            "type": "string",
            "defaultValue": "kustodc",
            "metadata": {
                "description": "Name of the data connection to create"
            }
        },
        "subscriptionId": {
            "type": "string",
            "defaultValue": "[subscription().subscriptionId]",
            "metadata": {
                "description": "Specifies the subscriptionId of the resources"
            }
        },
        "resourceGroup": {
            "type": "string",
            "defaultValue": "[resourceGroup().name]",
            "metadata": {
                "description": "Specifies the resourceGroup of the resources"
            }
        },
        "location": {
            "type": "string",
            "defaultValue": "[resourceGroup().location]",
            "metadata": {
                "description": "Location for all resources."
            }
        }
    },
    "variables": {
    },
    "resources": [{
            "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
            "apiVersion": "2022-02-01",
            "name": "[concat(parameters('Clusters_kustocluster_name'), '/', parameters('databases_kustodb_name'), '/', parameters('dataconnections_kustodc_name'))]",
            "location": "[parameters('location')]",
            "kind": "EventGrid",
            "properties": {
                "managedIdentityResourceId": "[resourceId('Microsoft.Kusto/clusters', parameters('clusters_kustocluster_name'))]",
                "storageAccountResourceId": "[resourceId(parameters('subscriptionId'), parameters('resourceGroup'), 'Microsoft.Storage/storageAccounts', parameters('StorageAccounts_storagedemo_name'))]",
                "eventHubResourceId": "[resourceId(parameters('subscriptionId'), parameters('resourceGroup'), 'Microsoft.EventHub/namespaces/eventhubs', parameters('namespaces_eventhubns_name'), parameters('EventHubs_eventhubdemo_name'))]",
                "consumerGroup": "[parameters('consumergroup_default_name')]",
                "tableName": "[parameters('tables_kustotable_name')]",
                "mappingRuleName": "[parameters('mapping_kustomapping_name')]",
                "dataFormat": "[parameters('dataformat_type')]",
                "databaseRouting": "[parameters('databaseRouting_type')]"
            }
        }
    ]
}

Supprimer une connexion de données Event Grid

Portail

Pour supprimer la connexion Event Grid de l’Portail Azure, procédez comme suit :

1. Accédez à votre cluster. Dans le menu de gauche, sélectionnez Bases de données. Ensuite, sélectionnez la base de données qui contient la table cible.
2. Dans le menu de gauche, sélectionnez Connexions de données. Ensuite, cochez la case en regard de la connexion de données Event Grid pertinente.
3. Dans la barre de menus du haut, sélectionnez Supprimer.

C#

Pour supprimer la connexion Event Grid, exécutez la commande suivante :

kustoManagementClient.DataConnections.Delete(resourceGroupName, clusterName, databaseName, dataConnectionName);

Python

Pour supprimer la connexion Event Grid, exécutez la commande suivante :

kusto_management_client.data_connections.delete(resource_group_name=resource_group_name, cluster_name=kusto_cluster_name, database_name=kusto_database_name, data_connection_name=kusto_data_connection_name)

Étapes suivantes

• Traiter les données de votre instance Event Hub avec Azure Stream Analytics