Halo Kusto: Buat aplikasi pertama Anda

Dalam artikel ini, Anda akan mempelajari cara:

• Membuat aplikasi klien pertama Anda
• Menggunakan autentikasi interaktif
• Jalankan kueri dasar yang mencetak Halo Kusto!

Prasyarat

Siapkan lingkungan pengembangan Anda untuk menggunakan pustaka klien Kusto.

Membuat aplikasi Anda

Di IDE atau editor teks pilihan Anda, buat proyek atau file bernama hello kusto menggunakan konvensi yang sesuai untuk bahasa pilihan Anda. Tambahkan kode berikut:

1. Tambahkan klien Kusto dan kelas penyusun string.

   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";
   

   Catatan

   Untuk aplikasi Node.js, gunakan InteractiveBrowserCredentialNodeOptions alih-alih 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. Tentukan fungsi kosong bernama main dan panggil.

   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. Buat objek penyusun string koneksi yang menentukan URI kluster dan mengatur mode autentikasi ke interaktif. Untuk informasi selengkapnya tentang URI kluster, lihat String koneksi 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

   dan berasal dari pendaftaran aplikasi Microsoft Entra yang Anda buat di bagian Prasyarat di Menyiapkan lingkungan pengembangan Anda.redirectUriclientId

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

   Catatan

   Untuk aplikasi Node.js, gunakan InteractiveBrowserCredentialNodeOptions alih-alih InteractiveBrowserCredentialInBrowserOptions.

   Java

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

   Catatan

   Untuk autentikasi interaktif, Anda memerlukan akun Microsoft atau identitas pengguna Microsoft Entra. Langganan Azure tidak diperlukan.

   Di C#, proses autentikasi interaktif mungkin tidak meminta pengguna jika:

   • Pengguna sudah diautentikasi pada perangkat
   • Ada autentikasi UI web Kusto.Explorer atau Azure Date Explorer yang ada di perangkat

4. Buat objek klien yang menggunakan objek penyusun string koneksi untuk menyambungkan ke kluster.

   Catatan

   Kami sangat menyarankan Agar Anda melakukan cache dan menggunakan kembali instans klien Kusto. Klien Kusto yang sering dibuat ulang dapat menyebabkan penurunan performa dalam aplikasi Anda dan peningkatan beban pada kluster Anda.

   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. Tentukan database dan kueri yang akan dijalankan. Kueri mencetak Hello Kusto! dalam kolom bernama Selamat Datang.

   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. Jalankan kueri dan cetak hasilnya.

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

   Catatan

   Output kueri dikembalikan dalam respons sebagai objek yang berisi satu atau beberapa tabel, terdiri dari satu baris dan kolom lagi. Format objek tergantung pada bahasa pustaka klien.

   Kueri cetak kusto mengembalikan satu tabel dengan satu baris dan kolom.

   C#

   Responsnya adalah objek DataReader . Anda dapat mereferensikan hasilnya, sebagai berikut:

   • Gunakan metode Read() untuk membaca baris pertama
   • Gunakan metode GetString() untuk mendapatkan nilai kolom pertama

   Python / TypeScript

   Respons dalam objek JSON hasil utama. Objek berisi array tabel, yang pada gilirannya berisi array baris. Setiap baris berisi data yang diatur ke dalam kamus kolom. Anda dapat mereferensikan hasilnya, sebagai berikut:

   • Indeks [0] array pertama mereferensikan tabel pertama
   • Indeks [0] array kedua mereferensikan baris pertama
   • Kunci kamus ["Welcome"] mereferensikan kolom Selamat Datang

   Java

   Responsnya adalah objek KustoOperationResult. Anda dapat mereferensikan hasilnya, sebagai berikut:

   • Gunakan metode getPrimaryResults() untuk mendapatkan tabel hasil utama
   • metode next() untuk membaca baris pertama
   • metode getString() untuk mendapatkan nilai kolom pertama

Kode lengkap akan terlihat seperti ini:

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

Catatan

Untuk aplikasi Node.js, gunakan InteractiveBrowserCredentialNodeOptions alih-alih 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"));
      }
    }
  }
}

Jalankan aplikasi Anda

Di shell perintah, gunakan perintah berikut untuk menjalankan aplikasi Anda:

C#

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

Python

python hello_kusto.py

Typescript

Di lingkungan Node.js:

node hello-kusto.js

Di lingkungan browser, gunakan perintah yang sesuai untuk menjalankan aplikasi Anda. Misalnya, untuk Vite-React:

npm run dev

Catatan

Di lingkungan browser, buka konsol alat pengembang untuk melihat output.

Java

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

Anda akan melihat hasil yang mirip dengan yang berikut ini:

Hello Kusto!

Langkah selanjutnya

Membuat aplikasi untuk menjalankan kueri dasar