Sdílet prostřednictvím

Dotazování dat s využitím knihovny Python Azure Data Exploreru

V tomto článku se dotazujete na data pomocí Azure Data Exploreru. Azure Data Explorer je rychlá a vysoce škálovatelná služba pro zkoumání dat protokolů a telemetrie.

Azure Data Explorer poskytuje datovou klientskou knihovnu pro Python. Pomocí této knihovny můžete data dotazovat z kódu. Připojte se k tabulce v clusteru nápovědy a zadejte dotaz na tabulku a vraťte výsledky.

Požadavky

Instalace datové knihovny

Nainstalujte azure-kusto-data.

pip install azure-kusto-data

Přidání příkazů pro import a konstant

Naimportujte třídy z azure.kusto knihovny a pandasknihovnu analýzy dat.

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

K ověření aplikace používá Azure Data Explorer VAŠE ID tenanta Microsoft Entra. ID tenanta zjistíte pomocí následující adresy URL, ve které YourDomain nahradíte svou doménou.

https://login.microsoftonline.com/<YourDomain>/.well-known/openid-configuration/

Pokud je vaše doména například contoso.com, je adresa URL https://login.microsoftonline.com/contoso.com/.well-known/openid-configuration/. Přejděte na tuto adresu URL a ve výsledcích vyhledejte authentication_endpoint .

"authorization_endpoint":"https://login.microsoftonline.com/6babcaad-604b-40ac-a9d7-9fd97c0b779f/oauth2/authorize"

V tomto případě je ID tenanta aaaabbbb-0000-cccc-1111-dddd2222eeee. Před spuštěním tohoto kódu nastavte hodnotu AAD_TENANT_ID.

AAD_TENANT_ID = "<TenantId>"
KUSTO_CLUSTER = "https://help.kusto.windows.net/"
KUSTO_DATABASE = "Samples"

Teď sestavte připojovací řetězec. V tomto příkladu se pro přístup ke clusteru používá ověřování pomocí zařízení. Můžete také použít certifikát aplikace Microsoft Entra, klíč aplikace Microsoft Entra a uživatele a heslo Microsoft Entra.

KCSB = KustoConnectionStringBuilder.with_aad_device_authentication(
    KUSTO_CLUSTER)
KCSB.authority_id = AAD_TENANT_ID

Připojení k Azure Data Exploreru a spuštění dotazu

Spusťte dotaz vůči clusteru a uložte výstup do datového rámce. Když se tento kód spustí, vrátí zprávu jako v následujícím příkladu: Pokud se chcete přihlásit, otevřete stránku https://microsoft.com/devicelogin pomocí webového prohlížeče a zadejte kód, který se má ověřit F3W4VWZDM. Podle pokynů se přihlaste a pak se vraťte a spusťte další blok kódu.

KUSTO_CLIENT = KustoClient(KCSB)
KUSTO_QUERY = "StormEvents | sort by StartTime desc | take 10"

RESPONSE = KUSTO_CLIENT.execute(KUSTO_DATABASE, KUSTO_QUERY)

Zkoumání dat v datovém rámci

Po zadání přihlášení dotaz vrátí výsledky a uloží se do datového rámce. S výsledky můžete pracovat stejně jako s jakýmkoli jiným datovým rámcem.

df = dataframe_from_result_table(RESPONSE.primary_results[0])
df

Měli byste vidět prvních 10 výsledků z tabulky StormEvents.

Další krok

Ingestování dat pomocí Pythonu

  • Last updated on