Creación de una conexión de datos de Event Grid para Azure Data Explorer

En este artículo, aprenderá a ingerir blobs desde la cuenta de almacenamiento en Azure Data Explorer mediante una conexión de datos de Event Grid. Creará una conexión de datos de Event Grid que establece una suscripción de Azure Event Grid. La suscripción de Event Grid enruta los eventos desde la cuenta de almacenamiento a Azure Data Explorer mediante Azure Event Hubs.

Para información general sobre la ingesta en Azure Data Explorer desde Event Grid, consulte Conexión a Event Grid.

Nota:

Para lograr el mejor rendimiento con la conexión de Event Grid, establezca la propiedad de ingesta rawSizeBytes a través de los metadatos del blob. Para obtener más información, vea propiedades de ingesta.

Requisitos previos

• Suscripción a Azure. Cree una cuenta de Azure gratuita.
• Un clúster y la base de datos de Azure Data Explorer. Cree un clúster y una base de datos.
• Una tabla de destino. Cree una tabla o use una tabla existente.
• Una asignación de ingesta para la tabla.
• Una cuenta de almacenamiento. Una suscripción de notificación de Event Grid se puede establecer en cuentas de Azure Storage para BlobStorage, StorageV2 o Data Lake Storage Gen2.

Creación de una conexión de datos de Event Grid

En esta sección, establecerá una conexión entre Event Grid y la tabla de Azure Data Explorer.

Portal: Azure Data Explorer

1. En el clúster que creó, seleccione Bases de datos>TestDatabase.

   

2. Seleccione Ingesta de datos>Agregar la conexión de datos.

   

3. En Aspectos básicos, seleccione el tipo de conexión: Blob Storage y, a continuación, rellene el formulario con la siguiente información:

   

   Configuración	Valor sugerido	Descripción del campo
   Nombre de la conexión de datos	test-grid-connection	Nombre de la conexión que desea crear en Azure Data Explorer.
   Suscripción de la cuenta de almacenamiento	Su Id. de suscripción	El identificador de la suscripción en la que reside la cuenta de almacenamiento.
   Cuenta de almacenamiento	gridteststorage1	Nombre de la cuenta de almacenamiento que creó anteriormente.
   Tipo de evento	Blob creado o Blob con el nombre cambiado	Tipo de evento que desencadena la ingesta. El evento Blob con el nombre cambiado solo se admite para el almacenamiento de ADLSv2. Para cambiar el nombre de un blob, vaya al blob en Azure Portal, haga clic con el botón derecho en el blob y seleccione Cambiar nombre. Estos son los tipos que se admiten: Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed.
   Creación de recursos	Automático	Defina si desea que Azure Data Explorer cree una suscripción de Event Grid, un espacio de nombres de Event Hubs y una instancia de este automáticamente. Para crear los recursos de forma manual, consulte Creación manual de recursos para la ingesta de Event Grid.

4. Seleccione Configuración del filtro si desea realizar un seguimiento de determinados asuntos. Establezca los filtros para las notificaciones de la manera siguiente:

   • El campo prefijo es el prefijo literal del asunto. Como el patrón que se aplica es startswith (comienza por), puede abarcar varios contenedores, carpetas o blobs. No se permiten comodines.
     • Para definir un filtro en el contenedor de blobs, el campo debe establecerse de la siguiente manera: /blobServices/default/containers/[container prefix].
     • Para definir un filtro en un prefijo de blob (o en una carpeta en Azure Data Lake Gen2), el campo debe establecerse de la siguiente manera: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • El campo sufijo es el sufijo literal del blob. No se permiten comodines.
   • El campo Distinguir mayúsculas de minúsculas indica si los filtros de prefijos y sufijos distinguen mayúsculas de minúsculas.
   • Para más información sobre el filtrado de eventos, consulte Eventos de Blob Storage.

   

5. Seleccione Siguiente: Propiedades de ingesta.

6. Rellene el formulario con la siguiente información. Los nombres de tabla y de asignación distinguen mayúsculas de minúsculas:

   

   Propiedades de ingesta:

   Configuración	Valor sugerido	Descripción del campo
   Permite el enrutamiento de los datos a otras bases de datos (conexión de datos de varias bases de datos)	No permitir	Activar esta opción si desea invalidar la base de datos de destino predeterminada asociada a la conexión de datos. Para más información acerca del enrutamiento de bases de datos, consulte Enrutamiento de eventos.
   Nombre de tabla	TestTable	La tabla que creó en TestDatabase.
   Formato de datos	JSON	Los formatos admitidos son Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW y W3CLOG. Las opciones de compresión admitidas son Zip y Gzip.
   Asignación	TestMapping	La asignación que creó en TestDatabase, que asigna los datos entrantes a los nombres de columna y los tipos de datos de TestTable. Si no se especifica, se usa una asignación de datos de identidad derivada del esquema de la tabla.
   Configuración avanzada	Mis datos tienen encabezados	Ignora los encabezados. Se admite para archivos de tipo *SV.

   Nota

   No es necesario especificar todos los valores de configuración de enrutamiento predeterminados. También se aceptan configuraciones parciales.

7. Seleccione Siguiente:Revisar y crear.

8. En *Revisar y crear.

9. Revise los recursos que se crearon automáticamente y seleccione Crear.

   

10. Espere hasta que se complete la implementación. Si se produce un error en la implementación, seleccione Detalles de la operación junto a la fase con errores para más información sobre el motivo del error. Seleccione Volver a implementar para intentar implementar los recursos de nuevo. Puede modificar los parámetros antes de la implementación.

    

Portal: Azure Storage

1. Vaya a la cuenta de almacenamiento en Azure Portal. En el menú de la izquierda, seleccione Eventos

2. En el panel principal, seleccione la pestaña Azure Data Explorer.

   

Se abre el panel Conexión de datos con la pestaña Aspectos básicos seleccionada.

1. En Aspectos básicos, rellene el formulario con la siguiente información:

   

   Configuración	Valor sugerido	Descripción del campo
   Nombre de la conexión de datos	test-grid-connection	Nombre de la conexión que desea crear en Azure Data Explorer.
   Cuenta de almacenamiento	gridteststorage1	La cuenta de almacenamiento desde la que ha accedido a este asistente. Se rellena automáticamente.
   Tipo de evento	Blob creado o Blob con el nombre cambiado	Tipo de evento que desencadena la ingesta. El evento Blob con el nombre cambiado solo se admite para el almacenamiento de ADLSv2. Para cambiar el nombre de un blob, vaya al blob en Azure Portal, haga clic con el botón derecho en el blob y seleccione Cambiar nombre. Estos son los tipos que se admiten: Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed.
   Creación de recursos	Automático	Defina si desea que Azure Data Explorer cree una suscripción de Event Grid, un espacio de nombres de Event Hubs y una instancia de este automáticamente. Para crear los recursos de forma manual, consulte Creación manual de recursos para la ingesta de Event Grid.

2. Seleccione Siguiente> Propiedades de ingesta.

3. En Propiedades de ingesta.

4. Rellene el formulario con la siguiente información. Los nombres de tabla y de asignación distinguen mayúsculas de minúsculas:

   

   Configuración	Valor sugerido	Descripción del campo
   Subscription		La suscripción de Azure Data Explorer.
   Cluster Name	TestCluster	Nombre del clúster en que desea ingerir datos.
   Nombre de la base de datos	TestDatabase	Base de datos de destino que creó en TestCluster.
   Permite el enrutamiento de los datos a otras bases de datos (conexión de datos de varias bases de datos)	No permitir	Activar esta opción si desea invalidar la base de datos de destino predeterminada asociada a la conexión de datos. Para más información acerca del enrutamiento de bases de datos, consulte Enrutamiento de eventos.
   Nombre de tabla	TestTable	Tabla de destino que creó en TestDatabase.
   Formato de datos	JSON	Los formatos admitidos son Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW y W3CLOG. Las opciones de compresión admitidas son Zip y Gzip.
   Asignación	TestMapping	La asignación que creó en TestDatabase, que asigna los datos entrantes a los nombres de columna y los tipos de datos de TestTable. Si no se especifica, se usa una asignación de datos de identidad derivada del esquema de la tabla.
   Configuración avanzada	Mis datos tienen encabezados	Ignora los encabezados. Se admite para archivos de tipo *SV.

   Nota:

   No es necesario especificar todos los valores de configuración de enrutamiento de datos. También se aceptan configuraciones parciales.

5. Seleccione Siguiente:Revisar y crear.

6. En Revisar y crear.

7. Revise los recursos que se crearon automáticamente y seleccione Crear.

   

8. Espere hasta que se complete la implementación. Si se produce un error en la implementación, seleccione Detalles de la operación junto a la fase con errores para más información sobre el motivo del error. Seleccione Volver a implementar para intentar implementar los recursos de nuevo. Puede modificar los parámetros antes de la implementación.

   

C#

1. Instale el paquete Microsoft.Azure.Management.Kusto NuGet.

2. Cree una entidad de seguridad de aplicación de Azure AD que se usará para la autenticación. Necesitará el identificador de directorio (inquilino), el identificador de aplicación y el secreto de cliente.

3. Ejecute el código siguiente:

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

   Configuración	Valor sugerido	Descripción del campo
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	El identificador de inquilino. También conocido como identificador de directorio.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identificador de suscripción que se usa para la creación de recursos.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identificador del cliente de la aplicación que puede acceder a los recursos del inquilino.
   clientSecret	PlaceholderClientSecret	Secreto del cliente de la aplicación que puede acceder a los recursos del inquilino.
   resourceGroupName	testrg	Nombre del grupo de recursos que contiene el clúster.
   clusterName	mykustocluster	Nombre del clúster.
   databaseName	mykustodatabase	Nombre de la base de datos de destino del clúster.
   eventGridConnectionName	myeventgridconnect	Nombre que desea asignar a la conexión de datos.
   tableName	StormEvents	Nombre de la tabla de destino de la base de datos de destino.
   mappingRuleName	StormEvents_CSV_Mapping	Nombre de la asignación de columnas asociada a la tabla de destino.
   dataFormat	csv	Formato de datos del mensaje.
   eventHubResourceId	Identificador del recurso	Identificador del recurso del centro de eventos en el que se ha configurado Event Grid para que envíe eventos.
   storageAccountResourceId	Identificador del recurso	Identificador del recurso de la cuenta de almacenamiento que contiene los datos que se van a ingerir.
   consumerGroup	$Default	Grupo de consumidores del centro de eventos.
   ubicación	Centro de EE. UU.	Ubicación del recurso de conexión de datos.
   blobStorageEventType	Microsoft.Storage.BlobCreated	Tipo de evento que desencadena la ingesta. Los eventos admitidos son: Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed. El cambio de nombre de blobs solo se admite para el almacenamiento de ADLSv2.
   databaseRouting	Múltiple o Sencillo	Enrutamiento de la base de datos para la conexión. Si establece el valor en Sencillo, la conexión de datos se enruta a una base de datos única del clúster, tal y como se especifica en la opción databaseName. Si establece el valor en Múltiple, puede invalidar la base de datos de destino predeterminada mediante la propiedad de ingesta Base de datos. Para más información, consulte Enrutamiento de eventos.

Python

1. Instale las bibliotecas necesarias.

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

2. Cree una entidad de seguridad de aplicación de Azure AD que se usará para la autenticación. Necesitará el identificador de directorio (inquilino), el identificador de aplicación y el secreto de cliente.

3. Ejecute el código siguiente:

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

   Configuración	Valor sugerido	Descripción del campo
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	El identificador de inquilino. También conocido como identificador de directorio.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identificador de suscripción que se usa para la creación de recursos.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	Identificador del cliente de la aplicación que puede acceder a los recursos del inquilino.
   client_secret	xxxxxxxxxxxxxx	Secreto del cliente de la aplicación que puede acceder a los recursos del inquilino.
   resource_group_name	testrg	Nombre del grupo de recursos que contiene el clúster.
   cluster_name	mykustocluster	Nombre del clúster.
   database_name	mykustodatabase	Nombre de la base de datos de destino del clúster.
   data_connection_name	myeventhubconnect	Nombre que desea asignar a la conexión de datos.
   table_name	StormEvents	Nombre de la tabla de destino de la base de datos de destino.
   mapping_rule_name	StormEvents_CSV_Mapping	Nombre de la asignación de columnas asociada a la tabla de destino.
   database_routing	Múltiple o Sencillo	Enrutamiento de la base de datos para la conexión. Si establece el valor en Sencillo, la conexión de datos se enruta a una base de datos única del clúster, tal y como se especifica en la opción databaseName. Si establece el valor en Múltiple, puede invalidar la base de datos de destino predeterminada mediante la propiedad de ingesta Base de datos. Para más información, consulte Enrutamiento de eventos.
   data_format	csv	Formato de datos del mensaje.
   event_hub_resource_id	Identificador del recurso	Identificador del recurso del centro de eventos en el que se ha configurado Event Grid para que envíe eventos.
   storage_account_resource_id	Identificador del recurso	Identificador del recurso de la cuenta de almacenamiento que contiene los datos que se van a ingerir.
   consumer_group	$Default	Grupo de consumidores del centro de eventos.
   ubicación	Centro de EE. UU.	Ubicación del recurso de conexión de datos.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	Tipo de evento que desencadena la ingesta. Los eventos admitidos son: Microsoft.Storage.BlobCreated o Microsoft.Storage.BlobRenamed. El cambio de nombre de blobs solo se admite para el almacenamiento de ADLSv2.

Plantilla ARM

En el ejemplo siguiente se muestra una plantilla de Azure Resource Manager para agregar una conexión de datos de Event Grid. Puede editar e implementar la plantilla en Azure Portal mediante el formulario.

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

Eliminar una conexión de datos de Event Grid

Portal

Para quitar la conexión de Event Grid desde Azure Portal, haga lo siguiente:

1. Vaya al clúster. En el menú de la izquierda, seleccione Bases de datos. A continuación, seleccione la base de datos que contiene la tabla de destino.
2. En el menú de la izquierda, seleccione Conexiones de datos. A continuación, active la casilla situada junto a la conexión de datos de Event Grid correspondiente.
3. En la barra de menús superior, seleccione Eliminar.

C#

Para quitar la conexión de Event Grid, ejecute el siguiente comando:

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

Python

Para quitar la conexión de Event Grid, ejecute el siguiente comando:

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)

Pasos siguientes

• Procesamiento de datos de un centro de eventos con Azure Stream Analytics