Tworzenie połączenia danych usługi Event Grid dla usługi Azure Data Explorer

Z tego artykułu dowiesz się, jak pozyskiwać obiekty blob z konta magazynu do usługi Azure Data Explorer przy użyciu połączenia danych usługi Event Grid. Utworzysz połączenie danych usługi Event Grid, które ustawia subskrypcję usługi Azure Event Grid . Subskrypcja usługi Event Grid kieruje zdarzenia z konta magazynu do usługi Azure Data Explorer za pośrednictwem usługi Azure Event Hubs.

Aby uzyskać ogólne informacje na temat pozyskiwania do usługi Azure Data Explorer z usługi Event Grid, zobacz Nawiązywanie połączenia z usługą Event Grid.

Uwaga

Aby uzyskać najlepszą wydajność połączenia usługi Event Grid, ustaw rawSizeBytes właściwość pozyskiwania za pośrednictwem metadanych obiektu blob. Aby uzyskać więcej informacji, zobacz właściwości pozyskiwania.

Wymagania wstępne

• Subskrypcja platformy Azure. Utwórz bezpłatne konto platformy Azure.
• Baza danych i klaster usługi Azure Data Explorer. Utwórz klaster i bazę danych.
• Tabela docelowa. Utwórz tabelę lub użyj istniejącej tabeli.
• Mapowanie pozyskiwania dla tabeli.
• Konto magazynu. Subskrypcję powiadomień usługi Event Grid można ustawić na kontach usługi Azure Storage dla BlobStorageusługi , StorageV2lub Usługi Data Lake Storage Gen2.

Tworzenie połączenia danych usługi Event Grid

W tej sekcji ustanowisz połączenie między usługą Event Grid i tabelą usługi Azure Data Explorer.

Portal — Azure Data Explorer

1. W obszarze utworzonego klastra wybierz pozycję Bazy danych>TestDatabase.

   

2. Wybierz pozycję Pozyskiwanie>danych Dodaj połączenie danych.

   

3. W obszarze Podstawy wybierz typ połączenia: Blob Storage , a następnie wypełnij formularz następującymi informacjami:

   

   Ustawienie	Sugerowana wartość	Opis pola
   Nazwa połączenia danych	test-grid-connection	Nazwa połączenia, które chcesz utworzyć w usłudze Azure Data Explorer.
   Subskrypcja konta magazynu	Identyfikator Twojej subskrypcji	Identyfikator subskrypcji, w której znajduje się twoje konto magazynu.
   Konto magazynu	gridteststorage1	Nazwa utworzonego wcześniej konta magazynu.
   Typ zdarzenia	Utworzono obiekt blob lub zmieniono nazwę obiektu blob	Typ zdarzenia wyzwalającego pozyskiwanie. Zmiana nazwy obiektu blob jest obsługiwana tylko w przypadku magazynu ADLSv2. Aby zmienić nazwę obiektu blob, przejdź do obiektu blob w witrynie Azure Portal, kliknij prawym przyciskiem myszy obiekt blob i wybierz polecenie Zmień nazwę. Obsługiwane typy to: Microsoft.Storage.BlobCreated lub Microsoft.Storage.BlobRenamed.
   Tworzenie zasobów	Automatyczna	Określ, czy chcesz, aby usługa Azure Data Explorer utworzyła subskrypcję usługi Event Grid, przestrzeń nazw usługi Event Hubs i usługę Event Hubs. Aby ręcznie utworzyć zasoby, zobacz Ręczne tworzenie zasobów na potrzeby pozyskiwania usługi Event Grid

4. Wybierz pozycję Ustawienia filtru, jeśli chcesz śledzić określone tematy. Filtry dla powiadomień ustaw w następujący sposób:

   • Pole prefiksu jest prefiksem literału tematu. W miarę jak stosowany wzorzec rozpoczyna się od, może obejmować wiele kontenerów, folderów lub obiektów blob. Symbole wieloznaczne nie są dozwolone.
     • Aby zdefiniować filtr w kontenerze obiektów blob, należy ustawić pole w następujący sposób: /blobServices/default/containers/[container prefix].
     • Aby zdefiniować filtr prefiksu obiektu blob (lub folderu w usłudze Azure Data Lake Gen2), pole musi być ustawione w następujący sposób: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • Pole sufiksu jest sufiksem literału obiektu blob. Symbole wieloznaczne nie są dozwolone.
   • Pole Wrażliwe na wielkość liter wskazuje, czy w filtrach prefiksu i sufiksu uwzględniana jest wielkość liter
   • Aby uzyskać więcej informacji na temat filtrowania zdarzeń, zobacz Zdarzenia usługi Blob Storage.

   

5. Wybierz pozycję Dalej: pozyskiwanie właściwości.

6. Wypełnij formularz, używając poniższych informacji. W nazwach tabel i mapowań uwzględniana jest wielkość liter:

   

   Właściwości pozyskiwania:

   Ustawienie	Sugerowana wartość	Opis pola
   Zezwalaj na kierowanie danych do innych baz danych (połączenie danych z wieloma bazami danych)	Nie zezwalaj	Włącz tę opcję, jeśli chcesz zastąpić domyślną docelową bazę danych skojarzona z połączeniem danych. Aby uzyskać więcej informacji na temat routingu bazy danych, zobacz Routing zdarzeń.
   Nazwa tabeli	TestTable	Tabela utworzona przez Ciebie w obszarze TestDatabase.
   Format danych	JSON	Obsługiwane formaty to Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW i W3CLOG. Obsługiwane opcje kompresji to Zip i Gzip.
   Mapowanie	TestMapping	Mapowanie utworzone w bazie danych TestDatabase, które mapuje dane przychodzące na nazwy kolumn i typy danych tabeli TestTable. Jeśli nie zostanie określony, zostanie użyte mapowanie danych tożsamości pochodzące ze schematu tabeli.
   Ustawienia zaawansowane	Moje dane mają nagłówki	Ignoruje nagłówki. Obsługiwane w przypadku plików typu *SV.

   Uwaga

   Nie musisz określać wszystkich domyślnych ustawień routingu. Ustawienia częściowe są również akceptowane.

7. Wybierz pozycję Dalej: Przejrzyj i utwórz

8. W obszarze *Przejrzyj i utwórz.

9. Przejrzyj zasoby, które zostały utworzone automatycznie, a następnie wybierz pozycję Utwórz.

   

10. Poczekaj na zakończenie wdrożenia. Jeśli wdrożenie nie powiodło się, wybierz pozycję Szczegóły operacji obok etapu niepowodzenia, aby uzyskać więcej informacji z przyczyny niepowodzenia. Wybierz pozycję Wdróż ponownie, aby spróbować ponownie wdrożyć zasoby. Parametry można zmienić przed wdrożeniem.

    

Portal — Azure Storage

1. Przejdź do konta magazynu w witrynie Azure Portal. W menu po lewej stronie wybierz pozycję Zdarzenia

2. W okienku głównym wybierz kartę Azure Data Explorer .

   

Zostanie otwarte okienko Połączenie danych z wybraną kartą Podstawowe .

1. W obszarze Podstawy wypełnij formularz następującymi informacjami:

   

   Ustawienie	Sugerowana wartość	Opis pola
   Nazwa połączenia danych	test-grid-connection	Nazwa połączenia, które chcesz utworzyć w usłudze Azure Data Explorer.
   Konto magazynu	gridteststorage1	Konto magazynu, z którego uzyskiwano dostęp do tego kreatora. Automatycznie wypełniane.
   Typ zdarzenia	Utworzono obiekt blob lub zmieniono nazwę obiektu blob	Typ zdarzenia wyzwalającego pozyskiwanie. Zmiana nazwy obiektu blob jest obsługiwana tylko w przypadku magazynu ADLSv2. Aby zmienić nazwę obiektu blob, przejdź do obiektu blob w witrynie Azure Portal, kliknij prawym przyciskiem myszy obiekt blob i wybierz polecenie Zmień nazwę. Obsługiwane typy to: Microsoft.Storage.BlobCreated lub Microsoft.Storage.BlobRenamed.
   Tworzenie zasobów	Automatyczna	Określ, czy chcesz, aby usługa Azure Data Explorer utworzyła subskrypcję usługi Event Grid, przestrzeń nazw usługi Event Hubs i usługę Event Hubs. Aby ręcznie utworzyć zasoby, zobacz Ręczne tworzenie zasobów na potrzeby pozyskiwania usługi Event Grid

2. Wybierz pozycję Następne> pozyskiwanie właściwości.

3. W obszarze Właściwości pozyskiwania.

4. Wypełnij formularz, używając poniższych informacji. W nazwach tabel i mapowań uwzględniana jest wielkość liter:

   

   Ustawienie	Sugerowana wartość	Opis pola
   Subskrypcja		Subskrypcja usługi Azure Data Explorer.
   Nazwa klastra	TestCluster	Nazwa klastra, w którym chcesz pozyskiwać dane.
   Nazwa bazy danych	TestDatabase	Docelowa baza danych utworzona w narzędziu TestCluster.
   Zezwalaj na kierowanie danych do innych baz danych (połączenie danych z wieloma bazami danych)	Nie zezwalaj	Włącz tę opcję, jeśli chcesz zastąpić domyślną docelową bazę danych skojarzona z połączeniem danych. Aby uzyskać więcej informacji na temat routingu bazy danych, zobacz Routing zdarzeń.
   Nazwa tabeli	TestTable	Tabela docelowa utworzona w bazie danych TestDatabase.
   Format danych	JSON	Obsługiwane formaty to Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW i W3CLOG. Obsługiwane opcje kompresji to Zip i Gzip.
   Mapowanie	TestMapping	Mapowanie utworzone w bazie danych TestDatabase, które mapuje dane przychodzące na nazwy kolumn i typy danych tabeli TestTable. Jeśli nie zostanie określony, zostanie użyte mapowanie danych tożsamości pochodzące ze schematu tabeli.
   Ustawienia zaawansowane	Moje dane mają nagłówki	Ignoruje nagłówki. Obsługiwane w przypadku plików typu *SV.

   Uwaga

   Nie musisz określać wszystkich ustawień routingu danych. Ustawienia częściowe są również akceptowane.

5. Wybierz pozycję Dalej: Przejrzyj i utwórz

6. W obszarze Przeglądanie i tworzenie.

7. Przejrzyj zasoby, które zostały utworzone automatycznie, a następnie wybierz pozycję Utwórz.

   

8. Poczekaj na zakończenie wdrożenia. Jeśli wdrożenie nie powiodło się, wybierz pozycję Szczegóły operacji obok etapu niepowodzenia, aby uzyskać więcej informacji z przyczyny niepowodzenia. Wybierz pozycję Wdróż ponownie, aby spróbować ponownie wdrożyć zasoby. Parametry można zmienić przed wdrożeniem.

   

C#

1. Zainstaluj pakiet NuGet Microsoft.Azure.Management.Kusto.

2. Utwórz jednostkę aplikacji usługi Azure AD do użycia na potrzeby uwierzytelniania. Będziesz potrzebować identyfikatora katalogu (dzierżawy), identyfikatora aplikacji i klucza tajnego klienta.

3. Uruchom następujący kod.

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

   Ustawienie	Sugerowana wartość	Opis pola
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator dzierżawy. Znany również jako identyfikator katalogu.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator subskrypcji używany do tworzenia zasobów.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator klienta aplikacji, która może uzyskiwać dostęp do zasobów w dzierżawie.
   clientSecret	Symbol zastępczyClientSecret	Klucz tajny klienta aplikacji, który może uzyskiwać dostęp do zasobów w dzierżawie.
   resourceGroupName	testrg	Nazwa grupy zasobów zawierającej klaster.
   clusterName	mykustocluster	Nazwa klastra.
   databaseName	mykustodatabase	Nazwa docelowej bazy danych w klastrze.
   eventGridConnectionName	myeventgridconnect	Żądana nazwa połączenia danych.
   tableName	StormEvents	Nazwa tabeli docelowej w docelowej bazie danych.
   mappingRuleName	StormEvents_CSV_Mapping	Nazwa mapowania kolumny powiązana z tabelą docelową.
   dataFormat	csv	Format danych wiadomości.
   eventHubResourceId	Identyfikator zasobu	Identyfikator zasobu centrum zdarzeń, w którym usługa Event Grid jest skonfigurowana do wysyłania zdarzeń.
   storageAccountResourceId	Identyfikator zasobu	Identyfikator zasobu konta magazynu, który przechowuje dane do pozyskiwania.
   consumerGroup	$Default	Grupa odbiorców centrum zdarzeń.
   lokalizacja	Środkowe stany USA	Lokalizacja zasobu połączenia danych.
   blobStorageEventType	Microsoft.Storage.BlobCreated	Typ zdarzenia wyzwalającego pozyskiwanie. Obsługiwane zdarzenia to: Microsoft.Storage.BlobCreated lub Microsoft.Storage.BlobRenamed. Zmiana nazw obiektów blob jest obsługiwana tylko w przypadku magazynu ADLSv2.
   databaseRouting	Wiele lub pojedynczy	Routing bazy danych dla połączenia. Jeśli ustawisz wartość Na pojedynczą, połączenie danych zostanie przekierowane do pojedynczej bazy danych w klastrze, jak określono w ustawieniu databaseName . Jeśli ustawisz wartość Na wiele, możesz zastąpić domyślną docelową bazę danych przy użyciu właściwości Pozyskiwanie bazy danych. Aby uzyskać więcej informacji, zobacz Routing zdarzeń.

Python

1. Zainstaluj wymagane biblioteki.

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

2. Utwórz jednostkę aplikacji usługi Azure AD do użycia na potrzeby uwierzytelniania. Będziesz potrzebować identyfikatora katalogu (dzierżawy), identyfikatora aplikacji i klucza tajnego klienta.

3. Uruchom następujący kod.

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

   Ustawienie	Sugerowana wartość	Opis pola
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator dzierżawy. Znany również jako identyfikator katalogu.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator subskrypcji używany do tworzenia zasobów.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator klienta aplikacji, która może uzyskiwać dostęp do zasobów w dzierżawie.
   client_secret	xxxxxxxxxxxxxxxx	Klucz tajny klienta aplikacji, który może uzyskiwać dostęp do zasobów w dzierżawie.
   resource_group_name	testrg	Nazwa grupy zasobów zawierającej klaster.
   cluster_name	mykustocluster	Nazwa klastra.
   database_name	mykustodatabase	Nazwa docelowej bazy danych w klastrze.
   data_connection_name	myeventhubconnect	Żądana nazwa połączenia danych.
   table_name	StormEvents	Nazwa tabeli docelowej w docelowej bazie danych.
   mapping_rule_name	StormEvents_CSV_Mapping	Nazwa mapowania kolumny powiązana z tabelą docelową.
   database_routing	Wiele lub pojedynczy	Routing bazy danych dla połączenia. Jeśli ustawisz wartość Na pojedynczą, połączenie danych zostanie przekierowane do pojedynczej bazy danych w klastrze, jak określono w ustawieniu databaseName . Jeśli ustawisz wartość Na wiele, możesz zastąpić domyślną docelową bazę danych przy użyciu właściwości Pozyskiwanie bazy danych. Aby uzyskać więcej informacji, zobacz Routing zdarzeń.
   data_format	csv	Format danych wiadomości.
   event_hub_resource_id	Identyfikator zasobu	Identyfikator zasobu centrum zdarzeń, w którym usługa Event Grid jest skonfigurowana do wysyłania zdarzeń.
   storage_account_resource_id	Identyfikator zasobu	Identyfikator zasobu konta magazynu, który przechowuje dane do pozyskiwania.
   consumer_group	$Default	Grupa odbiorców centrum zdarzeń.
   lokalizacja	Środkowe stany USA	Lokalizacja zasobu połączenia danych.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	Typ zdarzenia wyzwalającego pozyskiwanie. Obsługiwane zdarzenia to: Microsoft.Storage.BlobCreated lub Microsoft.Storage.BlobRenamed. Zmiana nazw obiektów blob jest obsługiwana tylko w przypadku magazynu ADLSv2.

Szablon usługi ARM

Poniższy przykład przedstawia szablon usługi Azure Resource Manager do dodawania połączenia danych usługi Event Grid. Szablon można edytować i wdrożyć w witrynie Azure Portal przy użyciu formularza.

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

Usuwanie połączenia danych usługi Event Grid

Portal

Aby usunąć połączenie usługi Event Grid z witryny Azure Portal, wykonaj następujące czynności:

1. Przejdź do klastra. W menu po lewej stronie wybierz pozycję Bazy danych. Następnie wybierz bazę danych zawierającą tabelę docelową.
2. W menu po lewej stronie wybierz pozycję Połączenia danych. Następnie zaznacz pole wyboru obok odpowiedniego połączenia danych usługi Event Grid.
3. Na górnym pasku menu wybierz pozycję Usuń.

C#

Aby usunąć połączenie usługi Event Grid, uruchom następujące polecenie:

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

Python

Aby usunąć połączenie usługi Event Grid, uruchom następujące polecenie:

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)

Następne kroki

• Przetwarzanie danych z centrum zdarzeń przy użyciu usługi Azure Stream Analytics