Membuat aplikasi untuk menjalankan perintah manajemen

Dalam artikel ini, Anda akan mempelajari cara:

• Jalankan perintah manajemen dan proses hasilnya
• Mengubah kebijakan batching penyerapan tingkat tabel
• Perlihatkan kebijakan penyimpanan tingkat database

Prasyarat

Siapkan lingkungan pengembangan Anda untuk menggunakan pustaka klien Kusto.

Jalankan perintah manajemen dan proses hasilnya

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

1. Buat aplikasi klien yang menghubungkan kluster Anda. Ganti tempat penampung <your_cluster_uri> dengan nama kluster Anda.

   C#

   Catatan

   Untuk perintah manajemen, Anda akan menggunakan CreateCslAdminProvider metode pabrik klien.

   using Kusto.Data;
   using Kusto.Data.Net.Client;
   
   namespace ManagementCommands {
     class ManagementCommands {
       static void Main(string[] args) {
         var clusterUri = "<your_cluster_uri>";
         var kcsb = new KustoConnectionStringBuilder(clusterUri)
             .WithAadUserPromptAuthentication();
   
         using (var kustoClient = KustoClientFactory.CreateCslAdminProvider(kcsb)) {
         }
       }
     }
   }
   

   Python

   from azure.kusto.data import KustoClient, KustoConnectionStringBuilder
   
   def main():
     cluster_uri = "<your_cluster_uri>"
     kcsb = KustoConnectionStringBuilder.with_interactive_login(cluster_uri)
   
     with KustoClient(kcsb) as kusto_client:
   
   if __name__ == "__main__":
     main()
   

   Typescript

   import { Client as KustoClient, KustoConnectionStringBuilder } from "azure-kusto-data/";
   import { InteractiveBrowserCredentialInBrowserOptions } from "@azure/identity";
   
   async function main() {
     const clusterUri = "<your_cluster_uri>";
     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);
   }
   
   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.KustoResultColumn;
   import com.microsoft.azure.kusto.data.auth.ConnectionStringBuilder;
   
   public class ManagementCommands {
     public static void main(String[] args) throws Exception {
       try {
         String clusterUri = "<your_cluster_uri>";
         ConnectionStringBuilder kcsb = ConnectionStringBuilder.createWithUserPrompt(clusterUri);
   
         try (Client kustoClient = ClientFactory.createClient(kcsb)) {
         }
       }
     }
   }
   

2. Tentukan fungsi yang mencetak perintah yang dijalankan dan tabel yang dihasilkan. Fungsi ini membonggar nama kolom dalam tabel hasil dan mencetak setiap pasangan nama-nilai pada baris baru.

   C#

   static void PrintResultsAsValueList(string command, IDataReader response) {
     while (response.Read()) {
       Console.WriteLine("\n{0}\n", new String('-', 20));
       Console.WriteLine("Command: {0}", command);
       Console.WriteLine("Result:");
       for (int i = 0; i < response.FieldCount; i++) {
         Console.WriteLine("\t{0} - {1}", response.GetName(i), response.IsDBNull(i) ? "None" : response.GetString(i));
       }
     }
   }
   

   Python

   def print_result_as_value_list(command, response):
     # create a list of columns
     cols = (col.column_name for col in response.primary_results[0].columns)
   
     print("\n" + "-" * 20 + "\n")
     print("Command: " + command)
     # print the values for each row
     for row in response.primary_results[0]:
       print("Result:")
       for col in cols:
         print("\t", col, "-", row[col])
   

   Typescript

   function printResultsAsValueList(command: string, response: KustoResponseDataSet) {
     // create a list of columns
     const cols = response.primaryResults[0].columns;
   
     console.log("\n" + "-".repeat(20) + "\n")
     console.log("Command: " + command)
     // print the values for each row
     for (const row of response.primaryResults[0].rows()) {
       console.log("Result:")
       for (col of cols)
       console.log("\t", col.name, "-", row.getValueAt(col.ordinal) ? row.getValueAt(col.ordinal).toString() : "None")
     }
   }
   

   Java

   public static void printResultsAsValueList(String command, KustoResultSetTable results) {
     while (results.next()) {
       System.out.println("\n" + "-".repeat(20) + "\n");
       System.out.println("Command: " + command);
       System.out.println("Result:");
       KustoResultColumn[] columns = results.getColumns();
       for (int i = 0; i < columns.length; i++) {
         System.out.println("\t" + columns[i].getColumnName() + " - " + (results.getObject(i) == null ? "None" : results.getString(i)));
       }
     }
   }
   

3. Tentukan perintah yang akan dijalankan. Perintah membuat tabel yang disebut MyStormEvents dan menentukan skema tabel sebagai daftar nama dan jenis kolom. Ganti tempat penampung <your_database> dengan nama database Anda.

   C#

   string database = "<your_database>";
   string table = "MyStormEvents";
   
   // Create a table named MyStormEvents
   // The brackets contain a list of column Name:Type pairs that defines the table schema
   string command = @$".create table {table}
                     (StartTime:datetime,
                      EndTime:datetime,
                      State:string,
                      DamageProperty:int,
                      DamageCrops:int,
                      Source:string,
                      StormSummary:dynamic)";
   

   Python

   database = "<your_database>"
   table = "MyStormEvents"
   
   # Create a table named MyStormEvents
   # The brackets contain a list of column Name:Type pairs that defines the table schema
   command = ".create table " + table + " " \
             "(StartTime:datetime," \
             " EndTime:datetime," \
             " State:string," \
             " DamageProperty:int," \
             " DamageCrops:int," \
             " Source:string," \
             " StormSummary:dynamic)"
   

   Typescript

   const database = "<your_database>";
   const table = "MyStormEvents";
   
   // Create a table named MyStormEvents
   // The brackets contain a list of column Name:Type pairs that defines the table schema
   const command = `.create table ${table}
                 (StartTime:datetime,
                  EndTime:datetime,
                  State:string,
                  DamageProperty:int,
                  Source:string,
                  StormSummary:dynamic)`;
   

   Java

   String database = "<your_database>";
   String table = "MyStormEvents";
   
   // Create a table named MyStormEvents
   // The brackets contain a list of column Name:Type pairs that defines the table schema
   String command = ".create table " + table + " " +
                    "(StartTime:datetime," +
                    " EndTime:datetime," +
                    " State:string," +
                    " DamageProperty:int," +
                    " DamageCrops:int," +
                    " Source:string," +
                    " StormSummary:dynamic)";
   

4. Jalankan perintah dan cetak hasilnya menggunakan fungsi yang ditentukan sebelumnya.

   C#

   Catatan

   Anda akan menggunakan ExecuteControlCommand metode untuk menjalankan perintah .

   using (var response = kustoClient.ExecuteControlCommand(database, command, null)) {
     PrintResultsAsValueList(command, response);
   }
   

   Python

   Catatan

   Anda akan menggunakan execute_mgmt metode untuk menjalankan perintah .

   response = kusto_client.execute_mgmt(database, command)
   print_result_as_value_list(command, response)
   

   Typescript

   Catatan

   Anda akan menggunakan executeMgmt metode untuk menjalankan perintah .

   const response = await kustoClient.executeMgmt(database, command);
   printResultsAsValueList(command, response)
   

   Java

   KustoOperationResult response = kusto_client.execute(database, command);
   printResultsAsValueList(command, response.getPrimaryResults());
   

Kode lengkap akan terlihat seperti ini:

C#

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

namespace ManagementCommands {
  class ManagementCommands {
    static void Main(string[] args) {
      string clusterUri = "https://<your_cluster_uri>";
      var kcsb = new KustoConnectionStringBuilder(clusterUri)
          .WithAadUserPromptAuthentication();

      using (var kustoClient = KustoClientFactory.CreateCslAdminProvider(kcsb)) {
        string database = "<your_database>";
        string table = "MyStormEvents";

        // Create a table named MyStormEvents
        // The brackets contain a list of column Name:Type pairs that defines the table schema
        string command = @$".create table {table} 
                          (StartTime:datetime,
                           EndTime:datetime,
                           State:string,
                           DamageProperty:int,
                           DamageCrops:int,
                           Source:string,
                           StormSummary:dynamic)";

        using (var response = kustoClient.ExecuteControlCommand(database, command, null)) {
          PrintResultsAsValueList(command, response);
        }
      }
    }

    static void PrintResultsAsValueList(string command, IDataReader response) {
      while (response.Read()) {
        Console.WriteLine("\n{0}\n", new String('-', 20));
        Console.WriteLine("Command: {0}", command);
        Console.WriteLine("Result:");
        for (int i = 0; i < response.FieldCount; i++) {
          Console.WriteLine("\t{0} - {1}", response.GetName(i), response.IsDBNull(i) ? "None" : response.GetString(i));
        }
      }
    }
  }
}

Python

from azure.kusto.data import KustoClient, KustoConnectionStringBuilder

def main():
  cluster_uri = "https://<your_cluster_uri>"
  kcsb = KustoConnectionStringBuilder.with_interactive_login(cluster_uri)

  with KustoClient(kcsb) as kusto_client:

    database = "<your_database>"
    table = "MyStormEvents"

    # Create a table named MyStormEvents
    # The brackets contain a list of column Name:Type pairs that defines the table schema
    command = ".create table " + table + " " \
              "(StartTime:datetime," \
              " EndTime:datetime," \
              " State:string," \
              " DamageProperty:int," \
              " DamageCrops:int," \
              " Source:string," \
              " StormSummary:dynamic)"

    response = kusto_client.execute_mgmt(database, command)
    print_result_as_value_list(command, response)

def print_result_as_value_list(command, response):
  # create a list of columns
  cols = (col.column_name for col in response.primary_results[0].columns)

  print("\n" + "-" * 20 + "\n")
  print("Command: " + command)
  # print the values for each row
  for row in response.primary_results[0]:
    print("Result:")
    for col in cols:
      print("\t", col, "-", row[col])

if __name__ == "__main__":
  main()

Typescript

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

async function main() {
  const clusterUri = "<your_cluster_uri>";
  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 = "<your_database>";
  const table = "MyStormEvents";

  // Create a table named MyStormEvents
  // The brackets contain a list of column Name:Type pairs that defines the table schema
  const command = `.create table ${table}
                 (StartTime:datetime,
                  EndTime:datetime,
                  State:string,
                  DamageProperty:int,
                  Source:string,
                  StormSummary:dynamic)`;

  const response = await kustoClient.executeMgmt(database, command);
  printResultsAsValueList(command, response)
}

function printResultsAsValueList(command: string, response: KustoResponseDataSet) {
  // create a list of columns
  const cols = response.primaryResults[0].columns;

  console.log("\n" + "-".repeat(20) + "\n")
  console.log("Command: " + command)
  // print the values for each row
  for (const row of response.primaryResults[0].rows()) {
    console.log("Result:")
    for (const col of cols) {
        console.log("\t", col.name, "-", row.getValueAt(col.ordinal) ? row.getValueAt(col.ordinal).toString() : "None")
    }
  }
}

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.KustoResultColumn;
import com.microsoft.azure.kusto.data.auth.ConnectionStringBuilder;

public class ManagementCommands {
  public static void main(String[] args) throws Exception {
    try {
      String clusterUri = "https://<your_cluster_uri>";
      ConnectionStringBuilder kcsb = ConnectionStringBuilder.createWithUserPrompt(clusterUri);
      try (Client kustoClient = ClientFactory.createClient(kcsb)) {
        String database = "<your_database>";
        String table = "MyStormEvents";

        // Create a table named MyStormEvents
        // The brackets contain a list of column Name:Type pairs that defines the table schema
        String command = ".create table " + table + " " +
                         "(StartTime:datetime," +
                         " EndTime:datetime," +
                         " State:string," +
                         " DamageProperty:int," +
                         " DamageCrops:int," +
                         " Source:string," +
                         " StormSummary:dynamic)";

        KustoOperationResult response = kustoClient.execute(database, command);
        printResultsAsValueList(command, response.getPrimaryResults());
      }
    }
  }
  public static void printResultsAsValueList(String command, KustoResultSetTable results) {
    while (results.next()) {
      System.out.println("\n" + "-".repeat(20) + "\n");
      System.out.println("Command: " + command);
      System.out.println("Result:");
      KustoResultColumn[] columns = results.getColumns();
      for (int i = 0; i < columns.length; i++) {
        System.out.println("\t" + columns[i].getColumnName() + " - " + (results.getObject(i) == null ? "None" : results.getString(i)));
      }
    }
  }
}

Jalankan aplikasi Anda

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

C#

# Change directory to the folder that contains the management commands project
dotnet run .

Python

python management_commands.py

Typescript

Di lingkungan Node.js:

node management-commands.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 outputnya.

Java

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

Anda akan melihat hasil yang mirip dengan yang berikut ini:

--------------------

Command: .create table MyStormEvents 
                 (StartTime:datetime,
                  EndTime:datetime,
                  State:string,
                  DamageProperty:int,
                  Source:string,
                  StormSummary:dynamic)
Result:
   TableName - MyStormEvents
   Schema - {"Name":"MyStormEvents","OrderedColumns":[{"Name":"StartTime","Type":"System.DateTime","CslType":"datetime"},{"Name":"EndTime","Type":"System.DateTime","CslType":"datetime"},{"Name":"State","Type":"System.String","CslType":"string"},{"Name":"DamageProperty","Type":"System.Int32","CslType":"int"},{"Name":"Source","Type":"System.String","CslType":"string"},{"Name":"StormSummary","Type":"System.Object","CslType":"dynamic"}]}
   DatabaseName - MyDatabaseName
   Folder - None
   DocString - None

Mengubah kebijakan batching penyerapan tingkat tabel

Anda dapat menyesuaikan perilaku batching penyerapan untuk tabel dengan mengubah kebijakan tabel terkait. Untuk informasi selengkapnya, lihat Kebijakan IngestionBatching.

Catatan

Jika Anda tidak menentukan semua parameter PolicyObject, parameter yang tidak ditentukan akan diatur ke nilai default. Misalnya, menentukan hanya "MaximumBatchingTimeSpan" yang akan menghasilkan "MaximumNumberOfItems" dan "MaximumRawDataSizeMB" yang diatur ke default.

Misalnya, Anda dapat memodifikasi aplikasi untuk mengubah nilai batas waktu kebijakan batching penyerapan menjadi 30 detik dengan mengubah ingestionBatching kebijakan untuk MyStormEvents tabel menggunakan perintah berikut:

C#

// Reduce the default batching timeout to 30 seconds
command = @$".alter-merge table {table} policy ingestionbatching '{{ ""MaximumBatchingTimeSpan"":""00:00:30"" }}'";

using (var response = kustoClient.ExecuteControlCommand(database, command, null))
{
  PrintResultsAsValueList(command, response);
}

Python

# Reduce the default batching timeout to 30 seconds
command = ".alter-merge table " + table + " policy ingestionbatching '{ \"MaximumBatchingTimeSpan\":\"00:00:30\" }'"

response = kusto_client.execute_mgmt(database, command)
print_result_as_value_list(command, response)

Typescript

// Reduce the default batching timeout to 30 seconds
command = ".alter-merge table " + table + " policy ingestionbatching '{ \"MaximumBatchingTimeSpan\":\"00:00:30\" }'"

response = await kustoClient.executeMgmt(database, command)
printResultsAsValueList(command, response)

Java

// Reduce the default batching timeout to 30 seconds
command = ".alter-merge table " + table + " policy ingestionbatching '{ \"MaximumBatchingTimeSpan\":\"00:00:30\" }'";

response = kusto_client.execute(database, command);
printResultsAsValueList(command, response.getPrimaryResults());

Saat menambahkan kode ke aplikasi dan menjalankannya, Anda akan melihat hasil yang mirip dengan yang berikut ini:

--------------------

Command: .alter-merge table MyStormEvents policy ingestionbatching '{ "MaximumBatchingTimeSpan":"00:00:30" }'
Result:
   PolicyName - IngestionBatchingPolicy
   EntityName - [YourDatabase].[MyStormEvents]
   Policy - {
  "MaximumBatchingTimeSpan": "00:00:30",
  "MaximumNumberOfItems": 500,
  "MaximumRawDataSizeMB": 1024
}
   ChildEntities - None
   EntityType - Table

Perlihatkan kebijakan penyimpanan tingkat database

Anda bisa menggunakan perintah manajemen untuk menampilkan kebijakan penyimpanan database.

Misalnya, Anda dapat memodifikasi aplikasi untuk menampilkan kebijakan retensi database Anda menggunakan kode berikut. Hasilnya dikumpulkan untuk memproyeksikan dua kolom dari hasil:

C#

// Show the database retention policy (drop some columns from the result)
command = @$".show database {database} policy retention | project-away ChildEntities, EntityType";

using (var response = kustoClient.ExecuteControlCommand(database, command, null)) {
  PrintResultsAsValueList(command, response);
}

Python

# Show the database retention policy (drop some columns from the result)
command = ".show database " + database + " policy retention | project-away ChildEntities, EntityType"

response = kusto_client.execute_mgmt(database, command)
print_result_as_value_list(command, response)

Typescript

// Show the database retention policy (drop some columns from the result)
command = ".show database " + database + " policy retention | project-away ChildEntities, EntityType"

response = await kustoClient.executeMgmt(database, command)
printResultsAsValueList(command, response)

Java

// Show the database retention policy (drop some columns from the result)
command = ".show database " + database + " policy retention | project-away ChildEntities, EntityType";

response = kusto_client.execute(database, command);
printResultsAsValueList(command, response.getPrimaryResults());

Saat menambahkan kode ke aplikasi dan menjalankannya, Anda akan melihat hasil yang mirip dengan yang berikut ini:

--------------------

Command: .show database YourDatabase policy retention | project-away ChildEntities, EntityType
Result:
   PolicyName - RetentionPolicy
   EntityName - [YourDatabase]
   Policy - {
  "SoftDeletePeriod": "365.00:00:00",
  "Recoverability": "Enabled"
}

Langkah selanjutnya

Membuat aplikasi untuk mendapatkan data menggunakan penyerapan antrean