Erstellen einer Event Grid-Datenverbindung für Azure Data Explorer

In diesem Artikel erfahren Sie, wie Blobs aus Ihrem Speicherkonto unter Verwendung einer Event Grid-Datenverbindung in Azure Data Explorer erfasst werden. Sie erstellen eine Event Grid-Datenverbindung, über die ein Azure Event Grid-Abonnement festgelegt wird. Das Event Grid-Abonnement leitet Ereignisse aus Ihrem Speicherkonto über Azure Event Hubs an Azure Data Explorer weiter.

Allgemeine Informationen zur Erfassung in Azure Data Explorer aus Event Grid finden Sie unter Herstellen einer Verbindung mit Event Grid.

Hinweis

Um die beste Leistung mit der Event Grid-Verbindung zu erzielen, legen Sie die rawSizeBytes Erfassungseigenschaft über die Blobmetadaten fest. Weitere Informationen finden Sie unter Erfassungseigenschaften.

Voraussetzungen

• Ein Azure-Abonnement. Erstellen Sie ein kostenloses Azure-Konto.
• Ein Azure Data Explorer-Cluster und eine Datenbank Erstellen eines Clusters und einer Datenbank
• Eine Zieltabelle. Erstellen Sie eine Tabelle , oder verwenden Sie eine vorhandene Tabelle.
• Eine Erfassungszuordnung für die Tabelle.
• Ein Speicherkonto. Ein Event Grid-Benachrichtigungsabonnement kann für Azure Storage-Konten für BlobStorage, StorageV2oder Data Lake Storage Gen2 festgelegt werden.

Erstellen einer Event Grid-Datenverbindung

In diesem Abschnitt stellen Sie eine Verbindung zwischen Event Grid und Ihrer Azure-Data Explorer-Tabelle her.

Portal: Azure Data Explorer

1. Wählen Sie unter dem von Ihnen erstellten Cluster DatenbankenTestDatabase.

   

2. Wählen Sie DatenerfassungDatenverbindung hinzufügen.

   

3. Wählen Sie unter Grundlagen den Verbindungstyp aus: Blob-Speicher und füllen Sie dann das Formular mit den folgenden Informationen aus:

   

   Einstellung	Empfohlener Wert	Feldbeschreibung
   Name der Datenverbindung	test-grid-connection	Der Name der Verbindung, die Sie im Azure Data Explorer erstellen möchten.
   Speicherkontoabonnement	Ihre Abonnement-ID	Die Abonnement-ID, unter der sich Ihr Speicherkonto befindet.
   Speicherkonto	gridteststorage1	Der Name des zuvor erstellten Speicherkontos.
   Ereignistyp	Blob erstellt oder Blob umbenannt	Der Typ des Ereignisses, das die Erfassung auslöst Blob umbenannt wird nur für ADLSv2-Speicher unterstützt. Um ein Blob umzubenennen, navigieren Sie in Azure-Portal zum Blob, klicken Sie mit der rechten Maustaste auf das Blob, und wählen Sie Umbenennen aus. Folgende Typen werden unterstützt: „Microsoft.Storage.BlobCreated“ oder „Microsoft.Storage.BlobRenamed“.
   Ressourcenerstellung	Automatisch	Legen Sie fest, ob mit Azure Data Explorer ein Event Grid-Abonnement, Event Hubs-Namespace und eine Event Hubs-Instanz für Sie erstellt werden soll. Informationen zur manuellen Erstellung von Ressourcen finden Sie unter Manuelles Erstellen von Ressourcen für die Event Grid-Erfassung.

4. Wählen Sie Filtereinstellungen aus, wenn Sie bestimmte Themen nachverfolgen möchten. Legen Sie die Filter für die Benachrichtigungen wie folgt fest:

   • Das Feld Präfix ist das Literalpräfix des Themas. Da das angewendete Muster startswith ist, kann es für mehrere Container, Ordner oder Blobs gelten. Platzhalter sind nicht zulässig.
     • Zum Definieren eines Filters für den Blobcontainer muss das Feld wie folgt festgelegt werden: .
     • Zum Definieren eines Filters für ein Blobpräfix (oder einen Ordner in Azure Data Lake Gen2) muss das Feld wie folgt festgelegt werden: .
   • Das Feld Suffix ist das Literalsuffix des Blobs. Platzhalter sind nicht zulässig.
   • Mit dem Feld Groß-/Kleinschreibung beachten wird angegeben, ob bei den Präfix- und Suffixfiltern nach Groß-/Kleinschreibung unterschieden wird.
   • Weitere Informationen zum Filtern von Ereignissen finden Sie unter Blob Storage-Ereignisse.

   

5. Klicken Sie auf Weiter: Erfassungseigenschaften.

6. Füllen Sie das Formular mit den folgenden Informationen aus. Für Tabellen- und Zuordnungsnamen wird die Groß-/Kleinschreibung beachtet:

   

   Erfassungseigenschaften:

   Einstellung	Empfohlener Wert	Feldbeschreibung
   Weiterleiten der Daten an andere Datenbanken zulassen (Datenverbindung mit mehreren Datenbanken)	Nicht zulassen	Aktivieren Sie diese Option, wenn Sie die Standardzieldatenbank überschreiben möchten, die der Datenverbindung zugeordnet ist. Weitere Informationen zum Datenbankrouting finden Sie unter Ereignisrouting.
   Tabellenname	TestTable	Die Tabelle, die Sie unter TestDatabase erstellt haben.
   Datenformat	JSON	Die unterstützten Formate sind Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW und W3CLOG. Die unterstützten Komprimierungsoptionen sind Zip und GZip.
   Zuordnung	TestMapping	Die Zuordnung, die Sie in TestDatabase erstellt haben, um eingehende Daten den Spaltennamen und Datentypen von TestTable zuzuordnen. Wenn nicht angegeben, wird eine identitätsdatenzuordnung, die aus dem Schema der Tabelle abgeleitet ist, verwendet.
   Erweiterte Einstellungen	Die Daten haben Überschriften.	Ignoriert Überschriften. Unterstützt für Dateien vom Typ „*SV“.

   Hinweis

   Sie müssen nicht alle Standardroutingeinstellungen angeben. Es ist auch zulässig, nur einen Teil der Einstellungen anzugeben.

7. Wählen Sie Weiter: Überprüfen + erstellen aus.

8. Unter *Überprüfen + erstellen.

9. Überprüfen Sie die Ressourcen, die automatisch für Sie erstellt wurden, und wählen Sie Erstellen aus.

   

10. Warten Sie, bis die Bereitstellung abgeschlossen wurde. Wenn bei Ihrer Bereitstellung ein Fehler aufgetreten ist, können Sie neben der fehlerhaften Phase auf Vorgangsdetails klicken, um weitere Informationen zur Fehlerursache anzuzeigen. Sie können auch Erneut bereitstellen auswählen, um die Bereitstellung der Ressourcen zu wiederholen. Sie können die Parameter vor der Bereitstellung ändern.

    

Portal : Azure Storage

1. Navigieren Sie im Azure-Portal zum Speicherkonto. Wählen Sie im linken Menü die Option Ereignisse aus.

2. Wählen Sie im Hauptbereich die Registerkarte Azure Data Explorer aus.

   

Der Bereich Datenverbindung wird geöffnet, und die Registerkarte Grundlagen ist ausgewählt.

1. Füllen Sie unter Grundlagen das Formular mit den folgenden Informationen aus.

   

   Einstellung	Empfohlener Wert	Feldbeschreibung
   Name der Datenverbindung	test-grid-connection	Der Name der Verbindung, die Sie im Azure Data Explorer erstellen möchten.
   Speicherkonto	gridteststorage1	Das Speicherkonto, über das Sie auf diesen Assistenten zugegriffen haben. Wird automatisch aufgefüllt.
   Ereignistyp	Blob erstellt oder Blob umbenannt	Der Typ des Ereignisses, das die Erfassung auslöst Blob umbenannt wird nur für ADLSv2-Speicher unterstützt. Navigieren Sie zum Umbenennen eines Blobs zum Blob in Azure-Portal, klicken Sie mit der rechten Maustaste auf das Blob, und wählen Sie Umbenennen aus. Folgende Typen werden unterstützt: „Microsoft.Storage.BlobCreated“ oder „Microsoft.Storage.BlobRenamed“.
   Ressourcenerstellung	Automatisch	Legen Sie fest, ob mit Azure Data Explorer ein Event Grid-Abonnement, Event Hubs-Namespace und eine Event Hubs-Instanz für Sie erstellt werden soll. Informationen zur manuellen Erstellung von Ressourcen finden Sie unter Manuelles Erstellen von Ressourcen für die Event Grid-Erfassung.

2. Wählen Sie die Option Weiter> Erfassungseigenschaften aus.

3. Unter Eigenschaften erfassen.

4. Füllen Sie das Formular mit den folgenden Informationen aus. Für Tabellen- und Zuordnungsnamen wird die Groß-/Kleinschreibung beachtet:

   

   Einstellung	Empfohlener Wert	Feldbeschreibung
   Subscription		Ihr Azure Data Explorer-Abonnement
   Clustername	TestCluster	Der Name des Clusters, in dem Sie Daten erfassen möchten
   Datenbankname	TestDatabase	Die Zieldatenbank, die Sie unter TestCluster erstellt haben
   Weiterleiten der Daten an andere Datenbanken zulassen (Datenverbindung mit mehreren Datenbanken)	Nicht zulassen	Aktivieren Sie diese Option, wenn Sie die Standardzieldatenbank überschreiben möchten, die der Datenverbindung zugeordnet ist. Weitere Informationen zum Datenbankrouting finden Sie unter Ereignisrouting.
   Tabellenname	TestTable	Die Zieltabelle, die Sie unter TestDatabase erstellt haben
   Datenformat	JSON	Die unterstützten Formate sind Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW und W3CLOG. Die unterstützten Komprimierungsoptionen sind Zip und GZip.
   Zuordnung	TestMapping	Die Zuordnung, die Sie in TestDatabase erstellt haben, um eingehende Daten den Spaltennamen und Datentypen von TestTable zuzuordnen. Wenn nicht angegeben, wird eine identitätsdatenzuordnung, die aus dem Schema der Tabelle abgeleitet ist, verwendet.
   Erweiterte Einstellungen	Die Daten haben Überschriften.	Ignoriert Überschriften. Unterstützt für Dateien vom Typ „*SV“.

   Hinweis

   Sie müssen nicht alle Datenroutingeinstellungen angeben. Es ist auch zulässig, nur einen Teil der Einstellungen anzugeben.

5. Wählen Sie Weiter: Überprüfen + erstellen aus.

6. Unter Überprüfen + erstellen.

7. Überprüfen Sie die Ressourcen, die automatisch für Sie erstellt wurden, und wählen Sie Erstellen aus.

   

8. Warten Sie, bis die Bereitstellung abgeschlossen wurde. Wenn bei Ihrer Bereitstellung ein Fehler aufgetreten ist, können Sie neben der fehlerhaften Phase auf Vorgangsdetails klicken, um weitere Informationen zur Fehlerursache anzuzeigen. Sie können auch Erneut bereitstellen auswählen, um die Bereitstellung der Ressourcen zu wiederholen. Sie können die Parameter vor der Bereitstellung ändern.

   

C#

1. Installieren Sie das NuGet-Paket Microsoft.Azure.Management.Kusto.

2. Erstellen Sie einen Azure AD-Anwendungsprinzipal , der für die Authentifizierung verwendet werden soll. Sie benötigen die Verzeichnis-ID (Mandanten-ID), die Anwendungs-ID und den geheimen Clientschlüssel.

3. Führen Sie den folgenden Code aus.

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

   Einstellung	Empfohlener Wert	Feldbeschreibung
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Ihre Mandanten-ID. Wird auch als Verzeichnis-ID bezeichnet.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Die Abonnement-ID, die Sie für die Ressourcenerstellung verwenden.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Die Client-ID der Anwendung, die auf Ressourcen in Ihrem Mandanten zugreifen kann.
   clientSecret	PlaceholderClientSecret	Das Clientgeheimnis der Anwendung, die auf Ressourcen in Ihrem Mandanten zugreifen kann.
   resourceGroupName	testrg	Der Name der Ressourcengruppe, die Ihren Cluster enthält.
   clusterName	mykustocluster	Der Name Ihres Clusters.
   databaseName	mykustodatabase	Der Name der Zieldatenbank in Ihrem Cluster.
   eventGridConnectionName	myeventgridconnect	Der gewünschte Name Ihrer Datenverbindung.
   tableName	StormEvents	Der Name der Zieltabelle in der Zieldatenbank.
   mappingRuleName	StormEvents_CSV_Mapping	Der Name der Spaltenzuordnung, die mit der Zieltabelle verknüpft ist.
   dataFormat	csv	Das Datenformat der Nachricht.
   eventHubResourceId	Ressourcen-ID	Die Ressourcen-ID Ihres Event Hubs, in dem Event Grid für das Senden von Ereignissen konfiguriert ist
   storageAccountResourceId	Ressourcen-ID	Die Ressourcen-ID Ihres Speicherkontos, das die Daten für die Erfassung enthält.
   consumerGroup	$Default	Die Consumergruppe Ihres Event Hubs.
   location	USA, Mitte	Der Speicherort der Datenverbindungsressource.
   blobStorageEventType	Microsoft.Storage.BlobCreated	Der Typ des Ereignisses, das die Erfassung auslöst Folgende Ereignisse werden unterstützt: „Microsoft.Storage.BlobCreated“ oder „Microsoft.Storage.BlobRenamed“. Das Umbenennen von Blobs wird nur für ADLSv2-Speicher unterstützt.
   databaseRouting	Multi oder Single	Das Datenbankrouting für die Verbindung. Wenn Sie den Wert auf Single festlegen, wird die Datenverbindung wie in der Einstellung databaseName angegeben an eine einzelne Datenbank im Cluster geroutet. Wenn Sie den Wert auf Multi festlegen, können Sie die Standardzieldatenbank mithilfe der ErfassungseigenschaftDatabase überschreiben. Weitere Informationen finden Sie unter Ereignisrouting.

Python

1. Installieren Sie die erforderlichen Bibliotheken.

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

2. Erstellen Sie einen Azure AD-Anwendungsprinzipal , der für die Authentifizierung verwendet werden soll. Sie benötigen die Verzeichnis-ID (Mandanten-ID), die Anwendungs-ID und den geheimen Clientschlüssel.

3. Führen Sie den folgenden Code aus.

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

   Einstellung	Empfohlener Wert	Feldbeschreibung
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Ihre Mandanten-ID. Wird auch als Verzeichnis-ID bezeichnet.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Die Abonnement-ID, die Sie für die Ressourcenerstellung verwenden.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Die Client-ID der Anwendung, die auf Ressourcen in Ihrem Mandanten zugreifen kann.
   client_secret	xxxxxxxxxxxxxx	Das Clientgeheimnis der Anwendung, die auf Ressourcen in Ihrem Mandanten zugreifen kann.
   resource_group_name	testrg	Der Name der Ressourcengruppe, die Ihren Cluster enthält.
   cluster_name	mykustocluster	Der Name Ihres Clusters.
   database_name	mykustodatabase	Der Name der Zieldatenbank in Ihrem Cluster.
   data_connection_name	myeventhubconnect	Der gewünschte Name Ihrer Datenverbindung.
   table_name	StormEvents	Der Name der Zieltabelle in der Zieldatenbank.
   mapping_rule_name	StormEvents_CSV_Mapping	Der Name der Spaltenzuordnung, die mit der Zieltabelle verknüpft ist.
   database_routing	Multi oder Single	Das Datenbankrouting für die Verbindung. Wenn Sie den Wert auf Single festlegen, wird die Datenverbindung wie in der Einstellung databaseName angegeben an eine einzelne Datenbank im Cluster geroutet. Wenn Sie den Wert auf Multi festlegen, können Sie die Standardzieldatenbank mithilfe der ErfassungseigenschaftDatabase überschreiben. Weitere Informationen finden Sie unter Ereignisrouting.
   data_format	csv	Das Datenformat der Nachricht.
   event_hub_resource_id	Ressourcen-ID	Die Ressourcen-ID Ihres Event Hubs, in dem Event Grid für das Senden von Ereignissen konfiguriert ist
   storage_account_resource_id	Ressourcen-ID	Die Ressourcen-ID Ihres Speicherkontos, das die Daten für die Erfassung enthält.
   consumer_group	$Default	Die Consumergruppe Ihres Event Hubs.
   location	USA, Mitte	Der Speicherort der Datenverbindungsressource.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	Der Typ des Ereignisses, das die Erfassung auslöst Folgende Ereignisse werden unterstützt: „Microsoft.Storage.BlobCreated“ oder „Microsoft.Storage.BlobRenamed“. Das Umbenennen von Blobs wird nur für ADLSv2-Speicher unterstützt.

ARM-Vorlage

Das folgende Beispiel zeigt eine Azure Resource Manager-Vorlage für das Hinzufügen einer Event Grid-Datenverbindung. Sie können die Vorlage im Azure-Portal mithilfe des Formulars bearbeiten und bereitstellen.

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

Entfernen einer Event Grid-Datenverbindung

Portal

Gehen Sie wie folgt vor, um die Event Grid-Verbindung aus dem Azure-Portal zu entfernen:

1. Zum Custer wechseln Wählen Sie im Menü auf der linken Seite Datenbanken aus. Wählen Sie dann die Datenbank aus, die die Zieltabelle enthält.
2. Wählen Sie im Menü auf der linken Seite Datenverbindungen aus. Aktivieren Sie dann das Kontrollkästchen neben der relevanten Event Grid-Datenverbindung.
3. Wählen Sie in der oberen Menüleiste Löschen aus.

C#

Führen Sie den folgenden Befehl aus, um die Event Grid-Verbindung zu entfernen:

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

Python

Führen Sie den folgenden Befehl aus, um die Event Grid-Verbindung zu entfernen:

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)

Nächste Schritte

• Verarbeiten von Daten aus einem Event Hub mit Azure Stream Analytics