基本的なクエリを実行するアプリを作成する

[アーティクル]
12/08/2023

この記事では、次の方法について説明します。

基本的なクエリを実行し、結果を処理する
序数位置を使用して列の値にアクセスする
クライアント要求プロパティを使用してクエリの動作をカスタマイズする
クエリパラメーターを使用してユーザー入力を保護する

前提条件

Kusto クライアントライブラリを使用するように開発環境を設定します。

基本的なクエリを実行し、結果を処理する

任意の IDE またはテキストエディターで、目的の言語に適した規則を使用して 、基本クエリ という名前のプロジェクトまたはファイルを作成します。次のコードを追加します。

ヘルプクラスターに接続するクライアントアプリを作成します。

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

namespace BasicQuery {
  class BasicQuery {
    static void Main(string[] args) {
      var clusterUri = "https://help.kusto.windows.net/";
      var kcsb = new KustoConnectionStringBuilder(clusterUri)
          .WithAadUserPromptAuthentication();

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

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:

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: "5e39af3b-ba50-4255-b547-81abfb507c58",
    redirectUri: "http://localhost:5173",
  } as InteractiveBrowserCredentialInBrowserOptions;
  const kcsb = KustoConnectionStringBuilder.withUserPrompt(clusterUri, authOptions);
  const kustoClient = new KustoClient(kcsb);
}

main();

Note

Node.js アプリの場合は、ではなく InteractiveBrowserCredentialInBrowserOptionsを使用InteractiveBrowserCredentialNodeOptionsします。

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 BasicQuery {
  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)) {
      }
    }
  }
}

実行するデータベースとクエリを定義します。このクエリは、被害総額が 1 億ドルを超えた日付、状態、および竜巻関連の損害の合計を返します。

var database = "Samples";
var query = @"StormEvents
              | where EventType == 'Tornado'
              | extend TotalDamage = DamageProperty + DamageCrops
              | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
              | where DailyDamage > 100000000
              | order by DailyDamage desc";

database = "Samples"
query = "StormEvents" \
        "| where EventType == 'Tornado'" \
        "| extend TotalDamage = DamageProperty + DamageCrops" \
        "| summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)" \
        "| where DailyDamage > 100000000" \
        "| order by DailyDamage desc"

const database = "Samples";
const query = `StormEvents
               | where EventType == 'Tornado'
               | extend TotalDamage = DamageProperty + DamageCrops
               | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
               | where DailyDamage > 100000000
               | order by DailyDamage desc`;

String database = "Samples";
String query = "StormEvents\n" +
               "| where EventType == 'Tornado'\n" +
               "| extend TotalDamage = DamageProperty + DamageCrops\n" +
               "| summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)\n" +
               "| where DailyDamage > 100000000\n" +
               "| order by DailyDamage desc";

クエリを実行し、結果を出力します。

using (var response = kustoClient.ExecuteQuery(database, query, null)) {
  int columnNoStartTime = response.GetOrdinal("StartTime");
  int columnNoState = response.GetOrdinal("State");
  int columnNoDailyDamage = response.GetOrdinal("DailyDamage");
  Console.WriteLine("Daily tornado damages over 100,000,000$:");

  while (response.Read()) {
    Console.WriteLine("{0} - {1}, {2}",
      response.GetDateTime(columnNoStartTime),
      response.GetString(columnNoState),
      response.GetInt64(columnNoDailyDamage));
  }
}

response = kusto_client.execute(database, query)

print("Daily tornado damages over 100,000,000$:")
for row in response.primary_results[0]:
  print(row["StartTime"], "-", row["State"], ",", row["DailyDamage"], "$")

const response = await kustoClient.execute(database, query);

console.log("Daily tornado damages over 100,000,000$:");
for (row of response.primaryResults[0].rows()) {
  console.log(row["StartTime"].toString(), "-", row["State"].toString(), ",", row["DailyDamage"].toString(), "$");
}

KustoOperationResult response = kusto_client.execute(database, query);
KustoResultSetTable primaryResults = response.getPrimaryResults();

System.out.println("Daily tornado damages over 100,000,000$:");
while (primaryResults.next()) {
  System.out.println(primaryResults.getString("StartTime") + " - " + primaryResults.getString("State") + " , " + primaryResults.getString("DailyDamage"));
}

完全なコードは次のようになります。

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

namespace BasicQuery {
  class BasicQuery {
    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 = @"StormEvents
                         | where EventType == 'Tornado'
                         | extend TotalDamage = DamageProperty + DamageCrops
                         | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
                         | where DailyDamage > 100000000
                         | order by DailyDamage desc";

        using (var response = kustoClient.ExecuteQuery(database, query, null)) {
          int columnNoStartTime = response.GetOrdinal("StartTime");
          int columnNoState = response.GetOrdinal("State");
          int columnNoDailyDamage = response.GetOrdinal("DailyDamage");

          Console.WriteLine("Daily tornado damages over 100,000,000$:");

          while (response.Read()) {
            Console.WriteLine("{0} - {1}, {2}",
              response.GetDateTime(columnNoStartTime),
              response.GetString(columnNoState),
              response.GetInt64(columnNoDailyDamage));
          }
        }
      }
    }
  }
}

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 = "StormEvents" \
            "| where EventType == 'Tornado'" \
            "| extend TotalDamage = DamageProperty + DamageCrops" \
            "| summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)" \
            "| where DailyDamage > 100000000" \
            "| order by DailyDamage desc"

    response = kusto_client.execute(database, query)

    print("Daily tornado damages over 100,000,000$:")
    for row in response.primary_results[0]:
      print(row["StartTime"], "-", row["State"], ",", row["DailyDamage"], "$")

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: "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 = `StormEvents
                 | where EventType == 'Tornado'
                 | extend TotalDamage = DamageProperty + DamageCrops
                 | where DailyDamage > 100000000
                 | order by DailyDamage desc`;
  const response = await kustoClient.execute(database, query);

  console.log("Daily tornado damages over 100,000,000$:");
  for (row of response.primaryResults[0].rows()) {
    console.log(row["StartTime"].toString(), "-", row["State"].toString(), ",", row["DailyDamage"].toString(), "$");
  }
}

main();

Note

Node.js アプリの場合は、ではなく InteractiveBrowserCredentialInBrowserOptionsを使用InteractiveBrowserCredentialNodeOptionsします。

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 BasicQuery {
  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 = "StormEvents\n" +
                       "| where EventType == 'Tornado'\n" +
                       "| extend TotalDamage = DamageProperty + DamageCrops\n" +
                       "| summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)\n" +
                       "| where DailyDamage > 100000000\n" +
                       "| order by DailyDamage desc";
        KustoOperationResult response = kustoClient.execute(database, query);
        KustoResultSetTable primaryResults = response.getPrimaryResults();

        System.out.println("Daily tornado damages over 100,000,000$:");
        while (primaryResults.next()) {
          System.out.println(primaryResults.getString("StartTime") + " - " + primaryResults.getString("State") + " , " + primaryResults.getString("DailyDamage"));
        }
      }
    }
  }
}

アプリの実行

コマンドシェルで、次のコマンドを使用してアプリを実行します。

# Change directory to the folder that contains the basic queries project
dotnet run .

python basic_query.py

Node.js 環境では、次の手順を実行します。

node basic-query.js

ブラウザー環境で、適切なコマンドを使用してアプリを実行します。たとえば、Vite-Reactの場合:

npm run dev

注意

ブラウザー環境で、開発者ツールコンソールを開いて出力を表示します。

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

次のような結果が表示されます。

Daily damages tornado with damages over 100,000,000$:
2007-02-02 00:00:00+00:00 - FLORIDA , 270004000 $
2007-03-01 00:00:00+00:00 - ALABAMA , 266853000 $
2007-05-04 00:00:00+00:00 - KANSAS , 251625000 $
2007-03-01 00:00:00+00:00 - GEORGIA , 143688000 $

序数位置を使用して列の値にアクセスする

クエリ結果の列の順序がわかっている場合は、列名よりも結果セット内の序数の位置で列の値にアクセスする方が効率的です。必要に応じて、実行時にライブラリメソッドを使用して、列名から列序数を決定できます。

注意

または project-away 演算子を使用して、クエリ結果の列の存在と順序をproject制御できます。

たとえば、前のコードを変更して、結果セット内の StartTime序数位置によって、 State、および DailyDamage 列の値にアクセスできます。

C# では、結果セット内の順序位置によってのみ、列の値にアクセスできます。列名は使用できません。そのため、コードは変わりません。

int columnNoStartTime = response.GetOrdinal("StartTime");
int columnNoState = response.GetOrdinal("State");
int columnNoDailyDamage = response.GetOrdinal("DailyDamage");
Console.WriteLine("Daily tornado damages over 100,000,000$:");

while (response.Read()) {
  Console.WriteLine("{0} - {1}, {2}",
    response.GetDateTime(columnNoStartTime),
    response.GetString(columnNoState),
    response.GetInt64(columnNoDailyDamage));
}

state_col = 0
start_time_col = next(col.ordinal for col in response.primary_results[0].columns if col.column_name == "StartTime")
damage_col = 2

print("Daily damages over 100,000,000$:")
for row in response.primary_results[0]:
  print(row[start_time_col], "-", row[state_col], ",", row[damage_col], "$")

const columnNoState = 0;
const columnNoStartTime = response.primaryResults[0].columns.find(c => c.name == "StartTime").ordinal;
const columnNoDailyDamage = 2;
console.log("Daily tornado damages over 100,000,000$:");

for (row of response.primaryResults[0].rows()) {
  console.log(row.getValueAt(columnNoStartTime).toString(), "-", row.getValueAt(columnNoState).toString(), ",", row.getValueAt(columnNoDailyDamage).toString(), "$");
}

Integer columnNoState = 0;
Integer columnNoStartTime = primaryResults.findColumn("StartTime");
Integer columnNoDailyDamage = 2;

while (primaryResults.next()) {
  System.out.println(primaryResults.getString(columnNoStartTime) + " - " + primaryResults.getString(columnNoState) + " , " + primaryResults.getString(columnNoDailyDamage));
}

クライアント要求プロパティを使用してクエリの動作をカスタマイズする

クライアント要求プロパティを設定することで、クエリの動作をカスタマイズできます。使用可能なオプションの詳細については、「クライアント要求のプロパティ」を参照してください。

たとえば、前のコードの呼び出しを kusto_client.execute_query 置き換えてカスタム要求 ID を渡し、クエリタイムアウトを 1 分に設定できます。クライアント要求プロパティを使用するには、クラスをインポートする ClientRequestProperties 必要があります。

using Kusto.Data.Common;

var crp = new ClientRequestProperties();
// Set a custom client request identifier
crp.ClientRequestId = "QueryDemo" + Guid.NewGuid().ToString();
// Set the query timeout to 1 minute
crp.SetOption(ClientRequestProperties.OptionServerTimeout, "1m");

using (var response = kustoClient.ExecuteQuery(database, query, crp)) {
}

from azure.kusto.data import ClientRequestProperties
from datetime import datetime
import uuid;

crp = ClientRequestProperties()
# Set a custom client request identifier
crp.client_request_id = "QueryDemo" + str(uuid.uuid4())
# Set the query timeout to 1 minute
crp.set_option(crp.request_timeout_option_name, datetime.timedelta(minutes=1))

response = kusto_client.execute_query(database, query, crp)

import { ClientRequestProperties } from "azure-kusto-data";
import { v4 as uuidv4 } from "uuid";

const crp = new ClientRequestProperties();
// Set a custom client request identifier
crp.clientRequestId = "QueryDemo" + uuidv4();
// Set the query timeout to 1 minute
crp.setServerTimeout(1000 * 60);

const response = await kustoClient.execute(database, query, crp);

import com.microsoft.azure.kusto.data.ClientRequestProperties;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

ClientRequestProperties crp = new ClientRequestProperties();
// Set a custom client request identifier
crp.setClientRequestId("QueryDemo" + UUID.randomUUID());
// Set the query timeout to 1 minute
crp.setTimeoutInMilliSec(TimeUnit.MINUTES.toMillis(60));

KustoOperationResult response = kusto_client.execute(database, query, crp);

クエリパラメーターを使用してユーザー入力を保護する

クエリパラメーターは、データのセキュリティと保護を維持するために重要です。これは、データへの不正アクセスまたは破損を試みる可能性のある潜在的な悪意のあるアクターから保護します。パラメーター化されたクエリの詳細については、「クエリパラメーター宣言ステートメント」を参照してください。

たとえば、前のコードを変更して、 EventType 値と DailyDamage 最小値をパラメーターとしてクエリに渡すことができます。パラメーターを使用するには:

クエリテキストでパラメーターを宣言する
クエリテキストのプロパティ値をパラメーター名に置き換える
execute メソッドに渡されるクライアント要求プロパティのパラメーター値を設定する

string query = @"declare query_parameters(event_type:string, daily_damage:int);
                  StormEvents
                  | where EventType == event_type
                  | extend TotalDamage = DamageProperty + DamageCrops
                  | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
                  | where DailyDamage > daily_damage
                  | order by DailyDamage desc";

var crp = new ClientRequestProperties();
crp.SetParameter("event_type", "Flash Flood");
crp.SetParameter("daily_damage", 200000000.ToString());

using (var response = kustoClient.ExecuteQuery(database, query, crp)) {
  int columnNoStartTime = response.GetOrdinal("StartTime");
  int columnNoState = response.GetOrdinal("State");
  int columnNoDailyDamage = response.GetOrdinal("DailyDamage");
  Console.WriteLine("Daily flash flood damages over 200,000,000$:");

  while (response.Read()) {
    Console.WriteLine("{0} - {1}, {2}",
      response.GetDateTime(columnNoStartTime),
      response.GetString(columnNoState),
      response.GetInt64(columnNoDailyDamage));
  }
}

query = "declare query_parameters(event_type:string, daily_damage:int);"\
        "StormEvents" \
        "| where EventType == event_type" \
        "| extend TotalDamages = DamageProperty + DamageCrops" \
        "| summarize DailyDamage=sum(TotalDamages) by State, bin(StartTime, 1d)" \
        "| where DailyDamage > daily_damage" \
        "| order by DailyDamage desc"

crp = ClientRequestProperties()
crp.set_parameter("event_type", "Flash Flood")
crp.set_parameter("daily_damage", str(200000000))

response = kusto_client.execute_query(=database, query, crp)

print("Daily flash flood damages over 200,000,000$:")
for row in response.primary_results[0]:
  print(row["StartTime"], "-", row["State"], ",", row["DailyDamage"], "$")

const query = `declare query_parameters(event_type:string, daily_damage:int);
               StormEvents
               | where EventType == event_type
               | extend TotalDamage = DamageProperty + DamageCrops
               | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
               | where DailyDamage > daily_damage
               | order by DailyDamage desc`;

const crp = new ClientRequestProperties();
crp.setParameter("event_type", "Flash Flood");
crp.setParameter("daily_damage", 200000000);

const response = await kustoClient.execute(database, query, crp);

console.log("Daily flash flood damages over 200,000,000$:");
for (row of response.primaryResults[0].rows()) {
  console.log(row.getValueAt(columnNoStartTime).toString(), "-", row.getValueAt(columnNoState).toString(), ",", row.getValueAt(columnNoDailyDamage).toString(), "$");
}

String query = "declare query_parameters(event_type:string, daily_damage:int);\n" +
               "StormEvents\n" +
               "| where EventType == event_type\n" +
               "| extend TotalDamage = DamageProperty + DamageCrops\n" +
               "| summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)\n" +
               "| where DailyDamage > daily_damage\n" +
               "| order by DailyDamage desc";

ClientRequestProperties crp = new ClientRequestProperties();
crp.setParameter("event_type", "Flash Flood");
crp.setParameter("daily_damage", 200000000);

KustoOperationResult response = kusto_client.execute(database, query, crp);
KustoResultSetTable primary_results = response.getPrimaryResults();

System.out.println("Daily flash flood damages over 200,000,000$:");
while (primary_results.next()) {
  System.out.println("DEBUG: " + primary_results.getString(columnNoStartTime) + " - " + primary_results.getString(columnNoState) + " , " + primary_results.getString(columnNoDailyDamage));
}

序数位置を使用して列の値とパラメーターにアクセスする完全なコードは、次のようになります。

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

namespace BasicQuery {
  class BasicQuery {
    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 = @"declare query_parameters(event_type:string, daily_damage:int);
                         StormEvents
                         | where EventType == event_type
                         | extend TotalDamage = DamageProperty + DamageCrops
                         | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
                         | where DailyDamage > daily_damage
                         | order by DailyDamage desc";

        var crp = new ClientRequestProperties();
        crp.ClientRequestId = "QueryDemo" + Guid.NewGuid().ToString();
        crp.SetOption(ClientRequestProperties.OptionServerTimeout, "1m");
        crp.SetParameter("event_type", "Flash Flood");
        crp.SetParameter("daily_damage", 200000000.ToString());

        using (var response = kustoClient.ExecuteQuery(database, query, crp)) {
          int columnNoStartTime = response.GetOrdinal("StartTime");
          int columnNoState = response.GetOrdinal("State");
          int columnNoDailyDamage = response.GetOrdinal("DailyDamage");

          Console.WriteLine("Daily flash flood damages over 200,000,000$:");

          while (response.Read()) {
            Console.WriteLine("{0} - {1}, {2}",
              response.GetDateTime(columnNoStartTime),
              response.GetString(columnNoState),
              response.GetInt64(columnNoDailyDamage));
          }
        }
      }
    }
  }
}

from azure.kusto.data import KustoClient, KustoConnectionStringBuilder, ClientRequestProperties
from datetime import timedelta
import uuid;

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

  crp = ClientRequestProperties()

  crp.client_request_id = "QueryDemo" + str(uuid.uuid4())
  crp.set_option(crp.request_timeout_option_name, timedelta(minutes=1))
  crp.set_parameter("event_type", "Flash Flood")
  crp.set_parameter("daily_damage", str(200000000))

  with KustoClient(kcsb) as kusto_client:

    database = "Samples"
    query = "declare query_parameters(event_type:string, daily_damage:int);"\
            "StormEvents" \
            "| where EventType == event_type" \
            "| extend TotalDamages = DamageProperty + DamageCrops" \
            "| summarize DailyDamage=sum(TotalDamages) by State, bin(StartTime, 1d)" \
            "| where DailyDamage > daily_damage" \
            "| order by DailyDamage desc"

    response = kusto_client.execute_query(database, query, crp)

    state_col = 0
    start_time_col = next(col.ordinal for col in response.primary_results[0].columns if col.column_name == "StartTime")
    damage_col = 2


    print("Daily flash flood damages over 200,000,000$:")
    for row in response.primary_results[0]:
      print(row[start_time_col], "-", row[state_col], ",", row[damage_col], "$")

if __name__ == "__main__":
  main()

import {  
    Client as KustoClient,
    KustoConnectionStringBuilder,
    ClientRequestProperties
} from "azure-kusto-data";
import { v4 as uuidv4 } from "uuid";

async function main() {
  const clusterUri = "https://help.kusto.windows.net";
  const kcsb = KustoConnectionStringBuilder.withUserPrompt(clusterUri);
  const kustoClient = new KustoClient(kcsb);

  const database = "Samples";
  const query = `declare query_parameters(event_type:string, daily_damage:int);
                 StormEvents
                 | where EventType == event_type
                 | extend TotalDamage = DamageProperty + DamageCrops
                 | summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)
                 | where DailyDamage > daily_damage
                 | order by DailyDamage desc`;

  const crp = new ClientRequestProperties();
  // Set a custom client request identifier
  crp.clientRequestId = "QueryDemo" + uuidv4();
  // Set the query timeout to 1 minute
  crp.setTimeout(1000 * 60);

  crp.setParameter("event_type", "Flash Flood");
  crp.setParameter("daily_damage", 200000000);

  const response = await kustoClient.execute(database, query, crp);

  const columnNoState = 0;
  const columnNoStartTime = response.primaryResults[0].columns.find(c => c.name == "StartTime").ordinal;
  const columnNoDailyDamage = 2;

  console.log("Daily flash flood damages over 200,000,000$:");
  for (row of response.primaryResults[0].rows()) {
    console.log(row.getValueAt(columnNoStartTime).toString(), "-", row.getValueAt(columnNoState).toString(), ",", row.getValueAt(columnNoDailyDamage).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;
import com.microsoft.azure.kusto.data.ClientRequestProperties;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

public class BasicQuery {
  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 = "declare query_parameters(event_type:string, daily_damage:int);\n" +
                       "StormEvents\n" +
                       "| where EventType == event_type\n" +
                       "| extend TotalDamage = DamageProperty + DamageCrops\n" +
                       "| summarize DailyDamage=sum(TotalDamage) by State, bin(StartTime, 1d)\n" +
                       "| where DailyDamage > daily_damage\n" +
                       "| order by DailyDamage desc";

        ClientRequestProperties crp = new ClientRequestProperties();
        // Set a custom client request identifier
        crp.setClientRequestId("QueryDemo" + UUID.randomUUID());
        // Set the query timeout to 1 minute
        crp.setTimeoutInMilliSec(TimeUnit.MINUTES.toMillis(60));
        crp.setParameter("event_type", "Flash Flood");
        crp.setParameter("daily_damage", 200000000);

        KustoOperationResult response = kustoClient.execute(database, query, crp);
        KustoResultSetTable primaryResults = response.getPrimaryResults();

        Integer columnNoState = 0;
        Integer columnNoStartTime = primaryResults.findColumn("StartTime");
        Integer columnNoDailyDamage = 2;

        System.out.println("Daily flash flood damages over 200,000,000$:");
        while (primaryResults.next()) {
          System.out.println("DEBUG: " + primaryResults.getString(columnNoStartTime) + " - " + primaryResults.getString(columnNoState) + " , " + primaryResults.getString(columnNoDailyDamage));
        }
      }
    }
  }
}

次のような結果が表示されます。

Daily flash flood damages over 200,000,000$:
2007-08-21 00:00:00+00:00 - OHIO , 253320000 $

次のステップ

管理コマンドを実行するアプリを作成する

次の方法で共有

基本的なクエリを実行するアプリを作成する

前提条件

基本的なクエリを実行し、結果を処理する

アプリの実行

序数位置を使用して列の値にアクセスする

クライアント要求プロパティを使用してクエリの動作をカスタマイズする

クエリパラメーターを使用してユーザー入力を保護する

次のステップ

フィードバック

フィードバック

その他のリソース

次の方法で共有

基本的なクエリを実行するアプリを作成する

前提条件

基本的なクエリを実行し、結果を処理する

アプリの実行

序数位置を使用して列の値にアクセスする

クライアント要求プロパティを使用してクエリの動作をカスタマイズする

クエリ パラメーターを使用してユーザー入力を保護する

次のステップ

フィードバック

フィードバック

その他のリソース

クエリパラメーターを使用してユーザー入力を保護する