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

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

   

2. Wybierz pozycję Pozyskiwanie> danychDodaj 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-połączenia-sieciowego	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	Automatyka	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 Prefix jest dosłownym prefiksem podmiotu. Ponieważ zastosowany wzorzec to startswith, 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 dosłownym sufiksem obiektu blob. Symbole wieloznaczne nie są dozwolone.
   • Pole Uwzględniające wielkość liter wskazuje, czy w filtrach prefiksu i sufiksu rozróżniana jest wielkość liter
   • Aby uzyskać więcej informacji na temat filtrowania zdarzeń, zobacz Zdarzenia usługi Blob Storage.

   

5. Wybierz pozycję Dalej: Dodawanie 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 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	Mapowanie testowe	Mapowanie, które utworzyłeś w TestDatabase, przyporządkowuje przychodzące dane do nazw kolumn i typów danych w 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 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.

    

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-połączenia-sieciowego	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 dla 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	Automatyczny	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ę Dalej> właściwości przetwarzania danych.

3. W Właściwościach 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	Mapowanie testowe	Mapowanie, które stworzyłeś w TestDatabase, i które odnosi przychodzące dane do nazw kolumn i typów danych w 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 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.

   

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

2. Utwórz aplikację usługi Azure AD do 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
   Identyfikator najemcy	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator dzierżawy. Znany również jako identyfikator katalogu.
   Identyfikator subskrypcji	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.
   tajemnica klienta	Symbol zastępczy ClientSecret	Klucz tajny klienta aplikacji, który może uzyskiwać dostęp do zasobów w dzierżawie.
   resourceGroupName (nazwa grupy zasobów)	testrg	Nazwa grupy zasobów zawierającej klaster.
   nazwa klastra	mykustocluster	Nazwa klastra.
   nazwaBazyDanych	mykustodatabase	Nazwa docelowej bazy danych w klastrze.
   nazwaPołączeniaEventGrid	myeventgridconnect	Żądana nazwa połączenia danych.
   nazwaTabeli	StormEvents	Nazwa tabeli docelowej w docelowej bazie danych.
   NazwaRegułyMapowania	StormEvents_CSV_Mapping	Nazwa mapowania kolumny powiązana z tabelą docelową.
   Format danych	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ń.
   Identyfikator zasobu konta przechowywania	Identyfikator zasobu	Identyfikator zasobu konta magazynu, który przechowuje dane do pozyskiwania.
   grupa konsumencka	$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.
   routowanie bazy danych	Wiele lub Pojedyncze	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 Multi, możesz zastąpić domyślną docelową bazę danych przy użyciu właściwości bazy danychingestion. Aby uzyskać więcej informacji, zobacz Routing zdarzeń.

1. Zainstaluj wymagane biblioteki.

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

2. Utwórz aplikację 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
   identyfikator_najemcy	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator dzierżawy. Znany również jako identyfikator katalogu.
   identyfikator_subskrypcji	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator subskrypcji używany do tworzenia zasobów.
   identyfikator_klienta	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identyfikator klienta aplikacji, która może uzyskiwać dostęp do zasobów w dzierżawie.
   tajemnica klienta	xxxxxxxxxxxxxxxx	Klucz tajny klienta aplikacji, który może uzyskiwać dostęp do zasobów w dzierżawie.
   nazwa_grupy_zasobów	testrg	Nazwa grupy zasobów zawierającej klaster.
   nazwa_klastra	mykustocluster	Nazwa klastra.
   nazwa_bazy_danych	mykustodatabase	Nazwa docelowej bazy danych w klastrze.
   nazwa_połączenia_danych	myeventhubconnect	Żądana nazwa połączenia danych.
   nazwa_tabeli	StormEvents	Nazwa tabeli docelowej w docelowej bazie danych.
   nazwa_reguły_mapowania	StormEvents_CSV_Mapping	Nazwa mapowania kolumny powiązana z tabelą docelową.
   routing_bazy_danych	Wiele lub Jedno	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 Multi, możesz nadpisać domyślną docelową bazę danych przy użyciu właściwości bazy danych przechwytywania. Więcej informacji znajdziesz w sekcji Routing zdarzeń.
   format danych	csv	Format danych wiadomości.
   identyfikator_zasobu_event_hub	Identyfikator zasobu	Identyfikator zasobu centrum zdarzeń, w którym usługa Event Grid jest skonfigurowana do wysyłania zdarzeń.
   identyfikator_zasobu_konta_magazynowego	Identyfikator zasobu	Identyfikator zasobu konta magazynu, który przechowuje dane do pozyskiwania.
   grupa konsumencka	$Default	Grupa odbiorców centrum zdarzeń.
   lokalizacja	Środkowe stany USA	Lokalizacja zasobu połączenia danych.
   typ_zdarzenia_magazynu_blob	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.

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

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ń.

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

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

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)