Membuat koneksi data Event Grid untuk Azure Data Explorer

Dalam artikel ini, Anda mempelajari cara menyerap blob dari akun penyimpanan Anda ke Azure Data Explorer menggunakan koneksi data Event Grid. Anda akan membuat koneksi data Event Grid yang menetapkan langganan Azure Event Grid. Langganan Event Grid merutekan peristiwa dari akun penyimpanan Anda ke Azure Data Explorer melalui Azure Event Hubs.

Untuk informasi umum tentang menyerap ke Azure Data Explorer dari Event Grid, lihat Menyambungkan ke Event Grid.

Catatan

Untuk mencapai performa terbaik dengan koneksi Event Grid, atur rawSizeBytes properti penyerapan melalui metadata blob. Untuk informasi selengkapnya, lihat properti penyerapan.

Prasyarat

• Langganan Azure. Membuat akun Azure gratis.
• Kluster dan database Azure Data Explorer. Membuat kluster dan database.
• Tabel tujuan. Buat tabel atau gunakan tabel yang sudah ada.
• Pemetaan penyerapan untuk tabel.
• Akun penyimpanan. Langganan pemberitahuan Event Grid dapat diatur di akun Azure Storage untuk BlobStorage, , StorageV2atau Data Lake Storage Gen2.

Membuat koneksi data Event Grid

Di bagian ini, Anda akan membuat koneksi antara Event Grid dan tabel Azure Data Explorer Anda.

Portal - Azure Data Explorer

1. Di bawah kluster yang Anda buat, pilih Database>TestDatabase.

   

2. Pilih Penyerapan>data Tambahkan koneksi data.

   

3. Di bawah Dasar,pilih jenis koneksi: Penyimpanan blob lalu isi formulir dengan informasi berikut:

   

   Pengaturan	Nilai yang disarankan	Deskripsi bidang
   Nama koneksi data	test-grid-connection	Nama koneksi yang ingin Anda buat di Azure Data Explorer.
   Langganan akun penyimpanan	ID langganan Anda.	ID langganan tempat akun penyimpanan Anda berada.
   Akun Penyimpanan	gridteststorage1	Nama akun penyimpanan yang Anda buat sebelumnya.
   Jenis peristiwa	Blob yang dibuat atau Blob yang diganti namanya	Jenis peristiwa yang memicu konsumsi. Blob berganti nama hanya didukung untuk penyimpanan ADLSv2. Untuk mengganti nama blob, navigasikan ke blob di portal Azure, klik kanan pada blob dan pilih Ganti Nama. Tipe y ang didukung adalah: Microsoft.Storage.BlobCreated atau Microsoft.Storage.BlobRenamed.
   Pembuatan sumber daya	Otomatis	Tentukan apakah Anda ingin Azure Data Explorer membuat Langganan Event Grid, namespace Azure Event Hubs, dan Azure Event Hubs untuk Anda. Untuk membuat sumber daya secara manual, lihat Membuat sumber daya secara manual untuk penyerapan Event Grid

4. Pilih Pengaturan Filter jika Anda ingin melacak subjek tertentu. Atur filter untuk pemberitahuan sebagai berikut:

   • Bidang awalan adalah awalan literal dari subjek. Karena pola yang diterapkan startswith, ia dapat menjangkau beberapa kontainer, folder, atau blob. Tidak ada kartubebas yang diizinkan.
     • Untuk menentukan filter pada kontainer blob, bidang harus diatur sebagai berikut: /blobServices/default/containers/[container prefix].
     • Untuk menentukan filter pada awalan blob (atau folder di Azure Data Lake Gen2), bidang harus diatur sebagai berikut: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • Bidang akhiran adalah akhiran literal dari blob. Tidak ada kartubebas yang diizinkan.
   • Bidang Case-Sensitive menunjukkan apakah awalan dan filter akhiran peka huruf besar/kecil
   • Untuk informasi selengkapnya tentang memfilter peristiwa, lihat peristiwa penyimpanan Blob.

   

5. Pilih Berikutnya: Properti penyerapan.

6. Isi formulir dengan informasi berikut. Tabel dan nama pemetaan peka huruf besar/kecil:

   

   Properti penyerapan:

   Pengaturan	Nilai yang disarankan	Deskripsi bidang
   Perbolehkan perutean data ke database lain (Koneksi data multi database)	Jangan izinkan	Aktifkan opsi ini jika Anda ingin mengambil alih database target default yang terkait dengan koneksi data. Untuk informasi selengkapnya tentang perutean database, lihat Perutean peristiwa.
   Nama tabel	TestTable	Tabel yang Anda buat di TestDatabase.
   Format data	JSON	Format yang didukung adalah Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW, dan W3CLOG. Pilihan kompresi yang didukung adalah Zip dan Gzip.
   Pemetaan	TestMapping	Pemetaan yang Anda buat di TestDatabase, yang memetakan data masuk ke nama kolom dan jenis data TestTable. Jika tidak ditentukan, pemetaan data identitas yang berasal dari skema tabel digunakan.
   Pengaturan tingkat lanjut	Data saya memiliki header	Abaikan header. Didukung untuk jenis file *SV.

   Catatan

   Anda tidak perlu menentukan semua Pengaturan perutean default. Pengaturan parsial juga diterima.

7. Pilih Berikutnya: Tinjau + buat

8. Di bawah *Tinjau + buat.

9. Tinjau sumber daya yang dibuat secara otomatis untuk Anda dan pilih Buat.

   

10. Tunggu hingga penyebaran selesai. Jika penyebaran Anda gagal, pilih Detail operasi di samping tahap gagal untuk mendapatkan informasi lebih lanjut karena alasan kegagalan. Pilih Redeploy untuk mencoba menyebarkan sumber daya lagi. Anda dapat mengubah parameter sebelum penyebaran.

    

Portal - Penyimpanan Azure

1. Telusuri ke akun penyimpanan di portal Azure. Di menu sebelah kiri, pilih Peristiwa

2. Di panel utama, pilih tab Azure Data Explorer .

   

Panel Koneksi data terbuka dengan tab Dasar dipilih.

1. Di bawah Dasar,isi formulir dengan informasi berikut:

   

   Pengaturan	Nilai yang disarankan	Deskripsi bidang
   Nama koneksi data	test-grid-connection	Nama koneksi yang ingin Anda buat di Azure Data Explorer.
   Akun Penyimpanan	gridteststorage1	Akun penyimpanan tempat Anda mengakses wisaya ini. Diisi otomatis.
   Jenis peristiwa	Blob yang dibuat atau Blob yang diganti namanya	Jenis peristiwa yang memicu konsumsi. Blob berganti nama hanya didukung untuk penyimpanan ADLSv2. Untuk mengganti nama blob, navigasikan ke blob di portal Azure, klik kanan pada blob dan pilih Ganti Nama. Tipe y ang didukung adalah: Microsoft.Storage.BlobCreated atau Microsoft.Storage.BlobRenamed.
   Pembuatan sumber daya	Otomatis	Tentukan apakah Anda ingin Azure Data Explorer membuat Langganan Event Grid, namespace Azure Event Hubs, dan Azure Event Hubs untuk Anda. Untuk membuat sumber daya secara manual, lihat Membuat sumber daya secara manual untuk penyerapan Event Grid

2. Pilih Properti penyerapan berikutnya>.

3. Di bawah Properti penyerapan.

4. Isi formulir dengan informasi berikut. Tabel dan nama pemetaan peka huruf besar/kecil:

   

   Pengaturan	Nilai yang disarankan	Deskripsi bidang
   Langganan		Langganan Azure Data Explorer Anda.
   Nama kluster	TestCluster	Nama kluster tempat Anda ingin menyerap data.
   Nama Database	TestDatabase	Database target yang Anda buat di TestCluster.
   Perbolehkan perutean data ke database lain (Koneksi data multi database)	Jangan izinkan	Aktifkan opsi ini jika Anda ingin mengambil alih database target default yang terkait dengan koneksi data. Untuk informasi selengkapnya tentang perutean database, lihat Perutean peristiwa.
   Nama tabel	TestTable	Tabel target yang Anda buat di TestDatabase.
   Format data	JSON	Format yang didukung adalah Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW, dan W3CLOG. Pilihan kompresi yang didukung adalah Zip dan Gzip.
   Pemetaan	TestMapping	Pemetaan yang Anda buat di TestDatabase, yang memetakan data masuk ke nama kolom dan jenis data TestTable. Jika tidak ditentukan, pemetaan data identitas yang berasal dari skema tabel digunakan.
   Pengaturan tingkat lanjut	Data saya memiliki header	Abaikan header. Didukung untuk jenis file *SV.

   Catatan

   Anda tidak perlu menentukan semua pengaturan perutean data. Pengaturan parsial juga diterima.

5. Pilih Berikutnya: Tinjau + buat

6. Di bawah Tinjau + buat.

7. Tinjau sumber daya yang dibuat secara otomatis untuk Anda dan pilih Buat.

   

8. Tunggu hingga penyebaran selesai. Jika penyebaran Anda gagal, pilih Detail operasi di samping tahap gagal untuk mendapatkan informasi lebih lanjut karena alasan kegagalan. Pilih Redeploy untuk mencoba menyebarkan sumber daya lagi. Anda dapat mengubah parameter sebelum penyebaran.

   

C#

1. Instal paket Microsoft.Azure.Management.Kusto NuGet.

2. Buat prinsipal aplikasi Azure ACTIVE Directory untuk digunakan untuk autentikasi. Anda akan memerlukan ID direktori (penyewa), ID aplikasi, dan rahasia klien.

3. Jalankan kode berikut.

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

   Pengaturan	Nilai yang disarankan	Deskripsi bidang
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID penyewa Anda. Juga dikenal sebagai ID direktori.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID langganan yang Anda gunakan untuk pembuatan sumber daya.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID klien aplikasi yang dapat mengakses sumber daya di penyewa Anda.
   clientSecret	PlaceholderClientSecret	Rahasia klien aplikasi yang dapat mengakses sumber daya di penyewa Anda.
   resourceGroupName	testrg	Nama grup sumber daya yang berisi kluster Anda.
   clusterName	mykustocluster	Nama kluster Anda.
   databaseName	mykustodatabase	Nama database target dalam kluster Anda.
   eventGridConnectionName	myeventgridconnect	Nama koneksi data yang diinginkan.
   tableName	StormEvents	Nama tabel target dalam database target.
   mappingRuleName	StormEvents_CSV_Mapping	Nama pemetaan kolom Anda yang terkait dengan tabel target.
   dataFormat	csv	Format data pesan.
   eventHubResourceId	ID Sumber Daya	ID sumber daya hub peristiwa Anda tempat Event Grid dikonfigurasi untuk mengirim peristiwa.
   storageAccountResourceId	ID Sumber Daya	ID sumber daya akun penyimpanan Anda yang menyimpan data untuk penyerapan.
   consumerGroup	$Default	Grup konsumen pusat aktivitas Anda.
   lokasi	US Tengah	Lokasi sumber daya koneksi data.
   blobStorageEventType	Microsoft.Storage.BlobDeleted	Jenis peristiwa yang memicu konsumsi. Peristiwa yang didukung adalah: Microsoft.Storage.BlobCreated atau Microsoft.Storage.BlobRenamed. Penggantian nama blob hanya didukung untuk penyimpanan ADLSv2.
   databaseRouting	Multi atau Tunggal	Perutean database untuk koneksi. Jika Anda mengatur nilai ke Tunggal, koneksi data akan dirutekan ke database tunggal di kluster seperti yang ditentukan dalam pengaturan databaseName . Jika Anda mengatur nilai ke Multi, Anda bisa mengambil alih database target default menggunakan properti Penyerapan database. Untuk informasi selengkapnya, lihat Perutean peristiwa.

Python

1. Instal pustaka yang diperlukan.

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

2. Buat prinsipal aplikasi Azure ACTIVE Directory untuk digunakan untuk autentikasi. Anda akan memerlukan ID direktori (penyewa), ID aplikasi, dan rahasia klien.

3. Jalankan kode berikut.

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

   Pengaturan	Nilai yang disarankan	Deskripsi bidang
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID penyewa Anda. Juga dikenal sebagai ID direktori.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID langganan yang Anda gunakan untuk pembuatan sumber daya.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	ID klien aplikasi yang dapat mengakses sumber daya di penyewa Anda.
   client_secret	xxxxxxxxxxxxxxxx	Rahasia klien aplikasi yang dapat mengakses sumber daya di penyewa Anda.
   resource_group_name	testrg	Nama grup sumber daya yang berisi kluster Anda.
   cluster_name	mykustocluster	Nama kluster Anda.
   database_name	mykustodatabase	Nama database target dalam kluster Anda.
   data_connection_name	myeventhubconnect	Nama koneksi data yang diinginkan.
   table_name	StormEvents	Nama tabel target dalam database target.
   mapping_rule_name	StormEvents_CSV_Mapping	Nama pemetaan kolom Anda yang terkait dengan tabel target.
   database_routing	Multi atau Tunggal	Perutean database untuk koneksi. Jika Anda mengatur nilai ke Tunggal, koneksi data akan dirutekan ke database tunggal di kluster seperti yang ditentukan dalam pengaturan databaseName . Jika Anda mengatur nilai ke Multi, Anda bisa mengambil alih database target default menggunakan properti Penyerapan database. Untuk informasi selengkapnya, lihat Perutean peristiwa.
   data_format	csv	Format data pesan.
   event_hub_resource_id	ID Sumber Daya	ID sumber daya hub peristiwa Anda tempat Event Grid dikonfigurasi untuk mengirim peristiwa.
   storage_account_resource_id	ID Sumber Daya	ID sumber daya akun penyimpanan Anda yang menyimpan data untuk penyerapan.
   consumer_group	$Default	Grup konsumen pusat aktivitas Anda.
   lokasi	US Tengah	Lokasi sumber daya koneksi data.
   blob_storage_event_type	Microsoft.Storage.BlobDeleted	Jenis peristiwa yang memicu konsumsi. Peristiwa yang didukung adalah: Microsoft.Storage.BlobCreated atau Microsoft.Storage.BlobRenamed. Penggantian nama blob hanya didukung untuk penyimpanan ADLSv2.

Templat ARM

Contoh berikut menunjukkan templat Azure Resource Manager untuk menambahkan koneksi data Event Grid. Anda dapat mengedit dan menyebarkan templat di portal Microsoft Azure dengan menggunakan formulir.

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

Menghapus koneksi data Event Grid

Portal

Untuk menghapus koneksi Event Grid dari portal Azure, lakukan hal berikut:

1. Buka kluster Anda. Dari menu sebelah kiri, pilih Database. Kemudian, pilih database yang berisi tabel target.
2. Dari menu sebelah kiri, pilih Koneksi data. Kemudian, pilih kotak centang di samping koneksi data Event Grid yang relevan.
3. Dari bilah menu atas, pilih Hapus.

C#

Untuk menghapus koneksi Event Grid, jalankan perintah berikut:

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

Python

Untuk menghapus koneksi Event Grid, jalankan perintah berikut:

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)

Langkah berikutnya

• Memproses data dari pusat aktivitas Anda menggunakan Azure Stream Analytics