Yönetim komutlarını çalıştırmak için uygulama oluşturma

Bu makalede şunları öğreneceksiniz:

• Bir yönetim komutu çalıştırma ve sonuçları işleme
• Tablo düzeyi alma toplu işlem ilkesini değiştirme
• Veritabanı düzeyinde bekletme ilkesini gösterme

Önkoşullar

Kusto istemci kitaplığını kullanmak için geliştirme ortamınızı ayarlayın.

Bir yönetim komutu çalıştırma ve sonuçları işleme

Tercih ettiğiniz IDE veya metin düzenleyicisinde, tercih ettiğiniz dile uygun kuralı kullanarak yönetim komutları adlı bir proje veya dosya oluşturun. Ardından aşağıdaki kodu ekleyin:

1. Kümenizi bağlayan bir istemci uygulaması oluşturun. Yer tutucuyu <your_cluster_uri> kümenizin adıyla değiştirin.

   C#

   Not

   Yönetim komutları için istemci fabrikası yöntemini kullanacaksınız CreateCslAdminProvider .

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

   Not

   Node.js uygulamalar için yerine InteractiveBrowserCredentialInBrowserOptionskullanınInteractiveBrowserCredentialNodeOptions.

   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. Çalıştırılmakta olan komutu ve sonuç tablolarını yazdıran bir işlev tanımlayın. Bu işlev sonuç tablolarındaki sütun adlarını açar ve her ad-değer çiftini yeni bir satıra yazdırır.

   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. Çalıştırılacak komutu tanımlayın. komutu MyStormEvents adlı bir tablo oluşturur ve tablo şemasını sütun adları ve türleri listesi olarak tanımlar. Yer tutucuyu <your_database> veritabanınızın adıyla değiştirin.

   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. komutunu çalıştırın ve daha önce tanımlanmış işlevi kullanarak sonucu yazdırın.

   C#

   Not

   komutunu çalıştırmak için yöntemini kullanacaksınız ExecuteControlCommand .

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

   Python

   Not

   komutunu çalıştırmak için yöntemini kullanacaksınız execute_mgmt .

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

   Typescript

   Not

   komutunu çalıştırmak için yöntemini kullanacaksınız executeMgmt .

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

   Java

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

Kodun tamamı şöyle görünmelidir:

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

Not

Node.js uygulamalar için yerine InteractiveBrowserCredentialInBrowserOptionskullanınInteractiveBrowserCredentialNodeOptions.

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

Uygulamanızı çalıştırma

Komut kabuğunda aşağıdaki komutu kullanarak uygulamanızı çalıştırın:

C#

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

Python

python management_commands.py

Typescript

Node.js bir ortamda:

node management-commands.js

Bir tarayıcı ortamında uygulamanızı çalıştırmak için uygun komutu kullanın. Örneğin, Vite-React için:

npm run dev

Not

Çıkışı görmek için tarayıcı ortamında geliştirici araçları konsolunu açın.

Java

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

Aşağıdakine benzer bir sonuç görmeniz gerekir:

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

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

Tablo düzeyi alma toplu işlem ilkesini değiştirme

İlgili tablo ilkesini değiştirerek tablolar için alım toplu işlem davranışını özelleştirebilirsiniz. Daha fazla bilgi için bkz. IngestionBatching ilkesi.

Not

PolicyObject'in tüm parametrelerini belirtmezseniz, belirtilmemiş parametreler varsayılan değerlere ayarlanır. Örneğin, yalnızca "MaximumBatchingTimeSpan" belirtilmesi "MaximumNumberOfItems" ve "MaximumRawDataSizeMB" değerlerinin varsayılan olarak ayarlanmasına neden olur.

Örneğin, aşağıdaki komutu kullanarak tablonun ilkesini değiştirerekingestionBatching alma toplu ilkesi zaman aşımı değerini 30 saniye olarak değiştirmek için MyStormEvents uygulamayı değiştirebilirsiniz:

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

Kodu uygulamanıza ekleyip çalıştırdığınızda aşağıdakine benzer bir sonuç görmeniz gerekir:

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

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

Veritabanı düzeyinde bekletme ilkesini gösterme

Veritabanının bekletme ilkesini görüntülemek için yönetim komutlarını kullanabilirsiniz.

Örneğin, aşağıdaki kodu kullanarak uygulamayı veritabanınızın bekletme ilkesini görüntüleyecek şekilde değiştirebilirsiniz. Sonuç, sonuçtan iki sütunu yansıtmak için seçilmiştir:

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

Kodu uygulamanıza ekleyip çalıştırdığınızda aşağıdakine benzer bir sonuç görmeniz gerekir:

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

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

Sonraki adım

Kuyruğa alınan alımı kullanarak veri almak için uygulama oluşturma