KQL データベースからのデータで Fabric ノートブックを使用する

ノートブックは、データ分析の説明と結果を含む読み取り可能なドキュメントであり、データ分析を行うために実行できる実行可能なドキュメントでもあります。 この記事では、Fabric ノートブックを使用して、KQL データベース内のデータに接続し、ネイティブ KQL (Kusto 照会言語) を使用してクエリを実行する方法について説明します。 ノートブックの詳細については、「Microsoft Fabric ノートブックの使用方法」を参照してください。

KQL データベースのデータで Fabric ノートブックを使用するには、次の 2 つの方法があります。

前提条件

ノートブックで Kusto スニペットを使用する

Fabric ノートブックでは、一般的に使用されるコード パターンを簡単に書けるようになるコード スニペットを提供します。 スニペットを使用して、KQL を使用して KQL データベース内でデータを書き込んだり読み取ったりすることができます。

  1. 既存のノートブックに移動するか、新しく作成します。

  2. コード セルで、kusto と入力し始めます。

    Kusto スニペットを使用して Fabric ノートブックで KQL を使用する画面キャプチャ。

  3. 実行する操作 (KQL データベースへのデータの書き込みまたは KQL データベースからのデータの読み取り) に対応するスニペットを選択します。

    次のコード スニペットは、データ読み取り操作の例を示しています。

    # Example of query for reading data from Kusto. Replace T with your <tablename>.
    kustoQuery = "['T'] | take 10"
    # The query URI for reading the data e.g. https://<>.kusto.data.microsoft.com.
    kustoUri = "https://<yourKQLdatabaseURI>.z0.kusto.data.microsoft.com"
    # The database with data to be read.
    database = "DocsDatabase"
    # The access credentials.
    accessToken = mssparkutils.credentials.getToken(kustoUri)
    kustoDf  = spark.read\
        .format("com.microsoft.kusto.spark.synapse.datasource")\
        .option("accessToken", accessToken)\
        .option("kustoCluster", kustoUri)\
        .option("kustoDatabase", database)\
        .option("kustoQuery", kustoQuery).load()
    
    # Example that uses the result data frame.
    kustoDf.show()
    

    次のコード スニペットは、データ書き込み操作の例を示しています。

    # The Kusto cluster uri to write the data. The query Uri is of the form https://<>.kusto.data.microsoft.com 
    kustoUri = ""
    # The database to write the data
    database = ""
    # The table to write the data 
    table    = ""
    # The access credentials for the write
    accessToken = mssparkutils.credentials.getToken(kustoUri)
    
    # Generate a range of 5 rows with Id's 5 to 9
    data = spark.range(5,10) 
    
    # Write data to a Kusto table
    data.write.\
    format("com.microsoft.kusto.spark.synapse.datasource").\
    option("kustoCluster",kustoUri).\
    option("kustoDatabase",database).\
    option("kustoTable", table).\
    option("accessToken", accessToken ).\
    option("tableCreateOptions", "CreateIfNotExist").mode("Append").save()
    
  4. データ セルの各フィールドの引用符内に必要な情報を入力します。

    フィールド 説明 関連リンク
    kustoQuery 評価する KQL クエリ。 KQL の概要
    KustoUri KQL データベースのクエリ URI。 KQL データベース URI をコピーする
    database KQL データベースの名前。 既存の KQL データベースにアクセスする
    data テーブルに書き込むデータ。
  5. コード セルを実行します。

KQL データベースからノートブックを作成する

KQL データベースに関連項目としてノートブックを作成すると、ノートブックには KQL データベースと同じ名前が付けられます。また、接続情報が事前に設定されます。

  1. KQL データベースを参照します。

  2. [新しい関連項目]>[ノートブック] の順に選択します。

    KQL データベースで関連項目としてノートブックを作成するスクリーンショット。

    KustoUri とデータベースの詳細が事前に設定されたノートブックが作成されます。

  3. kustoQuery フィールドに評価する KQL クエリを入力します。

    KQL データベースから作成されたノートブックのスクリーンショット。

  4. コード セルを実行します。