Hello Kusto: Tworzenie pierwszej aplikacji

W tym artykule omówiono sposób wykonywania następujących zadań:

• Tworzenie pierwszej aplikacji klienckiej
• Korzystanie z uwierzytelniania interakcyjnego
• Uruchom podstawowe zapytanie, które wyświetla komunikat Hello Kusto!

Wymagania wstępne

Skonfiguruj środowisko deweloperskie do korzystania z biblioteki klienta Kusto.

Tworzenie aplikacji

W preferowanym środowisku IDE lub edytorze tekstów utwórz projekt lub plik o nazwie hello kusto przy użyciu konwencji odpowiedniej dla preferowanego języka. Następnie dodaj następujący kod:

1. Dodaj klasy klienta i konstruktora ciągów Kusto.

   C#

   using Kusto.Data;
   using Kusto.Data.Net.Client;
   

   Python

   from azure.kusto.data import KustoClient, KustoConnectionStringBuilder
   

   Typescript

   import { Client as KustoClient, KustoConnectionStringBuilder } from "azure-kusto-data";
   import { InteractiveBrowserCredentialInBrowserOptions } from "@azure/identity";
   

   Uwaga

   W przypadku aplikacji Node.js użyj polecenia InteractiveBrowserCredentialNodeOptions zamiast InteractiveBrowserCredentialInBrowserOptions.

   Java

   import com.microsoft.azure.kusto.data.Client;
   import com.microsoft.azure.kusto.data.ClientFactory;
   import com.microsoft.azure.kusto.data.KustoOperationResult;
   import com.microsoft.azure.kusto.data.KustoResultSetTable;
   import com.microsoft.azure.kusto.data.auth.ConnectionStringBuilder;
   

2. Zdefiniuj pustą funkcję o nazwie main i wywołaj ją.

   C#

   namespace HelloKusto {
     class HelloKusto {
       static void Main(string[] args) {
       }
     }
   }
   

   Python

   def main():
   
   if __name__ == "__main__":
     main()
   

   Typescript

   async function main()
   {
   }
   
   main();
   

   Java

   public class HelloKusto 
   {
     public static void main(String[] args) throws Exception {
       try {
       }
     }
   }
   

3. Utwórz obiekt konstruktora parametry połączenia definiujący identyfikator URI klastra i ustawiający tryb uwierzytelniania na interaktywny. Aby uzyskać więcej informacji na temat identyfikatora URI klastra, zobacz Parametry połączenia usługi Kusto.

   C#

   var clusterUri = "https://help.kusto.windows.net/";
   var kcsb = new KustoConnectionStringBuilder(clusterUri).WithAadUserPromptAuthentication();
   

   Python

   cluster_uri = "https://help.kusto.windows.net"
   kcsb = KustoConnectionStringBuilder.with_interactive_login(cluster_uri)
   

   Typescript

   Wartości clientId i redirectUri pochodzą z Microsoft Entra rejestracji aplikacji utworzonej w sekcji Wymagania wstępne w temacie Konfigurowanie środowiska projektowego.

   const clusterUri = "https://help.kusto.windows.net";
   const authOptions = {
     clientId: "5e39af3b-ba50-4255-b547-81abfb507c58",
     redirectUri: "http://localhost:5173",
   } as InteractiveBrowserCredentialInBrowserOptions;
   const kcsb = KustoConnectionStringBuilder.withUserPrompt(clusterUri, authOptions);
   

   Uwaga

   W przypadku aplikacji Node.js użyj polecenia InteractiveBrowserCredentialNodeOptions zamiast InteractiveBrowserCredentialInBrowserOptions.

   Java

   String clusterUri = "https://help.kusto.windows.net/";
   ConnectionStringBuilder kcsb = ConnectionStringBuilder.createWithUserPrompt(clusterUri);
   

   Uwaga

   Do uwierzytelniania interakcyjnego potrzebne jest konto Microsoft lub Microsoft Entra tożsamość użytkownika. Subskrypcja platformy Azure nie jest wymagana.

   W języku C# proces uwierzytelniania interakcyjnego może nie wyświetlać monitu użytkownika, jeśli:

   • Użytkownik jest już uwierzytelniony na urządzeniu
   • Na urządzeniu istnieje uwierzytelnianie internetowego interfejsu użytkownika usługi Kusto.Explorer lub Usługi Azure Date Explorer

4. Utwórz obiekt klienta używający obiektu konstruktora parametry połączenia do nawiązania połączenia z klastrem.

   Uwaga

   Zdecydowanie zalecamy buforowanie i ponowne używanie wystąpienia klienta Kusto. Częste ponowne tworzenie klientów usługi Kusto może prowadzić do obniżenia wydajności aplikacji i zwiększonego obciążenia klastra.

   C#

   using (var kustoClient = KustoClientFactory.CreateCslQueryProvider(kcsb)) {
   }
   

   Python

   with KustoClient(kcsb) as kusto_client:
   

   Typescript

   const kustoClient = new KustoClient(kcsb);
   

   Java

   try (Client kustoClient = ClientFactory.createClient(kcsb)) {
   }
   

5. Zdefiniuj bazę danych i zapytanie do uruchomienia. Zapytanie wyświetla ciąg Hello Kusto! w kolumnie o nazwie Welcome (Witaj).

   C#

   var database = "Samples";
   var query = "print Welcome='Hello Kusto!'";
   

   Python

   database = "Samples"
   query = "print Welcome='Hello Kusto!'"
   

   Typescript

   const database = "Samples";
   const query = "print Welcome='Hello Kusto!'";
   

   Java

   String database = "Samples";
   String query = "print Welcome='Hello Kusto!'";
   

6. Uruchom zapytanie i wyświetl wynik.

   C#

   using (var response = kustoClient.ExecuteQuery(database, query, null)) {
     response.Read();
     int columnNo = response.GetOrdinal("Welcome");
     Console.WriteLine(response.GetString(columnNo));
   }
   

   Python

   response = kusto_client.execute(database, query)
   
   print(response.primary_results[0][0]["Welcome"])
   

   Typescript

   const response = await kustoClient.execute(database, query);
   
   console.log(response.primaryResults[0][0]["Welcome"].toString());
   

   Java

   KustoOperationResult response = kustoClient.execute(database, query);
   
   KustoResultSetTable primary_results = response.getPrimaryResults();
   primary_results.next();
   System.out.println(primary_results.getString("Welcome"));
   

   Uwaga

   Dane wyjściowe zapytania są zwracane w odpowiedzi jako obiekt zawierający co najmniej jedną tabelę składającą się z co najmniej jednego wiersza i kolumn. Format obiektu zależy od języka biblioteki klienta.

   Zapytanie print kusto zwraca pojedynczą tabelę z jednym wierszem i kolumną.

   C#

   Odpowiedź jest obiektem DataReader . Możesz odwołać się do wyniku w następujący sposób:

   • Odczytywanie pierwszego wiersza przy użyciu metody Read()
   • Użyj metody GetString(), aby uzyskać wartość pierwszej kolumny

   Python /TypeScript

   Odpowiedź w podstawowym obiekcie JSON wyników. Obiekt zawiera tablicę tabel, która z kolei zawiera tablicę wierszy. Każdy wiersz zawiera dane uporządkowane w słowniku kolumn. Możesz odwołać się do wyniku w następujący sposób:

   • Pierwszy indeks [0] tablicy odwołuje się do pierwszej tabeli
   • Drugi indeks [0] tablicy odwołuje się do pierwszego wiersza
   • Klucz ["Welcome"] słownika odwołuje się do kolumny Powitanie

   Java

   Odpowiedź jest obiektem KustoOperationResult. Możesz odwołać się do wyniku w następujący sposób:

   • Użyj metody getPrimaryResults(), aby uzyskać podstawową tabelę wyników
   • metoda next() odczytu pierwszego wiersza
   • metoda getString(), aby uzyskać wartość pierwszej kolumny

Pełny kod powinien wyglądać następująco:

C#

using Kusto.Data;
using Kusto.Data.Net.Client;

namespace HelloKusto {
  class HelloKusto {
    static void Main(string[] args) {
      string clusterUri = "https://help.kusto.windows.net/";
      var kcsb = new KustoConnectionStringBuilder(clusterUri).WithAadUserPromptAuthentication();
    
      using (var kustoClient = KustoClientFactory.CreateCslQueryProvider(kcsb)) {
        string database = "Samples";
        string query = "print Welcome='Hello Kusto!'";

        using (var response = kustoClient.ExecuteQuery(database, query, null)) {
          response.Read();
          int columnNo = response.GetOrdinal("Welcome");
          Console.WriteLine(response.GetString(columnNo));
        }
      }
    }
  }
}

Python

from azure.kusto.data import KustoClient, KustoConnectionStringBuilder

def main():
  cluster_uri = "https://help.kusto.windows.net"
  kcsb = KustoConnectionStringBuilder.with_interactive_login(cluster_uri)

  with KustoClient(kcsb) as kusto_client:

    database = "Samples"
    query = "print Welcome='Hello Kusto!'"
    response = kusto_client.execute(database, query)

    print(response.primary_results[0][0]["Welcome"])

if __name__ == "__main__":
  main()

Typescript

import { Client as KustoClient, KustoConnectionStringBuilder } from "azure-kusto-data/";
import { InteractiveBrowserCredentialInBrowserOptions } from "@azure/identity";

async function main()
{
  const clusterUri = "https://help.kusto.windows.net";
  const authOptions = {
    clientId: "5e39af3b-ba50-4255-b547-81abfb507c58",
    redirectUri: "http://localhost:5173",
  } as InteractiveBrowserCredentialInBrowserOptions;
  const kcsb = KustoConnectionStringBuilder.withUserPrompt(clusterUri, authOptions);
  const kustoClient = new KustoClient(kcsb);

  const database = "Samples";
  const query = "print Welcome='Hello Kusto!'";
  const response = await kustoClient.execute(database, query);

  console.log(response.primaryResults[0][0]["Welcome"].toString());
}

main();

Uwaga

W przypadku aplikacji Node.js użyj polecenia InteractiveBrowserCredentialNodeOptions zamiast InteractiveBrowserCredentialInBrowserOptions.

Java

import com.microsoft.azure.kusto.data.Client;
import com.microsoft.azure.kusto.data.ClientFactory;
import com.microsoft.azure.kusto.data.KustoOperationResult;
import com.microsoft.azure.kusto.data.KustoResultSetTable;
import com.microsoft.azure.kusto.data.auth.ConnectionStringBuilder;

public class HelloKusto {
  public static void main(String[] args) throws Exception {
    try {
      String clusterUri = "https://help.kusto.windows.net/";
      ConnectionStringBuilder kcsb = ConnectionStringBuilder.createWithUserPrompt(clusterUri);

      try (Client kustoClient = ClientFactory.createClient(kcsb)) {
        String database = "Samples";
        String query = "print Welcome='Hello Kusto!'";
        KustoOperationResult response = kustoClient.execute(database, query);

        KustoResultSetTable primaryResults = response.getPrimaryResults();
        primaryResults.next();
        System.out.println(primaryResults.getString("Welcome"));
      }
    }
  }
}

Uruchamianie aplikacji

W powłoce poleceń użyj następującego polecenia, aby uruchomić aplikację:

C#

# Change directory to the folder that contains the hello world project
dotnet run .

Python

python hello_kusto.py

Typescript

W środowisku Node.js:

node hello-kusto.js

W środowisku przeglądarki użyj odpowiedniego polecenia, aby uruchomić aplikację. Na przykład dla vite-React:

npm run dev

Uwaga

W środowisku przeglądarki otwórz konsolę narzędzi deweloperskich , aby wyświetlić dane wyjściowe.

Java

mvn install exec:java -Dexec.mainClass="<groupId>.HelloKusto"

Powinien zostać wyświetlony wynik podobny do następującego:

Hello Kusto!

Następny krok

Tworzenie aplikacji do uruchamiania podstawowych zapytań