Creare una connessione dati di Griglia di eventi per Azure Esplora dati

Questo articolo illustra come inserire BLOB dall'account di archiviazione in Azure Esplora dati usando una connessione dati di Griglia di eventi. Creare una connessione dati a Griglia di eventi che imposta una sottoscrizione alla Griglia di eventi di Azure. La sottoscrizione di Griglia di eventi instrada gli eventi dall'account di archiviazione ad Azure Esplora dati tramite un Hub eventi di Azure.

Per informazioni generali sull'inserimento in Azure Esplora dati da Griglia di eventi, vedere Connettersi a Griglia di eventi.

Nota

Per ottenere prestazioni ottimali con la connessione di Griglia di eventi, impostare la rawSizeBytes proprietà di inserimento tramite i metadati del BLOB. Per altre informazioni, vedere Proprietà di inserimento.

Prerequisiti

• Una sottoscrizione di Azure. Creare un account Azure gratuito.
• Un cluster e un database di Esplora dati di Azure. Creare un cluster e un database.
• Tabella di destinazione. Creare una tabella o usare una tabella esistente.
• Mapping di inserimento per la tabella.
• Un account di archiviazione. Una sottoscrizione di notifica di Griglia di eventi può essere impostata su Archiviazione di Azure account per BlobStorage, StorageV2o Data Lake Storage Gen2.

Creare una connessione dati a Griglia di eventi

In questa sezione verrà stabilita una connessione tra Griglia di eventi e la tabella di Azure Esplora dati.

Portale - Azure Esplora dati

1. Nel cluster creato selezionare Database>TestDatabase.

   

2. Selezionare Inserimento dati>Aggiungi connessione dati.

   

3. In Informazioni di base selezionare il tipo di connessione: Archiviazione BLOB e quindi compilare il modulo con le informazioni seguenti:

   

   Impostazione	Valore consigliato	Descrizione campo
   Nome connessione dati	test-grid-connection	Il nome della connessione da creare in Esplora dati di Azure.
   Sottoscrizione dell'account di archiviazione	ID della sottoscrizione	L'ID sottoscrizione in cui trova l'account di archiviazione.
   Account di archiviazione	gridteststorage1	Il nome dell'account di archiviazione creato in precedenza.
   Tipo di evento	BLOB creato o BLOB rinominato	Tipo di evento che attiva l'inserimento dati. BLOB rinominato è supportato solo per la risorsa di archiviazione ADLSv2. Per rinominare un BLOB, passare al BLOB in portale di Azure, fare clic con il pulsante destro del mouse sul BLOB e scegliere Rinomina. I tipi supportati sono Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed.
   Creazione risorse	Automatico	Definire se si vuole che Azure Esplora dati creare una sottoscrizione di Griglia di eventi, uno spazio dei nomi di Hub eventi e un hub eventi automaticamente. Per creare manualmente le risorse, vedere Creare manualmente risorse per l'inserimento in Griglia di eventi

4. Selezionare Filtra impostazioni, se si desidera tenere traccia di oggetti specifici. Impostare i filtri per le notifiche come segue:

   • Il campo prefisso è il valore letterale del prefisso dell'oggetto. Poiché il criterio applicato è startswith, può interessare più contenitori, cartelle o BLOB. I caratteri jolly non sono consentiti.
     • Per definire un filtro per il contenitore BLOB il campo deve essere impostato come segue: /blobServices/default/containers/[container prefix].
     • Per definire un filtro per un prefisso BLOB (o una cartella in Azure Data Lake Gen2) il campo deve essere impostato come segue: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • Il campo Suffisso è il valore letterale del suffisso del BLOB. I caratteri jolly non sono consentiti.
   • Il campo con distinzione tra Maiuscole/minuscole indica se i filtri del prefisso e del suffisso distinguono tra maiuscole e minuscole
   • Per altre informazioni sull’applicazione di filtri agli eventi vedere Eventi di archiviazione BLOB.

   

5. Selezionare Avanti: Inserisci proprietà.

6. Compilare il modulo con le informazioni seguenti. I nomi di tabella e mapping fanno distinzione tra maiuscole e minuscole:

   

   Inserire proprietà:

   Impostazione	Valore consigliato	Descrizione campo
   Consentire il routing dei dati ad altri database (connessione dati multi database)	Non consentire	Attivare questa opzione se si desidera eseguire l'override del database di destinazione predefinito associato alla connessione dati. Per altre informazioni sul routing del database, vedere Routing degli eventi.
   Nome tabella	TestTable	Tabella creata in TestDatabase.
   Formato dati	JSON	I formati supportati sono Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO e W3CLOG. Le opzioni di compressione supportate sono Zip e Gzip.
   Mapping	TestMapping	Mapping creato in TestDatabase, che esegue il mapping dei dati in ingresso ai nomi di colonna e ai tipi di dati di TestTable. Se non specificato, viene usato un mapping dei dati Identity derivato dallo schema della tabella.
   Impostazioni avanzate	Dati con intestazioni	Ignorare le intestazioni. Supportato per i file di tipo *SV.

   Nota

   Non è necessario specificare tutte le impostazioni di routing predefinite. È anche possibile specificare impostazioni parziali.

7. Selezionare Avanti: Rivedi e crea

8. In *Rivedi e crea.

9. Esaminare le risorse create automaticamente e selezionare Crea.

   

10. Attendere il completamento della distribuzione. Se la distribuzione non è riuscita, selezionare Dettagli operazione accanto alla fase non riuscita per ottenere altre informazioni sul motivo dell'errore. Selezionare Ridistribuisci per provare di nuovo a distribuire le risorse. È possibile modificare i parametri prima della distribuzione.

    

Portale - Archiviazione di Azure

1. Passare all'account di archiviazione nel portale di Azure. Nel menu a sinistra selezionare Eventi

2. Nel riquadro principale selezionare la scheda Azure Esplora dati.

   

Viene visualizzato il riquadro Connessione dati con la scheda Informazioni di base selezionata.

1. In Informazioni di base compilare il modulo con le informazioni seguenti:

   

   Impostazione	Valore consigliato	Descrizione campo
   Nome connessione dati	test-grid-connection	Il nome della connessione da creare in Esplora dati di Azure.
   Account di archiviazione	gridteststorage1	Account di archiviazione da cui si è eseguito l'accesso a questa procedura guidata. Ripopolato automaticamente.
   Tipo di evento	BLOB creato o BLOB rinominato	Tipo di evento che attiva l'inserimento dati. BLOB rinominato è supportato solo per la risorsa di archiviazione ADLSv2. Per rinominare un BLOB, passare al BLOB in portale di Azure, fare clic con il pulsante destro del mouse sul BLOB e scegliere Rinomina. I tipi supportati sono Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed.
   Creazione risorse	Automatico	Definire se si vuole che Azure Esplora dati creare una sottoscrizione di Griglia di eventi, uno spazio dei nomi di Hub eventi e un hub eventi automaticamente. Per creare manualmente le risorse, vedere Creare manualmente risorse per l'inserimento in Griglia di eventi

2. Selezionare Next Ingest properties (Proprietà inserimento successivo>).

3. In Proprietà inserimento.

4. Compilare il modulo con le informazioni seguenti. I nomi di tabella e mapping fanno distinzione tra maiuscole e minuscole:

   

   Impostazione	Valore consigliato	Descrizione campo
   Abbonamento		Sottoscrizione di Azure Esplora dati.
   Nome del cluster	TestCluster	Nome del cluster in cui si desidera inserire i dati.
   Nome database	TestDatabase	Database di destinazione creato in TestCluster.
   Consentire il routing dei dati ad altri database (connessione dati multi database)	Non consentire	Attivare questa opzione se si desidera eseguire l'override del database di destinazione predefinito associato alla connessione dati. Per altre informazioni sul routing del database, vedere Routing degli eventi.
   Nome tabella	TestTable	Tabella di destinazione creata in TestDatabase.
   Formato dati	JSON	I formati supportati sono Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO e W3CLOG. Le opzioni di compressione supportate sono Zip e Gzip.
   Mapping	TestMapping	Mapping creato in TestDatabase, che esegue il mapping dei dati in ingresso ai nomi di colonna e ai tipi di dati di TestTable. Se non specificato, viene usato un mapping dei dati Identity derivato dallo schema della tabella.
   Impostazioni avanzate	Dati con intestazioni	Ignorare le intestazioni. Supportato per i file di tipo *SV.

   Nota

   Non è necessario specificare tutte le impostazioni di routing dei dati. È anche possibile specificare impostazioni parziali.

5. Selezionare Avanti: Rivedi e crea

6. In Rivedi e crea.

7. Esaminare le risorse create automaticamente e selezionare Crea.

   

8. Attendere il completamento della distribuzione. Se la distribuzione non è riuscita, selezionare Dettagli operazione accanto alla fase non riuscita per ottenere altre informazioni sul motivo dell'errore. Selezionare Ridistribuisci per provare di nuovo a distribuire le risorse. È possibile modificare i parametri prima della distribuzione.

   

C#

1. Installare il pacchetto Microsoft.Azure.Management.Kusto NuGet.

2. Creare un'entità applicazione di Azure AD da usare per l'autenticazione. Sono necessari l'ID directory (tenant), l'ID applicazione e il segreto client.

3. Eseguire il codice seguente.

   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
   );
   

   Impostazione	Valore consigliato	Descrizione campo
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID tenant. Noto anche come ID directory.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	L'ID sottoscrizione usato per la creazione di risorse.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	L'ID client dell'applicazione che può accedere alle risorse nel tenant.
   clientSecret	PlaceholderClientSecret	Il segreto client dell'applicazione che può accedere alle risorse nel tenant.
   resourceGroupName	testrg	Nome del gruppo di risorse contenente il cluster.
   clusterName	mykustocluster	Nome del cluster.
   databaseName	mykustodatabase	Nome del database di destinazione nel cluster.
   eventGridConnectionName	myeventgridconnect	Nome desiderato della connessione dati.
   tableName	StormEvents	Nome della tabella di destinazione nel database di destinazione.
   mappingRuleName	StormEvents_CSV_Mapping	Nome del mapping delle colonne correlato alla tabella di destinazione.
   dataFormat	csv	Formato dati del messaggio.
   eventHubResourceId	ID risorsa	ID risorsa dell'hub eventi in cui Griglia di eventi è configurato per l'invio di eventi.
   storageAccountResourceId	ID risorsa	ID risorsa dell'account di archiviazione che contiene i dati per l'inserimento.
   consumerGroup	$Default	Gruppo di consumer dell'hub eventi.
   posizione	Stati Uniti centrali	Posizione della risorsa di connessione dati.
   blobStorageEventType	Microsoft.Storage.BlobCreated	Tipo di evento che attiva l'inserimento dati. Gli eventi supportati sono Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed. La ridenominazione dei BLOB è supportata solo per l'archiviazione ADLSv2.
   databaseRouting	Multi o Single	Routing del database per la connessione. Se si imposta il valore su Single, la connessione dati verrà instradata a un singolo database nel cluster come specificato nell'impostazione databaseName . Se si imposta il valore su Multi, è possibile eseguire l'override del database di destinazione predefinito usando la proprietà inserimento database. Per altre informazioni, vedere Routing degli eventi.

Python

1. Installare le librerie necessarie.

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

2. Creare un'entità applicazione di Azure AD da usare per l'autenticazione. Sono necessari l'ID directory (tenant), l'ID applicazione e il segreto client.

3. Eseguire il codice seguente.

   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())
   

   Impostazione	Valore consigliato	Descrizione campo
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID tenant. Noto anche come ID directory.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	L'ID sottoscrizione usato per la creazione di risorse.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	L'ID client dell'applicazione che può accedere alle risorse nel tenant.
   client_secret	xxxxxxxxxxxxxx	Il segreto client dell'applicazione che può accedere alle risorse nel tenant.
   resource_group_name	testrg	Nome del gruppo di risorse contenente il cluster.
   cluster_name	mykustocluster	Nome del cluster.
   database_name	mykustodatabase	Nome del database di destinazione nel cluster.
   data_connection_name	myeventhubconnect	Nome desiderato della connessione dati.
   table_name	StormEvents	Nome della tabella di destinazione nel database di destinazione.
   mapping_rule_name	StormEvents_CSV_Mapping	Nome del mapping delle colonne relativo alla tabella di destinazione.
   database_routing	Multi o Single	Routing del database per la connessione. Se si imposta il valore su Single, la connessione dati verrà instradata a un singolo database nel cluster come specificato nell'impostazione databaseName . Se si imposta il valore su Multi, è possibile eseguire l'override del database di destinazione predefinito usando la proprietà inserimento database. Per altre informazioni, vedere Routing degli eventi.
   data_format	csv	Formato dei dati del messaggio.
   event_hub_resource_id	ID risorsa	ID risorsa dell'hub eventi in cui Griglia di eventi è configurato per l'invio di eventi.
   storage_account_resource_id	ID risorsa	ID risorsa dell'account di archiviazione che contiene i dati per l'inserimento.
   consumer_group	$Default	Gruppo di consumer dell'hub eventi.
   posizione	Stati Uniti centrali	Posizione della risorsa di connessione dati.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	Tipo di evento che attiva l'inserimento dati. Gli eventi supportati sono Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed. La ridenominazione dei BLOB è supportata solo per l'archiviazione ADLSv2.

Modello ARM

L'esempio seguente illustra un modello di Azure Resource Manager per l'aggiunta di una connessione dati di Griglia di eventi. È possibile modificare e distribuire il modello nel portale di Azure usando il modulo.

{
    "$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')]"
            }
        }
    ]
}

Rimuovere una connessione dati di Griglia di eventi

Portale

Per rimuovere la connessione di Griglia di eventi dal portale di Azure, eseguire le operazioni seguenti:

1. Passare al cluster. Nel menu a sinistra selezionare Database. Selezionare quindi il database contenente la tabella di destinazione.
2. Dal menu a sinistra selezionare Connessioni dati. Selezionare quindi la casella di controllo accanto alla connessione dati di Griglia di eventi pertinente.
3. Nella barra dei menu in alto selezionare Elimina.

C#

Per rimuovere la connessione di Griglia di eventi, eseguire il comando seguente:

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

Python

Per rimuovere la connessione di Griglia di eventi, eseguire il comando seguente:

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)

Passaggi successivi

• Elaborare i dati dall'hub eventi usando Analisi di flusso di Azure