een query uitvoeren op gegevens met behulp van de Python-bibliotheek voor Azure Data Explorer
In dit artikel voert u een query uit op gegevens met behulp van de Azure Data Explorer. Azure Data Explorer is een snelle en zeer schaalbare service voor gegevensverkenning voor telemetrische gegevens en gegevens uit logboeken.
Azure Data Explorer biedt een gegevens-clientbibliotheek voor Python. Met behulp van deze bibliotheek kunt u gegevens doorzoeken vanuit uw code. Maak verbinding met een tabel in het Help-cluster dat we hebben ingesteld om u te helpen bij het leren. U kunt een query uitvoeren op een tabel in dat cluster en de resultaten retourneren.
Vereisten
- Python 3.7 of hoger
- Een Microsoft-account of een Microsoft Entra gebruikersidentiteit voor toegang tot het Help-cluster
De gegevensbibliotheek installeren
Installeer azure-kusto-data.
pip install azure-kusto-data
Importinstructies en constanten toevoegen
Importeer klassen uit de bibliotheek, evenals pandas, een bibliotheek voor gegevensanalyse.
from azure.kusto.data import KustoClient, KustoConnectionStringBuilder
from azure.kusto.data.exceptions import KustoServiceError
from azure.kusto.data.helpers import dataframe_from_result_table
import pandas as pd
Azure Data Explorer gebruikt uw Microsoft Entra tenant-id om een toepassing te verifiëren. Om uw tenant-id te vinden, gebruikt u de volgende URL, waarbij u YourDomain vervangt door uw domeinnaam.
https://login.microsoftonline.com/<YourDomain>/.well-known/openid-configuration/
Dus als uw domein contoso.com is, wordt de URL bijvoorbeeld: https://login.microsoftonline.com/contoso.com/.well-known/openid-configuration/. Klik op deze URL om de resultaten weer te geven. De eerste regel is als volgt.
"authorization_endpoint":"https://login.microsoftonline.com/6babcaad-604b-40ac-a9d7-9fd97c0b779f/oauth2/authorize"
De tenant-id is in dit geval 6babcaad-604b-40ac-a9d7-9fd97c0b779f. Stel de waarde voor AAD_TENANT_ID in voordat u deze code uitvoert.
AAD_TENANT_ID = "<TenantId>"
KUSTO_CLUSTER = "https://help.kusto.windows.net/"
KUSTO_DATABASE = "Samples"
Nu maakt u de verbindingsreeks. In dit voorbeeld wordt apparaatverificatie gebruikt voor toegang tot het cluster. U kunt ook Microsoft Entra toepassingscertificaat, Microsoft Entra toepassingssleutel en Microsoft Entra gebruiker en wachtwoord gebruiken.
KCSB = KustoConnectionStringBuilder.with_aad_device_authentication(
KUSTO_CLUSTER)
KCSB.authority_id = AAD_TENANT_ID
Verbinding maken met Azure Data Explorer en een query uitvoeren
Voer een query uit op het cluster en sla de uitvoer op in een gegevensframe. Wanneer deze code wordt uitgevoerd, wordt er een bericht als het volgende geretourneerd: Als u zich wilt aanmelden, opent u de pagina https://microsoft.com/devicelogin met een webbrowser. Voer de code F3W4VWZDM in om te verifiëren. Volg de stappen om u aan te melden en ga vervolgens terug om het volgende codeblok uit te voeren.
KUSTO_CLIENT = KustoClient(KCSB)
KUSTO_QUERY = "StormEvents | sort by StartTime desc | take 10"
RESPONSE = KUSTO_CLIENT.execute(KUSTO_DATABASE, KUSTO_QUERY)
Gegevens verkennen in DataFrame
Nadat u zich hebt aangemeld, retourneert de query resultaten en worden deze opgeslagen in een gegevensframe. U kunt op dezelfde manier met deze resultaten werken als met andere gegevensframes.
df = dataframe_from_result_table(RESPONSE.primary_results[0])
df
Als het goed is, worden de bovenste tien resultaten uit de tabel StormEvents weergegeven.