Hello Kusto: Tworzenie pierwszej aplikacji

Dotyczy: ✅Microsoft Fabric✅Azure Data Explorer

Z tego artykułu dowiesz się, jak wykonywać następujące działania:

Warunki 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 Kusto i StringBuilder.

   • C#
   • Python
   • TypeScript
   • Java

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

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

   • C#
   • Python
   • TypeScript
   • Java

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

3. Utwórz obiekt konstruktora parametrów połączenia, który definiuje identyfikator URI klastra i ustawia tryb uwierzytelniania na interakcyjny. Aby uzyskać więcej informacji na temat identyfikatora URI klastra, zobacz parametry połączenia usługi Kusto.

   • C#
   • Python
   • TypeScript
   • Java

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

   Notatka

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

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

   • Użytkownik jest już uwierzytelniony na urządzeniu
   • Na urządzeniu istnieje uwierzytelnianie w webowym interfejsie użytkownika Kusto.Explorer lub Azure Data Explorer.

4. Utwórz obiekt klienta, który używa obiektu konstruktora parametrów połączenia w celu nawiązania połączenia z klastrem.

   Notatka

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

   • C#
   • Python
   • TypeScript
   • Java

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

5. Zdefiniuj bazę danych i zapytanie do uruchomienia. Zapytanie wyświetla Hello Kusto! w kolumnie o nazwie Welcome.

   • C#
   • Python
   • TypeScript
   • Java

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

6. Uruchom zapytanie i wyświetl wynik.

   • C#
   • Python
   • TypeScript
   • Java

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

   Notatka

   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.

   Kusto zapytanie zwraca tabelę z jednym wierszem i jedną kolumną.

   • C#
   • Python/TypeScript
   • Java

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

   • Użyj metody read() , aby odczytać pierwszy wiersz
   • Użyj metody GetString(), aby uzyskać wartość pierwszej kolumny

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

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));
        }
      }
    }
  }
}

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()

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: "00001111-aaaa-2222-bbbb-3333cccc4444",
    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();

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 konsoli poleceń użyj następującego polecenia, aby uruchomić aplikację:

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

python hello_kusto.py

node hello-kusto.js

npm run dev

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

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

Hello Kusto!

Następny krok