Ingerir dados do Azure Stream Analytics para o Azure Data Explorer

Antes de começar, certifique-se de que tem uma tarefa existente do Stream Analytics ou crie uma nova e, em seguida, utilize os seguintes passos para criar a ligação Data Explorer do Azure.

1. Inicie sessão no portal do Azure.

2. No portal do Azure, abra Todos os recursos e selecione a tarefa do Stream Analytics.

3. Em Topologia da tarefa, selecione as Saídas.

4. Selecione Adicionar>Data Explorer do Azure.

   

5. Preencha o formulário de saída com as seguintes informações e, em seguida, selecione Guardar.

   Nota

   Pode utilizar as seguintes opções para especificar o cluster e a base de dados:

   • Subscrição: selecione Selecionar Data Explorer do Azure nas suas subscrições, selecione a sua subscrição e, em seguida, selecione o cluster e a base de dados.
   • Manualmente: selecione Fornecer definições de Data Explorer do Azure manualmente, especifique o URI e a base de dados do cluster.

   Nome da propriedade	Description
   Alias de saída	Um nome amigável utilizado nas consultas para direcionar a saída da consulta para esta base de dados.
   Subscrição	Selecione a subscrição do Azure onde reside o cluster.
   Cluster	O nome exclusivo que identifica o cluster. O nome de domínio [região].kusto.windows.net é anexado ao nome de cluster que indicar. O nome pode conter apenas letras minúsculas e números. Tem de conter entre 4 e 22 carateres.
   Cluster URI	O URI de ingestão de dados do cluster. Pode especificar o URI para o Data Explorer do Azure ou Azure Synapse Data Explorer pontos finais de ingestão de dados.
   Base de Dados	O nome da base de dados para onde está a enviar a sua saída. O nome da base de dados tem de ser exclusivo dentro do cluster.
   Autenticação	Uma identidade gerida Microsoft Entra que permite ao cluster aceder facilmente a outros recursos protegidos Microsoft Entra. A identidade é gerida pela plataforma do Azure e não precisa que o utilizador aprovisione ou rode nenhuns segredos. A configuração de identidade gerida permite-lhe utilizar chaves geridas pelo cliente para o cluster.
   Tabela	O nome da tabela para onde está a enviar a sua saída. Os nomes das colunas e os tipos de dados na saída do Azure Stream Analytics têm de corresponder ao esquema da tabela Data Explorer do Azure.

   

O exemplo seguinte mostra um modelo de Resource Manager do Azure para adicionar um conector de saída do Azure Data Explorer. Pode editar e implementar o modelo no portal do Azure para criar o conector.

{
    "$schema": "http://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "streamingJobName": {
            "type": "string",
            "defaultValue": "streamingjob"
        },
        "eventHubNamespace": {
            "type": "string"
        },
        "eventHubKey": {
            "type": "securestring"
        },
        "eventHubName": {
            "type": "string"
        },
        "eventHubConsumerGroupName": {
            "type": "string"
        },
        "streamingUnits": {
            "type": "int",
            "defaultValue": 3
        },
        "ADXClusterUri": {
            "type": "string"
        },
        "ADXDatabaseName": {
            "type": "string"
        },
        "ADXTableName": {
            "type": "string"
        }
    },
    "resources": [
        {
            "apiVersion": "2017-04-01-preview",
            "name": "[parameters('streamingJobName')]",
            "location": "[resourceGroup().location]",
            "type": "Microsoft.StreamAnalytics/StreamingJobs",
            "identity": {
                "type": "systemAssigned"
            },
            "properties": {
                "sku": {
                    "name": "standard"
                },
                "eventsOutOfOrderPolicy": "drop",
                "eventsOutOfOrderMaxDelayInSeconds": 10,
                "compatibilityLevel": "1.2",
                "outputStartMode": "JobStartTime",
                "inputs": [
                    {
                        "name": "inputEventHub",
                        "properties": {
                            "type": "stream",
                            "serialization": {
                                "type": "JSON",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.ServiceBus/EventHub",
                                "properties": {
                                    "serviceBusNamespace": "[parameters('eventHubNamespace')]",
                                    "sharedAccessPolicyName": "RootManageSharedAccessKey",
                                    "sharedAccessPolicyKey": "[parameters('eventHubKey')]",
                                    "eventHubName": "[parameters('eventHubName')]",
                                    "consumerGroupName": "[parameters('eventHubConsumerGroupName')]"
                                }
                            }
                        }
                    }
                ],
                "transformation": {
                    "name": "ProcessSampleData",
                    "properties": {
                        "streamingUnits": "[int(parameters('streamingUnits'))]",
                        "query": "select * from inputEventHub"
                    }
                },
                "outputs": [
                    {
                        "name": "output",
                        "properties": {
                            "serialization": {
                                "type": "CSV",
                                "properties": {
                                    "encoding": "UTF8"
                                }
                            },
                            "datasource": {
                                "type": "Microsoft.Kusto/clusters/databases",
                                "properties": {
                                    "cluster": "[parameters('ADXClusterUri')]",
                                    "table": "[parameters('ADXTableName')]",
                                    "database": "[parameters('ADXDatabaseName')]",
                                    "authenticationMode": "Msi"
                                }
                            }
                        }
                    }
                ]
            }
        }
    ]
}