Partager via

Interroger des données à l’aide de la bibliothèque Python d’Azure Data Explorer

Dans cet article, vous allez interroger des données en utilisant Azure Data Explorer. L’Explorateur de données Azure est un service d’exploration de données rapide et hautement évolutive pour les données des journaux et les données de télémétrie.

L’Explorateur de données Azure fournit une bibliothèque cliente de données pour Python. Cette bibliothèque vous permet d’interroger les données de votre code. Connectez-vous à une table sur le cluster d’aide et interrogez la table, puis retournez les résultats.

Prérequis

Installer la bibliothèque de données

Installez azure-kusto-data.

pip install azure-kusto-data

Ajouter les constantes et les instructions d’importation

Importez des classes à partir de la azure.kusto bibliothèque et pandas, une bibliothèque d’analyse des données.

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

Pour authentifier une application, Azure Data Explorer utilise votre ID de locataire Microsoft Entra. Pour trouver votre ID de locataire, utilisez l’URL suivante en remplaçant YourDomain par votre domaine.

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

Par exemple, si votre domaine est contoso.com, l’URL est : https://login.microsoftonline.com/contoso.com/.well-known/openid-configuration/. Accédez à cette URL et recherchez authentication_endpoint dans les résultats.

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

Ici, l’ID de locataire est aaaabbbb-0000-cccc-1111-dddd2222eeee. Définissez la valeur pour AAD_TENANT_ID avant d’exécuter ce code.

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

Maintenant, créez la chaîne de connexion. Cet exemple utilise l’authentification de l’appareil pour accéder au cluster. Vous pouvez également utiliser le certificat d’application Microsoft Entra, la clé d’application Microsoft Entra et l’utilisateur et le mot de passe Microsoft Entra.

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

Se connecter à l’Explorateur de données Azure et exécuter une requête

Exécutez une requête sur le cluster et stockez le résultat dans un dataframe. Lorsque ce code s’exécute, il retourne un message semblable à celui suivant : Pour vous connecter, utilisez un navigateur web pour ouvrir la page https://microsoft.com/devicelogin et entrez le code F3W4VWZDM pour vous authentifier. Suivez les étapes pour vous connecter, puis revenez pour exécuter le bloc de code suivant.

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

RESPONSE = KUSTO_CLIENT.execute(KUSTO_DATABASE, KUSTO_QUERY)

Explorer les données dans un dataframe

Une fois que vous vous êtes connecté, la requête retourne les résultats, lesquels sont alors stockés dans un cadre de données. Vous pouvez utiliser les résultats comme vous le faites dans n’importe quel autre dataframe.

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

Vous devez voir les 10 premiers résultats du tableau StormEvents.

Étape suivante

Ingérer des données à l’aide de Python

  • Last updated on