Azure Veri Gezgini için Event Grid veri bağlantısı oluşturma

Bu makalede, Event Grid veri bağlantısı kullanarak depolama hesabınızdaki blobları Azure Veri Gezgini'a nasıl alacağınızı öğreneceksiniz. Azure Event Grid aboneliğini ayarlayan bir Event Grid veri bağlantısı oluşturacaksınız. Event Grid aboneliği, olayları depolama hesabınızdan Azure Event Hubs aracılığıyla Azure Veri Gezgini yönlendirir.

Event Grid'den Azure Veri Gezgini alma hakkında genel bilgi için bkz. Event Grid'e bağlanma.

Not

Event Grid bağlantısıyla en iyi performansı elde etmek için blob meta verileri aracılığıyla alma özelliğini ayarlayın rawSizeBytes . Daha fazla bilgi için bkz . alma özellikleri.

Önkoşullar

• Azure aboneliği. Ücretsiz bir Azure hesabı oluşturun.
• Azure Veri Gezgini kümesi ve veritabanı. Küme ve veritabanı oluşturma.
• Hedef tablo. Tablo oluşturun veya var olan bir tabloyu kullanın.
• Tablo için alım eşlemesi.
• Depolama hesabı. Bir Event Grid bildirim aboneliği, , StorageV2veya Data Lake Storage 2. Nesil için BlobStorageAzure Depolama hesaplarında ayarlanabilir.

Event Grid veri bağlantısı oluşturma

Bu bölümde Event Grid ile Azure Veri Gezgini tablonuz arasında bir bağlantı kuracaksınız.

Portal - Azure Veri Gezgini

1. Oluşturduğunuz kümenin altında Veritabanları>TestDatabase'i seçin.

   

2. Veri alımı>Veri bağlantısı ekle'yi seçin.

   

3. Temel Bilgiler'in altında bağlantı türünü seçin: Blob depolama ve ardından formu aşağıdaki bilgilerle doldurun:

   

   Ayar	Önerilen değer	Alan açıklaması
   Veri bağlantısı adı	test-grid-connection	Azure Veri Gezgini'da oluşturmak istediğiniz bağlantının adı.
   Depolama hesabı aboneliği	Abonelik kimliğiniz	Depolama hesabınızın bulunduğu abonelik kimliği.
   Storage account	gridteststorage1	Daha önce oluşturduğunuz depolama hesabının adı.
   Olay türü	Blob oluşturuldu veya Blob yeniden adlandırıldı	Alımı tetikleyen olay türü. Yeniden adlandırılan blob yalnızca ADLSv2 depolama için desteklenir. Blobu yeniden adlandırmak için Azure portalında bloba gidin, bloba sağ tıklayın ve Yeniden Adlandır'ı seçin. Desteklenen türler şunlardır: Microsoft.Storage.BlobCreated veya Microsoft.Storage.BlobRenamed.
   Kaynak oluşturma	Otomatik	Azure Veri Gezgini'nin sizin için Event Grid Aboneliği, Event Hubs ad alanı ve Event Hubs oluşturmasını isteyip istemediğinizi tanımlayın. Kaynakları el ile oluşturmak için bkz . Event Grid alımı için kaynakları el ile oluşturma

4. Belirli konuları izlemek istiyorsanız Ayarları filtrele'yi seçin. Bildirimlerin filtrelerini aşağıdaki gibi ayarlayın:

   • Ön ek alanı, konunun değişmez önekidir. Uygulanan desen ile başladığından, birden çok kapsayıcıya, klasöre veya bloba yayılabilir. Joker karakterlere izin verilmez.
     • Blob kapsayıcısı üzerinde bir filtre tanımlamak için, alanın şu şekilde ayarlanması gerekir : /blobServices/default/containers/[container prefix].
     • Blob ön ekinde (veya Azure Data Lake 2. Nesil'de bir klasörde) filtre tanımlamak için, alanın şu şekilde ayarlanması gerekir : /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • Sonek alanı, blobun değişmez değer son ekidir. Joker karakterlere izin verilmez.
   • Büyük/Küçük Harfe Duyarlı alan, önek ve sonek filtrelerinin büyük/küçük harfe duyarlı olup olmadığını gösterir
   • Olayları filtreleme hakkında daha fazla bilgi için bkz . Blob depolama olayları.

   

5. İleri: Alma özellikleri'ni seçin.

6. Formu aşağıdaki bilgilerle doldurun. Tablo ve eşleme adları büyük/küçük harfe duyarlıdır:

   

   Alma özellikleri:

   Ayar	Önerilen değer	Alan açıklaması
   Verileri diğer veritabanlarına yönlendirmeye izin ver (Çoklu veritabanı veri bağlantısı)	İzin verme	Veri bağlantısıyla ilişkili varsayılan hedef veritabanını geçersiz kılmak istiyorsanız bu seçeneği açın. Veritabanı yönlendirmesi hakkında daha fazla bilgi için bkz . Olay yönlendirme.
   Tablo adı	TestTable	TestDatabase içinde oluşturduğunuz tablo.
   Veri biçimi	JSON	Desteklenen biçimler Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW ve W3CLOG'dur. Desteklenen sıkıştırma seçenekleri Zip ve Gzip'dir.
   Eşleme	TestMapping	Gelen verileri TestTable'ın sütun adlarına ve veri türlerine eşleyen TestDatabase'de oluşturduğunuz eşleme. Belirtilmezse, tablonun şemasından türetilen bir kimlik veri eşlemesi kullanılır.
   Gelişmiş ayarlar	Verilerimde üst bilgiler var	Üst bilgileri yoksayar. *SV türü dosyaları için desteklenir.

   Not

   Tüm Varsayılan yönlendirme ayarlarını belirtmeniz gerekmez. Kısmi ayarlar da kabul edilir.

7. İleri: gözden geçir + oluştur'u seçin

8. *Gözden geçir + oluştur altında.

9. Sizin için otomatik olarak oluşturulan kaynakları gözden geçirin ve Oluştur'u seçin.

   

10. Dağıtım tamamlanana kadar bekleyin. Dağıtımınız başarısız olduysa, başarısızlığın nedeni hakkında daha fazla bilgi edinmek için başarısız aşamanın yanındaki İşlem ayrıntıları'nı seçin. Kaynakları yeniden dağıtmayı denemek için Yeniden dağıt'ı seçin. Dağıtımdan önce parametreleri değiştirebilirsiniz.

    

Portal - Azure depolama

1. Azure portalında depolama hesabına göz atın. Soldaki menüden Olaylar'ı seçin

2. Ana bölmede Azure Veri Gezgini sekmesini seçin.

   

Veri bağlantısı bölmesi açılır ve Temel Bilgiler sekmesi seçili durumdadır.

1. Temel Bilgiler'in altında formu aşağıdaki bilgilerle doldurun:

   

   Ayar	Önerilen değer	Alan açıklaması
   Veri bağlantısı adı	test-grid-connection	Azure Veri Gezgini'da oluşturmak istediğiniz bağlantının adı.
   Storage account	gridteststorage1	Bu sihirbaza erişmiş olduğunuz depolama hesabı. Otomatik doldurulan.
   Olay türü	Blob oluşturuldu veya Blob yeniden adlandırıldı	Alımı tetikleyen olay türü. Yeniden adlandırılan blob yalnızca ADLSv2 depolama için desteklenir. Blobu yeniden adlandırmak için Azure portalında bloba gidin, bloba sağ tıklayın ve Yeniden Adlandır'ı seçin. Desteklenen türler şunlardır: Microsoft.Storage.BlobCreated veya Microsoft.Storage.BlobRenamed.
   Kaynak oluşturma	Otomatik	Azure Veri Gezgini'nin sizin için Event Grid Aboneliği, Event Hubs ad alanı ve Event Hubs oluşturmasını isteyip istemediğinizi tanımlayın. Kaynakları el ile oluşturmak için bkz . Event Grid alımı için kaynakları el ile oluşturma

2. Sonraki Alma özellikleri'ni> seçin.

3. Alma özellikleri altında.

4. Formu aşağıdaki bilgilerle doldurun. Tablo ve eşleme adları büyük/küçük harfe duyarlıdır:

   

   Ayar	Önerilen değer	Alan açıklaması
   Abonelik		Azure Veri Gezgini aboneliğiniz.
   Küme Adı	TestCluster	Verileri almak istediğiniz kümenin adı.
   Veritabanı Adı	TestDatabase	TestCluster'da oluşturduğunuz hedef veritabanı.
   Verileri diğer veritabanlarına yönlendirmeye izin ver (Çoklu veritabanı veri bağlantısı)	İzin verme	Veri bağlantısıyla ilişkili varsayılan hedef veritabanını geçersiz kılmak istiyorsanız bu seçeneği açın. Veritabanı yönlendirmesi hakkında daha fazla bilgi için bkz . Olay yönlendirme.
   Tablo adı	TestTable	TestDatabase'de oluşturduğunuz hedef tablo.
   Veri biçimi	JSON	Desteklenen biçimler Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW ve W3CLOG'dur. Desteklenen sıkıştırma seçenekleri Zip ve Gzip'dir.
   Eşleme	TestMapping	Gelen verileri TestTable'ın sütun adlarına ve veri türlerine eşleyen TestDatabase'de oluşturduğunuz eşleme. Belirtilmezse, tablonun şemasından türetilen bir kimlik veri eşlemesi kullanılır.
   Gelişmiş ayarlar	Verilerimde üst bilgiler var	Üst bilgileri yoksayar. *SV türü dosyaları için desteklenir.

   Not

   Tüm Veri yönlendirme ayarlarını belirtmeniz gerekmez. Kısmi ayarlar da kabul edilir.

5. İleri: gözden geçir + oluştur'u seçin

6. Gözden geçir ve oluştur'un altında.

7. Sizin için otomatik olarak oluşturulan kaynakları gözden geçirin ve Oluştur'u seçin.

   

8. Dağıtım tamamlanana kadar bekleyin. Dağıtımınız başarısız olduysa, başarısızlığın nedeni hakkında daha fazla bilgi edinmek için başarısız aşamanın yanındaki İşlem ayrıntıları'nı seçin. Kaynakları yeniden dağıtmayı denemek için Yeniden dağıt'ı seçin. Dağıtımdan önce parametreleri değiştirebilirsiniz.

   

C#

1. Microsoft.Azure.Management.Kusto NuGet paketini yükleyin.

2. Kimlik doğrulaması için kullanılacak bir Azure AD uygulama sorumlusu oluşturun. Dizin (kiracı) kimliği, uygulama kimliği ve istemci gizli dizisi gerekir.

3. Aşağıdaki kodu çalıştırın.

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

   Ayar	Önerilen değer	Alan açıklaması
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracı kimliğiniz. Dizin kimliği olarak da bilinir.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kaynak oluşturmak için kullandığınız abonelik kimliği.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci kimliği.
   clientSecret	PlaceholderClientSecret	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci gizli dizisi.
   resourceGroupName	testrg	Kümenizi içeren kaynak grubunun adı.
   clusterName	mykustocluster	Kümenizin adı.
   veritabanıAdı	mykustodatabase	Kümenizdeki hedef veritabanının adı.
   eventGridConnectionName	myeventgridconnect	Veri bağlantınızın istenen adı.
   tableName	StormEvents	Hedef veritabanındaki hedef tablonun adı.
   mappingRuleName	StormEvents_CSV_Mapping	Hedef tabloyla ilgili sütun eşlemenizin adı.
   dataFormat	csv	İletinin veri biçimi.
   eventHubResourceId	Kaynak Kimliği	Event Grid'in olayları gönderecek şekilde yapılandırıldığı olay hub'ınızın kaynak kimliği.
   storageAccountResourceId	Kaynak Kimliği	Veri alımı için verileri tutan depolama hesabınızın kaynak kimliği.
   consumerGroup	$Default	Olay hub'ınızın tüketici grubu.
   konum	Central US	Veri bağlantısı kaynağının konumu.
   blobStorageEventType	Microsoft.Storage.BlobCreated	Alımı tetikleyen olay türü. Desteklenen olaylar şunlardır: Microsoft.Storage.BlobCreated veya Microsoft.Storage.BlobRenamed. Blob yeniden adlandırma yalnızca ADLSv2 depolama için desteklenir.
   databaseRouting	Çoklu veya Tek	Bağlantı için veritabanı yönlendirmesi. Değeri Tek olarak ayarlarsanız, veri bağlantısı databaseName ayarında belirtildiği gibi kümedeki tek bir veritabanına yönlendirilir. Değeri Multi olarak ayarlarsanız, Veritabanı alımı özelliğini kullanarak varsayılan hedef veritabanını geçersiz kılabilirsiniz. Daha fazla bilgi için bkz . Olay yönlendirme.

Python

1. Gerekli kitaplıkları yükleyin.

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

2. Kimlik doğrulaması için kullanılacak bir Azure AD uygulama sorumlusu oluşturun. Dizin (kiracı) kimliği, uygulama kimliği ve istemci gizli dizisi gerekir.

3. Aşağıdaki kodu çalıştırın.

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

   Ayar	Önerilen değer	Alan açıklaması
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracı kimliğiniz. Dizin kimliği olarak da bilinir.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kaynak oluşturmak için kullandığınız abonelik kimliği.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci kimliği.
   client_secret	xxxxxxxxxxx	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci gizli dizisi.
   resource_group_name	testrg	Kümenizi içeren kaynak grubunun adı.
   cluster_name	mykustocluster	Kümenizin adı.
   database_name	mykustodatabase	Kümenizdeki hedef veritabanının adı.
   data_connection_name	myeventhubconnect	Veri bağlantınızın istenen adı.
   table_name	StormEvents	Hedef veritabanındaki hedef tablonun adı.
   mapping_rule_name	StormEvents_CSV_Mapping	Hedef tabloyla ilgili sütun eşlemenizin adı.
   database_routing	Çoklu veya Tek	Bağlantı için veritabanı yönlendirmesi. Değeri Tek olarak ayarlarsanız, veri bağlantısı databaseName ayarında belirtildiği gibi kümedeki tek bir veritabanına yönlendirilir. Değeri Multi olarak ayarlarsanız, Veritabanı alımı özelliğini kullanarak varsayılan hedef veritabanını geçersiz kılabilirsiniz. Daha fazla bilgi için bkz . Olay yönlendirme.
   data_format	csv	İletinin veri biçimi.
   event_hub_resource_id	Kaynak Kimliği	Event Grid'in olayları gönderecek şekilde yapılandırıldığı olay hub'ınızın kaynak kimliği.
   storage_account_resource_id	Kaynak Kimliği	Veri alımı için verileri tutan depolama hesabınızın kaynak kimliği.
   consumer_group	$Default	Olay hub'ınızın tüketici grubu.
   konum	Central US	Veri bağlantısı kaynağının konumu.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	Alımı tetikleyen olay türü. Desteklenen olaylar şunlardır: Microsoft.Storage.BlobCreated veya Microsoft.Storage.BlobRenamed. Blob yeniden adlandırma yalnızca ADLSv2 depolama için desteklenir.

ARM şablonu

Aşağıdaki örnekte Event Grid veri bağlantısı eklemeye yönelik bir Azure Resource Manager şablonu gösterilmektedir. Formu kullanarak şablonu Azure portalında düzenleyebilir ve dağıtabilirsiniz.

{
    "$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 veri bağlantısını kaldırma

Portal

Event Grid bağlantısını Azure portalından kaldırmak için aşağıdakileri yapın:

1. Kümenize gidin. Soldaki menüden Veritabanları'nı seçin. Ardından hedef tabloyu içeren veritabanını seçin.
2. Soldaki menüden Veri bağlantıları'nı seçin. Ardından ilgili Event Grid veri bağlantısının yanındaki onay kutusunu seçin.
3. Üst menü çubuğunda Sil'i seçin.

C#

Event Grid bağlantısını kaldırmak için aşağıdaki komutu çalıştırın:

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

Python

Event Grid bağlantısını kaldırmak için aşağıdaki komutu çalıştırın:

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)

Sonraki adımlar

• Azure Stream Analytics'i kullanarak olay hub'ınızdaki verileri işleme