Een Event Grid-gegevensverbinding maken voor Azure Data Explorer

Artikel
05/03/2023

In dit artikel leert u hoe u blobs uit uw opslagaccount opneemt in Azure Data Explorer met behulp van een Event Grid-gegevensverbinding. U maakt een Event Grid-gegevensverbinding waarmee een Azure Event Grid-abonnement wordt ingesteld. Het Event Grid-abonnement routeert gebeurtenissen van uw opslagaccount naar Azure Data Explorer via een Azure Event Hubs.

Zie Verbinding maken met Event Grid voor algemene informatie over opname in Azure Data Explorer vanuit Event Grid.

Notitie

Als u de beste prestaties wilt bereiken met de Event Grid-verbinding, stelt u de rawSizeBytes opname-eigenschap in via de metagegevens van de blob. Zie opname-eigenschappen voor meer informatie.

Vereisten

Een Azure-abonnement. Maak een gratis Azure-account.
Een Azure Data Explorer-cluster en -database. Maak een cluster en database.
Een doeltabel. Maak een tabel of gebruik een bestaande tabel.
Een opnametoewijzing voor de tabel.
Een opslagaccount. Een Event Grid-meldingsabonnement kan worden ingesteld op Azure Storage-accounts voor BlobStorage, StorageV2of Data Lake Storage Gen2.

Een Event Grid-gegevensverbinding maken

In deze sectie brengt u een verbinding tot stand tussen Event Grid en uw Azure Data Explorer-tabel.

Selecteer Databases>TestDatabase onder het cluster dat u hebt gemaakt.
Selecteer Gegevensopname>Toevoegen gegevensverbinding.

Selecteer onder Basis het verbindingstype: Blob-opslag en vul het formulier vervolgens in met de volgende informatie:

Schermopname van het tabblad Basisbeginselen van gegevensverbinding, met de opties voor het verbindingstype Blob Storage.

Instelling	Voorgestelde waarde	Veldomschrijving
Naam van gegevensverbinding	test-grid-connection	De naam van de verbinding die u wilt maken in Azure Data Explorer.
Abonnement van opslagaccount	Uw abonnements-id	De abonnements-id waar uw opslagaccount zich bevindt.
Opslagaccount	gridteststorage1	De naam van het opslagaccount dat u eerder hebt gemaakt.
Gebeurtenistype	Blob gemaakt of blob hernoemd	Het type gebeurtenis dat opname activeert. De naam van de blob wordt alleen ondersteund voor ADLSv2-opslag. Als u de naam van een blob wilt wijzigen, gaat u naar de blob in Azure Portal, klikt u met de rechtermuisknop op de blob en selecteert u Naam wijzigen. Ondersteunde typen zijn: Microsoft.Storage.BlobCreated of Microsoft.Storage.BlobRenamed.
Resources maken	Automatisch	Definieer of u wilt dat Azure Data Explorer een Event Grid-abonnement, een Event Hubs-naamruimte en een Event Hubs voor u maakt. Als u handmatig resources wilt maken, raadpleegt u Handmatig resources maken voor Event Grid-opname

Selecteer Filterinstellingen als u specifieke onderwerpen wilt bijhouden. Stel de filters voor de meldingen als volgt in:
- Het voorvoegselveld is het letterlijke voorvoegsel van het onderwerp. Wanneer het toegepaste patroon wordt gestart, kan het meerdere containers, mappen of blobs omvatten. Er zijn geen jokertekens zijn toegestaan.
  - Als u een filter voor de blobcontainer wilt definiëren, moet het veld als volgt worden ingesteld: /blobServices/default/containers/[container prefix]
  - Als u een filter wilt definiëren voor een blobvoorvoegsel (of een map in Azure Data Lake Gen2), moet het veld als volgt worden ingesteld: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix]
- Het achtervoegselveld is het letterlijke achtervoegsel van de blob. Er zijn geen jokertekens zijn toegestaan.
- Hoofdlettergevoelig veld geeft aan of het voor- en achtervoegselfilters hoofdlettergevoelig zijn
- Zie Blob Storage-gebeurtenissen voor meer informatie over het filteren van gebeurtenissen.
Selecteer Volgende: Opname-eigenschappen.

Vul het formulier in met de volgende gegevens. Tabel- en toewijzingsnamen zijn hoofdlettergevoelig:

Schermopname van het tabblad Eigenschappen van Gegevensverbinding opnemen, met de eigenschappen van de doeltabel.

Opname-eigenschappen:

Instelling	Voorgestelde waarde	Veldomschrijving
Routering van de gegevens naar andere databases toestaan (multidatabasegegevensverbinding)	Niet toestaan	Schakel deze optie in als u de standaarddoeldatabase wilt overschrijven die is gekoppeld aan de gegevensverbinding. Zie Gebeurtenissenroutering voor meer informatie over databaseroutering.
Tabelnaam	TestTable	De tabel die u hebt gemaakt in TestDatabase.
Gegevensopmaak	JSON	Ondersteunde indelingen zijn Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW en W3CLOG. Ondersteunde compressieopties zijn Zip en Gzip.
Toewijzing	TestMapping	De toewijzing die u hebt gemaakt in TestDatabase, waarmee binnenkomende gegevens worden toegewezen aan de kolomnamen en gegevenstypen van TestTable. Als dit niet is opgegeven, wordt een identiteitsgegevenstoewijzing gebruikt die is afgeleid van het schema van de tabel.
Geavanceerde instellingen	Mijn gegevens bevatten kopteksten	Negeert kopteksten. Ondersteund voor *SV-typebestanden.

Notitie

U hoeft niet alle standaardrouteringsinstellingen op te geven. Gedeeltelijke instellingen worden ook geaccepteerd.

Volgende selecteren: Beoordelen en maken
Onder *Beoordelen + maken.
Controleer de resources die automatisch voor u zijn gemaakt en selecteer Maken.
Wacht tot de implementatie is voltooid. Als uw implementatie is mislukt, selecteert u Bewerkingsgegevens naast de mislukte fase om meer informatie te krijgen over de reden van de fout. Selecteer Opnieuw implementeren om de resources opnieuw te implementeren. U kunt de parameters vóór de implementatie wijzigen.

Blader naar het opslagaccount in Azure Portal. Selecteer Gebeurtenissen in het linkermenu
Selecteer in het hoofdvenster het tabblad Azure Data Explorer .

Het deelvenster Gegevensverbinding wordt geopend met het tabblad Basisinformatie geselecteerd.

Vul onder Basisinformatie het formulier in met de volgende informatie:

Schermopname van het tabblad Basisbeginselen van gegevensverbinding, met de opties voor het verbindingstype.

Instelling	Voorgestelde waarde	Veldomschrijving
Naam van gegevensverbinding	test-grid-connection	De naam van de verbinding die u wilt maken in Azure Data Explorer.
Opslagaccount	gridteststorage1	Het opslagaccount van waaruit u deze wizard hebt geopend. Automatisch ingevuld.
Gebeurtenistype	Blob gemaakt of blob hernoemd	Het type gebeurtenis dat opname activeert. De naam van de blob wordt alleen ondersteund voor ADLSv2-opslag. Als u de naam van een blob wilt wijzigen, gaat u naar de blob in Azure Portal, klikt u met de rechtermuisknop op de blob en selecteert u Naam wijzigen. Ondersteunde typen zijn: Microsoft.Storage.BlobCreated of Microsoft.Storage.BlobRenamed.
Resources maken	Automatisch	Definieer of u wilt dat Azure Data Explorer een Event Grid-abonnement, een Event Hubs-naamruimte en een Event Hubs voor u maakt. Als u handmatig resources wilt maken, raadpleegt u Handmatig resources maken voor Event Grid-opname

Selecteer eigenschappen voor volgende> opname.
Eigenschappen voor opnemen.

Vul het formulier in met de volgende gegevens. Tabel- en toewijzingsnamen zijn hoofdlettergevoelig:

Schermopname van het tabblad Eigenschappen van Gegevensverbinding opnemen, met de eigenschappen voor abonnements- en gegevensroutering.

Instelling	Voorgestelde waarde	Veldomschrijving
Abonnement		Uw Azure Data Explorer-abonnement.
Clusternaam	TestCluster	De naam van het cluster waarin u gegevens wilt opnemen.
Databasenaam	TestDatabase	De doeldatabase die u hebt gemaakt in TestCluster.
Routering van de gegevens naar andere databases toestaan (multidatabasegegevensverbinding)	Niet toestaan	Schakel deze optie in als u de standaarddoeldatabase wilt overschrijven die is gekoppeld aan de gegevensverbinding. Zie Gebeurtenissenroutering voor meer informatie over databaseroutering.
Tabelnaam	TestTable	De doeltabel die u hebt gemaakt in TestDatabase.
Gegevensopmaak	JSON	Ondersteunde indelingen zijn Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW en W3CLOG. Ondersteunde compressieopties zijn Zip en Gzip.
Toewijzing	TestMapping	De toewijzing die u hebt gemaakt in TestDatabase, waarmee binnenkomende gegevens worden toegewezen aan de kolomnamen en gegevenstypen van TestTable. Als dit niet is opgegeven, wordt een identiteitsgegevenstoewijzing gebruikt die is afgeleid van het schema van de tabel.
Geavanceerde instellingen	Mijn gegevens bevatten kopteksten	Negeert kopteksten. Ondersteund voor *SV-typebestanden.

Notitie

U hoeft niet alle instellingen voor gegevensroutering op te geven. Gedeeltelijke instellingen worden ook geaccepteerd.

Volgende selecteren: Beoordelen en maken
Onder Beoordelen en maken.
Controleer de resources die automatisch voor u zijn gemaakt en selecteer Maken.
Wacht tot de implementatie is voltooid. Als uw implementatie is mislukt, selecteert u Bewerkingsgegevens naast de mislukte fase om meer informatie te krijgen over de reden van de fout. Selecteer Opnieuw implementeren om de resources opnieuw te implementeren. U kunt de parameters vóór de implementatie wijzigen.

Installeer het Microsoft.Azure.Management.Kusto NuGet-pakket.
Maak een Azure AD-toepassingsprincipaal die moet worden gebruikt voor verificatie. U hebt de map-id (tenant), de toepassings-id en het clientgeheim nodig.

Voer de volgende code uit.

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

Instelling	Voorgestelde waarde	Veldomschrijving
tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Uw tenant-id. Ook wel map-id genoemd.
subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	De abonnements-id die u gebruikt voor het maken van resources.
clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	De client-id van de toepassing die toegang heeft tot resources in uw tenant.
clientSecret	Tijdelijke aanduidingClientSecret	Het clientgeheim van de toepassing die toegang heeft tot resources in uw tenant.
resourceGroupName	testrg	De naam van de resourcegroep die uw cluster bevat.
clusterName	mykustocluster	De naam van het cluster.
databaseName	mykustodatabase	De naam van de doeldatabase in uw cluster.
eventGridConnectionName	myeventgridconnect	De gewenste naam van uw gegevensverbinding.
tableName	StormEvents	De naam van de doeltabel in de doeldatabase.
mappingRuleName	StormEvents_CSV_Mapping	De naam van de kolomtoewijzing die is gerelateerd aan de doeltabel.
dataFormat	CSV	De gegevensindeling van het bericht.
eventHubResourceId	Resource-id	De resource-id van uw Event Hub waar Event Grid is geconfigureerd voor het verzenden van gebeurtenissen.
storageAccountResourceId	Resource-id	De resource-id van uw opslagaccount met de gegevens voor opname.
consumerGroup	$Default	De consumentengroep van uw Event Hub.
locatie	US - centraal	De locatie van de gegevensverbindingsresource.
blobStorageEventType	Microsoft.Storage.BlobCreated	Het type gebeurtenis dat opname activeert. Ondersteunde gebeurtenissen zijn: Microsoft.Storage.BlobCreated of Microsoft.Storage.BlobRenamed. De naam van de blob wordt alleen ondersteund voor ADLSv2-opslag.
databaseRouting	Meerdere of enkele	De databaseroutering voor de verbinding. Als u de waarde instelt op Single, wordt de gegevensverbinding doorgestuurd naar één database in het cluster, zoals opgegeven in de instelling databaseName . Als u de waarde instelt op Multi, kunt u de standaarddoeldatabase overschrijven met behulp van de eigenschap Databaseopname. Zie Gebeurtenissenroutering voor meer informatie.

Installeer de vereiste bibliotheken.

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

Maak een Azure AD-toepassingsprincipaal die moet worden gebruikt voor verificatie. U hebt de map-id (tenant), de toepassings-id en het clientgeheim nodig.

Voer de volgende code uit.

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

Instelling	Voorgestelde waarde	Veldomschrijving
tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Uw tenant-id. Ook wel map-id genoemd.
subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	De abonnements-id die u gebruikt voor het maken van resources.
client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	De client-id van de toepassing die toegang heeft tot resources in uw tenant.
client_secret	xxxxxxxxxxxx	Het clientgeheim van de toepassing die toegang heeft tot resources in uw tenant.
resource_group_name	testrg	De naam van de resourcegroep die uw cluster bevat.
cluster_name	mykustocluster	De naam van het cluster.
database_name	mykustodatabase	De naam van de doeldatabase in uw cluster.
data_connection_name	myeventhubconnect	De gewenste naam van uw gegevensverbinding.
table_name	StormEvents	De naam van de doeltabel in de doeldatabase.
mapping_rule_name	StormEvents_CSV_Mapping	De naam van de kolomtoewijzing die is gerelateerd aan de doeltabel.
database_routing	Meerdere of enkele	De databaseroutering voor de verbinding. Als u de waarde instelt op Single, wordt de gegevensverbinding doorgestuurd naar één database in het cluster, zoals opgegeven in de instelling databaseName . Als u de waarde instelt op Multi, kunt u de standaarddoeldatabase overschrijven met behulp van de eigenschap Databaseopname. Zie Gebeurtenissenroutering voor meer informatie.
data_format	CSV	De gegevensindeling van het bericht.
event_hub_resource_id	Resource-id	De resource-id van uw Event Hub waar Event Grid is geconfigureerd voor het verzenden van gebeurtenissen.
storage_account_resource_id	Resource-id	De resource-id van uw opslagaccount met de gegevens voor opname.
consumer_group	$Default	De consumentengroep van uw Event Hub.
locatie	US - centraal	De locatie van de gegevensverbindingsresource.
blob_storage_event_type	Microsoft.Storage.BlobCreated	Het type gebeurtenis dat opname activeert. Ondersteunde gebeurtenissen zijn: Microsoft.Storage.BlobCreated of Microsoft.Storage.BlobRenamed. De naam van de blob wordt alleen ondersteund voor ADLSv2-opslag.

In het volgende voorbeeld ziet u een Azure Resource Manager-sjabloon voor het toevoegen van een Event Grid-gegevensverbinding. U kunt de sjabloon bewerken en implementeren in Azure Portal met behulp van het formulier.

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

Een Event Grid-gegevensverbinding verwijderen

Ga als volgt te werk om de Event Grid-verbinding uit Azure Portal te verwijderen:

Ga naar uw cluster. Selecteer Databases in het linkermenu. Selecteer vervolgens de database die de doeltabel bevat.
Selecteer Gegevensverbindingen in het linkermenu. Schakel vervolgens het selectievakje in naast de relevante Event Grid-gegevensverbinding.
Selecteer Verwijderen in de bovenste menubalk.

Voer de volgende opdracht uit om de Event Grid-verbinding te verwijderen:

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

Voer de volgende opdracht uit om de Event Grid-verbinding te verwijderen:

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)

Volgende stappen

Gegevens van uw Event Hub verwerken met behulp van Azure Stream Analytics

Delen via

Een Event Grid-gegevensverbinding maken voor Azure Data Explorer

Vereisten

Een Event Grid-gegevensverbinding maken

Een Event Grid-gegevensverbinding verwijderen

Volgende stappen

Aanvullende resources