Event Grid-adatkapcsolat létrehozása az Azure Data Explorerhez

Ebből a cikkből megtudhatja, hogyan lehet blobokat beszúrni a tárfiókból az Azure Data Explorerbe event Grid-adatkapcsolat használatával. Létre fog hozni egy Event Grid-adatkapcsolatot, amely beállít egy Azure Event Grid-előfizetést. Az Event Grid-előfizetés egy Azure Event Hubson keresztül irányítja át az eseményeket a tárfiókból az Azure Data Explorerbe.

Az Azure Data Explorerbe az Event Gridből való betöltéssel kapcsolatos általános információkért lásd: Csatlakozás az Event Gridhez.

Feljegyzés

Az Event Grid-kapcsolaton keresztüli legjobb teljesítmény eléréséhez állítsa be a rawSizeBytes betöltési tulajdonságot a blob metaadatain keresztül. További információkért lásd a feldolgozási tulajdonságokat.

Előfeltételek

• Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.
• Egy Azure Data Explorer-fürt és adatbázis. Hozzon létre egy klasztert és adatbázist.
• Célállomás tábla. Hozzon létre egy táblát , vagy használjon egy meglévő táblát.
• A táblázat betöltési leképezése .
• Egy tárfiók. Event Grid-értesítési előfizetés beállítható az Azure Storage-fiókokon a BlobStorageStorageV2. generációs Data Lake Storage-fiókhoz.

Event Grid-adatkapcsolat létrehozása

Ebben a szakaszban kapcsolatot fog létesíteni az Event Grid és az Azure Data Explorer-tábla között.

Portál – Azure Data Explorer

1. A létrehozott fürt alatt válassza a Databases>

   

2. Válassza az Adatbetöltés>adatkapcsolat hozzáadása lehetőséget.

   

3. Az Alapszintű beállítások területen válassza ki a kapcsolat típusát: Blob Storage, majd töltse ki az űrlapot a következő információkkal:

   

   Beállítás	Ajánlott érték	Mező leírása
   Adatkapcsolat neve	teszt-hálózati kapcsolat	Az Azure Data Explorerben létrehozni kívánt kapcsolat neve.
   Tárfiók-előfizetés	Saját előfizetés azonosítója	Az előfizetés azonosítója, ahol a tárfiók található.
   Tárhelyfiók	gridteststorage1	A korábban létrehozott tárfiók neve.
   Eseménytípus	Blob létrehozása vagy átnevezése	A bevitel kiváltó esemény típusa. Az átnevezett blobok csak az ADLSv2-tárolók esetében támogatottak. Blob átnevezéséhez keresse meg a blobot az Azure Portalon, kattintson a jobb gombbal a blobra, és válassza az Átnevezés lehetőséget. Támogatott típusok: Microsoft.Storage.BlobCreated vagy Microsoft.Storage.BlobRenamed.
   Erőforrások létrehozása	Automatikus	Adja meg, hogy az Azure Data Explorer hozzon-e létre egy Event Grid-előfizetést, egy Event Hubs névteret és egy Event Hubot. Az erőforrások manuális létrehozásához lásd : Erőforrások manuális létrehozása az Event Grid-betöltéshez

4. Ha bizonyos témákat szeretne nyomon követni, válassza a Szűrési beállítások lehetőséget . Az értesítések szűrőinek beállítása az alábbiak szerint:

   • Az előtagmező a tárgy szó szerinti előtagja. Amikor az alkalmazott startswith minta van használva, az több tárolóra, mappára vagy blobra is kiterjedhet. Helyettesítő karakterek nem megengedettek.
     • Ha szűrőt szeretne definiálni a blobtárolón, a mezőt a következőképpen kell beállítani: /blobServices/default/containers/[container prefix].
     • Ha egy blobelőtagon (vagy az Azure Data Lake Gen2 egy mappáján) szeretne szűrőt definiálni, a mezőt a következőképpen kell beállítani: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix]
   • Az utótag mező a blob literális utótagja. Helyettesítő karakterek nem használhatók.
   • Érzékeny a kis- és nagybetűkre mező azt jelzi, hogy az előtag- és utótagszűrők érzékenyek-e a kis- és nagybetűkre
   • A szűrési eseményekről további információt a Blob Storage-események című témakörben talál.

   

5. Válassza a Tovább: Betöltési tulajdonságok lehetőséget.

6. Adja meg az alábbi adatokat az űrlapon. A tábla- és leképezésnevek megkülönböztetik a kis- és nagybetűket:

   

   Betöltési tulajdonságok:

   Beállítás	Ajánlott érték	Mező leírása
   Adatok átirányításának engedélyezése más adatbázisokhoz (többadatbázisos adatkapcsolat)	Ne engedd	Kapcsolja be ezt a beállítást, ha felül szeretné bírálni az adatkapcsolathoz társított alapértelmezett céladatbázist. Az adatbázis-útválasztásról további információt az Események útválasztása című témakörben talál.
   Tábla neve	TestTable	A TestDatabase adatbázisban létrehozott tábla.
   Adatformátum	JSON	Támogatott formátumok: Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW és W3CLOG. A támogatott tömörítési lehetőségek a Zip és a Gzip.
   Hozzárendelés	TestMapping	A TestDatabase-ben létrehozott leképezés, amely leképezi a bejövő adatokat a TestTable oszlopneveihez és adattípusaihoz. Ha nincs megadva, a rendszer a tábla sémájából származtatott identitásadat-leképezést használja.
   Speciális beállítások	Az adataim fejlécekkel vannak elemmel	A fejlécek figyelmen kívül hagyása. *SV típusú fájlok esetén támogatott.

   Feljegyzés

   Nem kell megadnia az összes alapértelmezett útválasztási beállítást. Részleges beállításokat is elfogadunk.

7. Válassza a Tovább elemet : Áttekintés + létrehozás

8. A *Véleményezés + létrehozás területen.

9. Tekintse át az ön számára automatikusan létrehozott erőforrásokat, és válassza a Létrehozás lehetőséget.

   

10. Várjon, amíg az üzembe helyezés befejeződik. Ha az üzembe helyezés sikertelen volt, válassza a sikertelen szakasz melletti művelet részleteit , hogy további információt kapjon a hiba okáról. Válassza az Újratelepítés lehetőséget az erőforrások ismételt üzembe helyezéséhez. A paramétereket az üzembe helyezés előtt módosíthatja.

    

Portál – Azure Storage

1. Keresse meg a tárhelyfiókot az Azure Portalon. A bal oldali menüben válassza az Események lehetőséget

2. A fő panelen válassza az Azure Data Explorer lapot.

   

Megnyílik az Adatkapcsolat panel, amelyen az Alapismeretek lap van kijelölve.

1. Az Alapszintű beállítások területen töltse ki az űrlapot a következő információkkal:

   

   Beállítás	Ajánlott érték	Mező leírása
   Adatkapcsolat neve	hálózati tesztkapcsolat	Az Azure Data Explorerben létrehozni kívánt kapcsolat neve.
   Tárolási fiók	gridteststorage1	Az a tárfiók, ahonnan a varázslót elérte. Automatikusan kitöltve.
   Eseménytípus	Blob létrehozása vagy átnevezése	A betöltést kiváltó esemény típusa. Az átnevezett blobok csak az ADLSv2-tárolók esetében támogatottak. Blob átnevezéséhez keresse meg a blobot az Azure Portalon, kattintson a jobb gombbal a blobra, és válassza az Átnevezés lehetőséget. Támogatott típusok: Microsoft.Storage.BlobCreated vagy Microsoft.Storage.BlobRenamed.
   Erőforrások létrehozása	Automatikus	Megadhatja, hogy az Azure Data Explorer hozzon-e létre Egy Event Grid-előfizetést, egy Event Hubs-névteret és egy Event Hubs-t. Az erőforrások manuális létrehozásához lásd : Erőforrások manuális létrehozása az Event Grid-betöltéshez

2. Válassza a Következő> feldolgozási tulajdonságok lehetőséget.

3. A Betöltési tulajdonságok területen.

4. Adja meg az alábbi adatokat az űrlapon. A tábla- és leképezésnevek megkülönböztetik a kis- és nagybetűket:

   

   Beállítás	Ajánlott érték	Mező leírása
   Előfizetés		Az Azure Data Explorer-előfizetése.
   Fürt neve	TestCluster	Annak a fürtnek a neve, amelyben adatokat szeretne betöltésre.
   Adatbázis neve	TestDatabase	A TestClusterben létrehozott céladatbázis.
   Adatok átirányításának engedélyezése más adatbázisokhoz (többadatbázisos adatkapcsolat)	Ne engedélyezze	Kapcsolja be ezt a beállítást, ha felül szeretné bírálni az adatkapcsolathoz társított alapértelmezett céladatbázist. Az adatbázis-útválasztásról további információt az Események útválasztása című témakörben talál.
   Tábla neve	TestTable	A céltábla, amit a TestDatabase-ben létrehoztál.
   Adatformátum	JSON	Támogatott formátumok: Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW és W3CLOG. A támogatott tömörítési lehetőségek a Zip és a Gzip.
   Hozzárendelés	TestMapping	A TestDatabase-ben létrehozott leképezés, amely leképezi a bejövő adatokat a TestTable oszlopneveihez és adattípusaihoz. Ha nincs megadva, a rendszer a tábla sémájából származtatott identitásadat-leképezést használja.
   Speciális beállítások	Az adataim tartalmaznak fejléceket	A fejlécek figyelmen kívül hagyása. *SV típusú fájlok esetén támogatott.

   Feljegyzés

   Nem kell megadnia az összes adatútválasztási beállítást. Részleges beállításokat is elfogadunk.

5. Válassza a Tovább elemet : Áttekintés + létrehozás

6. Az Értékelés + létrehozás alatt.

7. Tekintse át az ön számára automatikusan létrehozott erőforrásokat, és válassza a Létrehozás lehetőséget.

   

8. Várjon, amíg az üzembe helyezés befejeződik. Ha az üzembe helyezés sikertelen volt, válassza a sikertelen szakasz melletti művelet részleteit , hogy további információt kapjon a hiba okáról. Válassza az Újratelepítés lehetőséget az erőforrások ismételt üzembe helyezéséhez. A paramétereket az üzembe helyezés előtt módosíthatja.

   

C#

1. Telepítse a Microsoft.Azure.Management.Kusto NuGet csomagot.

2. Hozzon létre egy Azure AD alkalmazásazonosítót a hitelesítéshez. Szüksége lesz a címtár (bérlő) azonosítójára, az alkalmazásazonosítóra és az ügyfél titkos kódjára.

3. Futtassa a következő kódot.

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

   Beállítás	Ajánlott érték	Mező leírása
   bérlőazonosító	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Az Ön bérlőazonosítója. Más néven könyvtárazonosító.
   előfizetésAzonosító	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az erőforrás-létrehozáshoz használt előfizetés-azonosító.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Annak az alkalmazásnak az ügyfélazonosítója, amely hozzáfér a bérlő erőforrásaihoz.
   ügyfél titkos kódja	PlaceholderClientSecret	Az alkalmazás ügyfélkulcsa, amely hozzáfér a bérlő erőforrásaihoz.
   resourceGroupName	testrg	A fürtöt tartalmazó erőforráscsoport neve.
   clusterName	mykustocluster	A fürt neve.
   Adatbázis neve	mykustodatabase	A fürt céladatbázisának neve.
   eventGridConnectionName	myeventgridconnect	Az adatkapcsolat kívánt neve.
   tableName	StormEvents	A céltábla neve a céladatbázisban.
   leképezésiSzabályNév	StormEvents_CSV_Mapping	A céltáblához kapcsolódó oszlopleképezés neve.
   dataFormat	csv	Az üzenet adatformátuma.
   eventHubResourceId	Erőforrás-azonosító	Az eseményközpont erőforrás-azonosítója, ahol az Event Grid események küldésére van konfigurálva.
   tárolóFiókErőforrásAzonosító	Erőforrás-azonosító	A betöltéshez szükséges adatokat tartalmazó tárfiók erőforrás-azonosítója.
   consumerGroup	$Alapértelmezett	Az eseményközpont fogyasztói csoportja.
   hely	USA középső régiója	Az adatkapcsolati erőforrás helye.
   blob tárolási eseménytípus	Microsoft.Storage.BlobCreated	A beolvasást kiváltó esemény típusa. A támogatott események a következők: Microsoft.Storage.BlobCreated vagy Microsoft.Storage.BlobRenamed. A blob átnevezése csak az ADLSv2 storage esetében támogatott.
   databaseRouting	Több - vagy egyszemélyes	A kapcsolat adatbázis-útválasztása. Ha az értéket egyetlen értékre állítja, a rendszer az adatkapcsolatot a fürt egyetlen adatbázisához irányítja a databaseName beállításban megadott módon. Ha multi értékre állítja az értéket, felülbírálhatja az alapértelmezett céladatbázist az Adatbázis-betöltésitulajdonság használatával. További információ: Események útválasztása.

Python

1. Telepítse a szükséges kódtárakat.

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

2. Hozzon létre egy Azure AD-alkalmazásnevet a hitelesítéshez. Szüksége lesz a címtár (bérlő) azonosítójára, az alkalmazásazonosítóra és az ügyfél titkos kódjára.

3. Futtassa a következő kódot.

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

   Beállítás	Ajánlott érték	Mező leírása
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az Ön bérlőazonosítója. Más néven könyvtárazonosító.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az erőforrás-létrehozáshoz használt előfizetés-azonosító.
   ügyfél azonosítója	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Annak az alkalmazásnak az ügyfélazonosítója, amely hozzáfér a bérlő erőforrásaihoz.
   titkos ügyfélkód	xxxxxxxxxxxxxx	Az alkalmazás ügyfélkulcsa, amely hozzáfér a bérlő erőforrásaihoz.
   erőforrás_csoport_név	testrg	A fürtöt tartalmazó erőforráscsoport neve.
   cluster_name	mykustocluster	Az Ön fürtjének neve.
   database_name	mykustodatabase	A fürt céladatbázisának neve.
   data_connection_name	myeventhubconnect	Az adatkapcsolat kívánt neve.
   table_name	StormEvents	A céltábla neve a céladatbázisban.
   leképezési_szabály_neve	StormEvents_CSV_Mapping	A céltáblához kapcsolódó oszlopleképezés neve.
   database_routing	Több - vagy egyszemélyes	A kapcsolat adatbázis-útválasztása. Ha az értéket egyetlen-re állítja, a rendszer az adatkapcsolatot a fürtön belül egyetlen adatbázishoz irányítja a databaseName beállításban megadott módon. Ha multi értékre állítja az értéket, felülbírálhatja az alapértelmezett céladatbázist az Adatbázis-betöltésitulajdonság használatával. További információ: Események útválasztása.
   adatformátum	csv	Az üzenet adatformátuma.
   event_hub_erőforrás_azonosító	Erőforrás-azonosító	Az eseményközpont erőforrás-azonosítója, ahol az Event Grid események küldésére van konfigurálva.
   tárhely_fiók_erőforrás_azonosító	Erőforrás-azonosító	A betöltéshez szükséges adatokat tartalmazó tárfiók erőforrás-azonosítója.
   consumer_group	$Default	Az eseményközpont fogyasztói csoportja.
   hely	USA középső régiója	Az adatkapcsolati erőforrás helye.
   blobtárolási_eseménytípus	Microsoft.Storage.BlobCreated	Az adatbetöltést kiváltó esemény típusa. A támogatott események a következők: Microsoft.Storage.BlobCreated vagy Microsoft.Storage.BlobRenamed. A blob átnevezése csak az ADLSv2 storage esetében támogatott.

ARM-sablon

Az alábbi példa egy Event Grid-adatkapcsolat hozzáadására szolgáló Azure Resource Manager-sablont mutat be. A sablont az űrlap használatával szerkesztheti és helyezheti üzembe az Azure Portalon.

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

Event Grid-adatkapcsolat eltávolítása

Portál

Ha el szeretné távolítani az Event Grid-kapcsolatot az Azure Portalról, tegye a következőket:

1. Nyissa meg a fürtöt. A bal oldali menüben válassza az Adatbázisok lehetőséget. Ezután válassza ki a céltáblát tartalmazó adatbázist.
2. A bal oldali menüben válassza az Adatkapcsolatok lehetőséget. Ezután jelölje be a megfelelő Event Grid-adatkapcsolat melletti jelölőnégyzetet.
3. A felső menüsávon válassza a Törlés lehetőséget.

C#

Az Event Grid-kapcsolat eltávolításához futtassa a következő parancsot:

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

Python

Az Event Grid-kapcsolat eltávolításához futtassa a következő parancsot:

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)

Következő lépések

• Adatok feldolgozása az eseményközpontból az Azure Stream Analytics használatával