Megosztás:

Adatok lekérdezése az Azure Data Explorer Python-kódtárával

Ebben a cikkben adatokat kérdez le az Azure Data Explorer használatával. Az Azure Data Explorer egy gyors és nagy mértékben méretezhető adatfeltárási szolgáltatás a napló- és telemetriaadatokhoz.

Az Azure Data Explorer egy adatügyfél-kódtárat biztosít a Pythonhoz. Ez a kódtár lehetővé teszi az adatok lekérését a kódból. Csatlakozzon a súgófürt egyik táblához, és kérdezze le a táblát, és adja vissza az eredményeket.

Előfeltételek

Az adattár telepítése

Telepítse az azure-kusto-data-t.

pip install azure-kusto-data

Importálási utasítások és állandók hozzáadása

Importálja az osztályokat a azure.kusto tárból, és pandasegy adatelemzési tárat.

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

Egy alkalmazás hitelesítéséhez az Azure Data Explorer a Microsoft Entra-bérlő azonosítóját használja. A bérlőazonosító megkereséséhez használja a következő URL-címet, és a „YourDomain” helyett adja meg az Ön domain nevét.

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

Ha például a domainje contoso.com, az URL-cím a következő: https://login.microsoftonline.com/contoso.com/.well-known/openid-configuration/. Keresse meg ezt az URL-címet, és keresse meg a authentication_endpoint az eredmények között.

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

Ebben az esetben a bérlőazonosító a következő aaaabbbb-0000-cccc-1111-dddd2222eeee: . A kód futtatása előtt állítsa be a AAD_TENANT_ID értékét.

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

Most már hozza létre a kapcsolati karakterláncot. Ez a példa eszközhitelesítést használ a klaszter eléréséhez. Használhatja a Microsoft Entra alkalmazástanúsítványt, a Microsoft Entra alkalmazáskulcsot és a Microsoft Entra felhasználót és jelszót is.

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

Csatlakozás az Azure Data Explorerhez és lekérdezés végrehajtása

Lekérdezést hajt végre a fürtön, és tárolja a kimenetet egy adatkeretben. A kód futtatásakor a következőhöz hasonló üzenetet ad vissza: A bejelentkezéshez használjon webböngészőt a lap https://microsoft.com/devicelogin megnyitásához, és adja meg a hitelesítéshez F3W4VWZDM kódot. A bejelentkezéshez kövesse a lépéseket, majd térjen vissza a következő kódblokk futtatásához.

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

RESPONSE = KUSTO_CLIENT.execute(KUSTO_DATABASE, KUSTO_QUERY)

Adatok felfedezése a DataFrame-ben

A bejelentkezés után a lekérdezés visszaadja az eredményeket, és egy adatkeretben tárolja őket. Az eredményeket úgy használhatja, mint bármely más adatkeretet.

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

A StormEvents tábla 10 legjobb eredményét kell látnia.

Következő lépés

Adatok betöltése a Python használatával

  • Last updated on