Criar uma ligação de dados do Event Grid para o Azure Data Explorer

Neste artigo, vai aprender a ingerir blobs da sua conta de armazenamento no Azure Data Explorer através de uma ligação de dados do Event Grid. Irá criar uma ligação de dados do Event Grid que define uma subscrição Azure Event Grid. A subscrição do Event Grid encaminha eventos da sua conta de armazenamento para o Azure Data Explorer através de um Hubs de Eventos do Azure.

Para obter informações gerais sobre como ingerir no Azure Data Explorer do Event Grid, veja Ligar ao Event Grid.

Nota

Para obter o melhor desempenho com a ligação do Event Grid, defina a rawSizeBytes propriedade ingestão através dos metadados do blob. Para obter mais informações, veja Propriedades de ingestão.

Pré-requisitos

• Uma subscrição do Azure. Crie uma conta gratuita do Azure.
• Um cluster e uma base de dados do Azure Data Explorer. Criar um cluster e uma base de dados.
• Uma tabela de destino. Crie uma tabela ou utilize uma tabela existente.
• Um mapeamento de ingestão para a tabela.
• Uma conta de armazenamento. Uma subscrição de notificação do Event Grid pode ser definida em contas de Armazenamento do Azure para BlobStorage, StorageV2ou Data Lake Storage Gen2.

Criar uma ligação de dados do Event Grid

Nesta secção, vai estabelecer uma ligação entre o Event Grid e a sua tabela de Data Explorer do Azure.

Portal - Data Explorer do Azure

1. No cluster que criou, selecione Bases de Dados>TestDatabase.

   

2. Selecione Ingestão de>dados Adicionar ligação de dados.

   

3. Em Noções básicas, selecione o tipo de ligação: Armazenamento de blobs e, em seguida, preencha o formulário com as seguintes informações:

   

   Definição	Valor sugerido	Descrição do campo
   Nome da ligação de dados	test-grid-connection	O nome da ligação que pretende criar no Azure Data Explorer.
   Subscrição da conta de armazenamento	O ID da subscrição	O ID da subscrição onde se encontra a sua conta de armazenamento.
   Conta de armazenamento	gridteststorage1	O nome da conta de armazenamento que criou anteriormente.
   Tipo de evento	Blob criado ou Blob mudado	O tipo de evento que aciona a ingestão. O nome do blob mudado é suportado apenas para o armazenamento do ADLSv2. Para mudar o nome de um blob, navegue para o blob em portal do Azure, clique com o botão direito do rato no blob e selecione Mudar o nome. Os tipos suportados são: Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed.
   Criação de recursos	Automático	Defina se pretende que o Azure Data Explorer crie uma Subscrição do Event Grid, um espaço de nomes dos Hubs de Eventos e um Hubs de Eventos para si. Para criar recursos manualmente, veja Criar manualmente recursos para a ingestão do Event Grid

4. Selecione Definições de filtro se quiser controlar assuntos específicos. Defina os filtros para as notificações da seguinte forma:

   • O campo prefixo é o prefixo literal do assunto. À medida que o padrão aplicado é iniciado, pode abranger vários contentores, pastas ou blobs. Não são permitidos carateres universais.
     • Para definir um filtro no contentor de blobs, o campo tem de ser definido da seguinte forma: /blobServices/default/containers/[container prefix].
     • Para definir um filtro num prefixo de blobs (ou numa pasta no Azure Data Lake Gen2), o campo tem de ser definido da seguinte forma: /blobServices/default/containers/[container name]/blobs/[folder/blob prefix].
   • O campo Sufixo é o sufixo literal do blob. Não são permitidos carateres universais.
   • O campo Sensível a Maiúsculas e Minúsculas indica se os filtros de prefixo e sufixo são sensíveis a maiúsculas e minúsculas
   • Para obter mais informações sobre a filtragem de eventos, veja Eventos de armazenamento de blobs.

   

5. Selecione Seguinte: Ingerir propriedades.

6. Preencha o formulário com as seguintes informações. Os nomes das tabelas e mapeamentos são sensíveis às maiúsculas e minúsculas:

   

   Ingerir propriedades:

   Definição	Valor sugerido	Descrição do campo
   Permitir o encaminhamento dos dados para outras bases de dados (ligação de dados de várias bases de dados)	Não permitir	Ative esta opção se quiser substituir a base de dados de destino predefinida associada à ligação de dados. Para obter mais informações sobre o encaminhamento de bases de dados, veja Encaminhamento de eventos.
   Nome da tabela	TestTable	A tabela que criou em TestDatabase.
   Formato de dados	JSON	Os formatos suportados são Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW e W3CLOG. As opções de compressão suportadas são Zip e Gzip.
   Mapeamento	TestMapping	O mapeamento que criou no TestDatabase, que mapeia os dados recebidos para os nomes de colunas e tipos de dados da TestTable. Se não for especificado, é utilizado um mapeamento de dados de identidade derivado do esquema da tabela.
   Definições avançadas	Os meus dados têm cabeçalhos	Ignora cabeçalhos. Suportado para *Ficheiros de tipo SV.

   Nota

   Não tem de especificar todas as definições de encaminhamento Predefinidas. As definições parciais também são aceites.

7. Selecione Seguinte: Rever + criar

8. Em *Rever + criar.

9. Reveja os recursos que foram criados automaticamente e selecione Criar.

   

10. Aguarde até que a implementação esteja concluída. Se a implementação tiver falhado, selecione Detalhes da operação junto à fase com falha para obter mais informações sobre o motivo da falha. Selecione Reimplementar para tentar implementar os recursos novamente. Pode alterar os parâmetros antes da implementação.

    

Portal - Armazenamento do Azure

1. Navegue para a conta de armazenamento no portal do Azure. No menu esquerdo, selecione Eventos

2. No painel principal, selecione o separador Azure Data Explorer.

   

O painel Ligação de dados é aberto com o separador Informações básicas selecionado.

1. Em Noções básicas, preencha o formulário com as seguintes informações:

   

   Definição	Valor sugerido	Descrição do campo
   Nome da ligação de dados	test-grid-connection	O nome da ligação que pretende criar no Azure Data Explorer.
   Conta de armazenamento	gridteststorage1	A conta de armazenamento a partir da qual acedeu a este assistente. Preenchido automaticamente.
   Tipo de evento	Blob criado ou o nome do Blob foi mudado	O tipo de evento que aciona a ingestão. O nome do blob mudado é suportado apenas para o armazenamento do ADLSv2. Para mudar o nome de um blob, navegue para o blob no portal do Azure, clique com o botão direito do rato no blob e selecione Mudar o Nome. Os tipos suportados são: Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed.
   Criação de recursos	Automático	Defina se pretende que o Azure Data Explorer crie uma Subscrição do Event Grid, um espaço de nomes dos Hubs de Eventos e um Hub de Eventos para si. Para criar recursos manualmente, veja Criar manualmente recursos para ingestão do Event Grid

2. Selecione Propriedades da Ingestão Seguinte>.

3. Em Ingerir propriedades.

4. Preencha o formulário com as seguintes informações. Os nomes de tabelas e mapeamentos são sensíveis às maiúsculas e minúsculas:

   

   Definição	Valor sugerido	Descrição do campo
   Subscrição		A sua subscrição do Azure Data Explorer.
   Nome do Cluster	TestCluster	O nome do cluster no qual pretende ingerir dados.
   Nome da base de dados	TestDatabase	A base de dados de destino que criou no TestCluster.
   Permitir o encaminhamento dos dados para outras bases de dados (ligação a dados de várias bases de dados)	Não permitir	Ative esta opção se quiser substituir a base de dados de destino predefinida associada à ligação de dados. Para obter mais informações sobre o encaminhamento de bases de dados, veja Encaminhamento de eventos.
   Nome da tabela	TestTable	A tabela de destino que criou em TestDatabase.
   Formato de dados	JSON	Os formatos suportados são Avro, CSV, JSON, MULTILINE JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHEAVRO, RAW e W3CLOG. As opções de compressão suportadas são Zip e Gzip.
   Mapeamento	TestMapping	O mapeamento que criou em TestDatabase, que mapeia os dados recebidos para os nomes de colunas e tipos de dados de TestTable. Se não for especificado, é utilizado um mapeamento de dados de identidade derivado do esquema da tabela.
   Definições avançadas	Os meus dados têm cabeçalhos	Ignora cabeçalhos. Suportado para *ficheiros de tipo SV.

   Nota

   Não tem de especificar todas as definições de Encaminhamento de dados. As definições parciais também são aceites.

5. Selecione Seguinte: Rever + criar

6. Em Rever + criar.

7. Reveja os recursos que foram criados automaticamente e selecione Criar.

   

8. Aguarde até que a implementação esteja concluída. Se a implementação tiver falhado, selecione Detalhes da operação junto à fase com falha para obter mais informações sobre o motivo da falha. Selecione Reimplementar para tentar implementar os recursos novamente. Pode alterar os parâmetros antes da implementação.

   

C#

1. Instale o pacote NuGet Microsoft.Azure.Management.Kusto.

2. Crie um Azure AD principal de aplicação a utilizar para autenticação. Precisará do ID do diretório (inquilino), do ID da aplicação e do segredo do cliente.

3. Execute o seguinte código.

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

   Definição	Valor sugerido	Descrição do campo
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	O ID do inquilino. Também conhecido como ID de diretório.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	O ID de subscrição que utiliza para a criação de recursos.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	O ID de cliente da aplicação que pode aceder aos recursos no seu inquilino.
   clientSecret	PlaceholderClientSecret	O segredo do cliente da aplicação que pode aceder aos recursos no seu inquilino.
   resourceGroupName	testrg	O nome do grupo de recursos que contém o cluster.
   clusterName	mykustocluster	O nome do cluster.
   databaseName	mykustodatabase	O nome da base de dados de destino no cluster.
   eventGridConnectionName	myeventgridconnect	O nome pretendido da sua ligação de dados.
   tableName	StormEvents	O nome da tabela de destino na base de dados de destino.
   mappingRuleName	StormEvents_CSV_Mapping	O nome do mapeamento de colunas relacionado com a tabela de destino.
   dataFormat	csv	O formato de dados da mensagem.
   eventHubResourceId	ID do Recurso	O ID de recurso do hub de eventos onde o Event Grid está configurado para enviar eventos.
   storageAccountResourceId	ID do Recurso	O ID de recurso da sua conta de armazenamento que contém os dados para ingestão.
   consumerGroup	$Default	O grupo de consumidores do seu hub de eventos.
   localização	E.U.A. Central	A localização do recurso de ligação de dados.
   blobStorageEventType	Microsoft.Storage.BlobCreated	O tipo de evento que aciona a ingestão. Os eventos suportados são: Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed. O nome do blob é suportado apenas para o armazenamento do ADLSv2.
   databaseRouting	Multi ou Single	O encaminhamento da base de dados para a ligação. Se definir o valor como Único, a ligação de dados será encaminhada para uma única base de dados no cluster, conforme especificado na definição databaseName . Se definir o valor como Multi, pode substituir a base de dados de destino predefinida com a propriedade Ingestão de basesde dados. Para obter mais informações, veja Encaminhamento de eventos.

Python

1. Instale as bibliotecas necessárias.

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

2. Crie uma Azure AD principal de aplicação para utilizar para autenticação. Precisará do ID do diretório (inquilino), do ID da aplicação e do segredo do cliente.

3. Execute o seguinte código.

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

   Definição	Valor sugerido	Descrição do campo
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxxx	O ID do inquilino. Também conhecido como ID de diretório.
   subscription_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxxx	O ID da subscrição que utiliza para a criação de recursos.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxxx	O ID de cliente da aplicação que pode aceder aos recursos no seu inquilino.
   client_secret	xxxxxxxxxxxxxx	O segredo do cliente da aplicação que pode aceder aos recursos no seu inquilino.
   resource_group_name	testrg	O nome do grupo de recursos que contém o cluster.
   cluster_name	mykustocluster	O nome do cluster.
   database_name	mykustodatabase	O nome da base de dados de destino no cluster.
   data_connection_name	myeventhubconnect	O nome pretendido da sua ligação de dados.
   table_name	StormEvents	O nome da tabela de destino na base de dados de destino.
   mapping_rule_name	StormEvents_CSV_Mapping	O nome do mapeamento de colunas relacionado com a tabela de destino.
   database_routing	Multi ou Single	O encaminhamento da base de dados para a ligação. Se definir o valor como Único, a ligação de dados será encaminhada para uma única base de dados no cluster, conforme especificado na definição databaseName . Se definir o valor como Multi, pode substituir a base de dados de destino predefinida com a propriedade Ingestão de basesde dados. Para obter mais informações, veja Encaminhamento de eventos.
   data_format	csv	O formato de dados da mensagem.
   event_hub_resource_id	ID do Recurso	O ID de recurso do hub de eventos onde o Event Grid está configurado para enviar eventos.
   storage_account_resource_id	ID do Recurso	O ID de recurso da sua conta de armazenamento que contém os dados para ingestão.
   consumer_group	$Default	O grupo de consumidores do seu hub de eventos.
   localização	E.U.A. Central	A localização do recurso de ligação de dados.
   blob_storage_event_type	Microsoft.Storage.BlobCreated	O tipo de evento que aciona a ingestão. Os eventos suportados são: Microsoft.Storage.BlobCreated ou Microsoft.Storage.BlobRenamed. O nome do blob só é suportado para o armazenamento do ADLSv2.

Modelo ARM

O exemplo seguinte mostra um modelo do Azure Resource Manager para adicionar uma ligação de dados do Event Grid. Pode editar e implementar o modelo no portal do Azure com o formulário.

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

Remover uma ligação de dados do Event Grid

Portal

Para remover a ligação do Event Grid da portal do Azure, faça o seguinte:

1. Aceda ao cluster. No menu esquerdo, selecione Bases de Dados. Em seguida, selecione a base de dados que contém a tabela de destino.
2. No menu esquerdo, selecione Ligações de dados. Em seguida, selecione a caixa de verificação junto à ligação de dados relevante do Event Grid.
3. Na barra de menus superior, selecione Eliminar.

C#

Para remover a ligação do Event Grid, execute o seguinte comando:

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

Python

Para remover a ligação do Event Grid, execute o seguinte 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)

Passos seguintes

• Processar dados do hub de eventos com o Azure Stream Analytics