Usar blocos de anotações de malha com dados de um banco de dados KQL
Os blocos de notas são documentos legíveis que contêm descrições e resultados da análise de dados e documentos executáveis que podem ser executados para executar a análise de dados. Neste artigo, você aprenderá a usar um bloco de anotações de malha para se conectar a dados em um banco de dados KQL e executar consultas usando KQL (Kusto Query Language) nativo. Para obter mais informações sobre blocos de anotações, consulte Como usar blocos de anotações do Microsoft Fabric.
Há duas maneiras de usar blocos de anotações de malha com dados do banco de dados KQL:
- Usar trechos do Kusto em um bloco de anotações
- Criar um bloco de notas a partir de uma base de dados KQL
Pré-requisitos
- Um espaço de trabalho com uma capacidade habilitada para Microsoft Fabric
- Um banco de dados KQL com pelo menos permissões de visualização
Usar trechos do Kusto em um bloco de anotações
Os blocos de anotações de malha fornecem trechos de código que ajudam você a escrever facilmente padrões de código comumente usados. Você pode usar trechos para escrever ou ler dados em um banco de dados KQL usando o KQL.
Navegue até um bloco de anotações existente ou crie um novo.
Em uma célula de código, comece a digitar kusto.
Selecione o trecho que corresponde à operação que você deseja executar: Gravar dados em um banco de dados KQL ou Ler dados de um banco de dados KQL.
O trecho de código a seguir mostra a operação de leitura de dados de exemplo:
# Example of query for reading data from Kusto. Replace T with your <tablename>. kustoQuery = "['T'] | take 10" # The query URI for reading the data e.g. https://<>.kusto.data.microsoft.com. kustoUri = "https://<yourKQLdatabaseURI>.z0.kusto.data.microsoft.com" # The database with data to be read. database = "DocsDatabase" # The access credentials. accessToken = mssparkutils.credentials.getToken(kustoUri) kustoDf = spark.read\ .format("com.microsoft.kusto.spark.synapse.datasource")\ .option("accessToken", accessToken)\ .option("kustoCluster", kustoUri)\ .option("kustoDatabase", database)\ .option("kustoQuery", kustoQuery).load() # Example that uses the result data frame. kustoDf.show()
O trecho de código a seguir mostra o exemplo de operação de gravação de dados:
# The Kusto cluster uri to write the data. The query Uri is of the form https://<>.kusto.data.microsoft.com kustoUri = "" # The database to write the data database = "" # The table to write the data table = "" # The access credentials for the write accessToken = mssparkutils.credentials.getToken(kustoUri) # Generate a range of 5 rows with Id's 5 to 9 data = spark.range(5,10) # Write data to a Kusto table data.write.\ format("com.microsoft.kusto.spark.synapse.datasource").\ option("kustoCluster",kustoUri).\ option("kustoDatabase",database).\ option("kustoTable", table).\ option("accessToken", accessToken ).\ option("tableCreateOptions", "CreateIfNotExist").mode("Append").save()
Insira as informações necessárias entre aspas de cada campo na célula de dados:
Campo Descrição Ligações relacionadas kustoQuery A consulta KQL a ser avaliada. Descrição geral do KQL KustoUri O URI de consulta do seu banco de dados KQL. Copiar um URI de banco de dados KQL base de dados O nome do seu banco de dados KQL. Acessar um banco de dados KQL existente dados Os dados a serem gravados na tabela. Execute a célula de código.
Criar um bloco de notas a partir de uma base de dados KQL
Quando você cria um bloco de anotações como um item relacionado em um banco de dados KQL, o bloco de anotações recebe o mesmo nome que o banco de dados KQL e é pré-preenchido com informações de conexão.
Navegue até a sua base de dados KQL.
Selecione Novo item>relacionado Bloco de Anotações.
Um bloco de anotações é criado com o KustoUri e os detalhes do banco de dados pré-preenchidos.
Insira a consulta KQL a ser avaliada no campo kustoQuery .
Execute a célula de código.