Azure Functions 用の Azure Data Explorer 出力バインド (プレビュー)

[アーティクル]
07/11/2023

関数が実行されると、Azure Data Explorer 出力バインドによって Azure Data Explorer にデータが取り込まれます。

セットアップと構成の詳細については、概要に関するページをご覧ください。

例

A C# 関数は、次の C# モードのいずれかを使用して作成できます。

分離されたワーカーモデル: ランタイムから分離されたワーカープロセスで実行されるコンパイル済みの C# 関数。分離ワーカープロセスは、LTS および非 LTS バージョンの .NET および .NET Framework で実行されている C# 関数をサポートするために必要です。
インプロセスモデル: Functions ランタイムと同じプロセスで実行されるコンパイル済みの C# 関数。
C# スクリプト: Azure portal で C# 関数を作成するときに主に使用されます。

重要

インプロセスモデルのサポートは 2026 年 11 月 10 日に終了します。完全なサポートのために、アプリを分離ワーカーモデルに移行することを強くお勧めします。

分離ワーカーモデル
インプロセスモデル

Azure Data Explorer 出力バインドのその他のサンプルが、GitHub リポジトリで入手できます。

このセクションには、次の例が含まれています。

HTTP トリガー、1 つのレコードを書き込む
HTTP トリガー、マッピングを使用したレコードの書き込み

この例では Product クラスとそれに対応するデータベーステーブルを参照します。

public class Product
{
    [JsonProperty(nameof(ProductID))]
    public long ProductID { get; set; }

    [JsonProperty(nameof(Name))]
    public string Name { get; set; }

    [JsonProperty(nameof(Cost))]
    public double Cost { get; set; }
}

.create-merge table Products (ProductID:long, Name:string, Cost:double)

HTTP トリガー、1 つのレコードを書き込む

次の例は、データベースにレコードを追加する C# 関数を示しています。関数では、JSON 本文として HTTP POST 要求に含まれるデータを使用しています。

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Extensions.Kusto;
using Microsoft.Azure.Functions.Worker.Http;
using Microsoft.Azure.WebJobs.Extensions.Kusto.SamplesOutOfProc.OutputBindingSamples.Common;

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.SamplesOutOfProc.OutputBindingSamples
{
    public static class AddProduct
    {
        [Function("AddProduct")]
        [KustoOutput(Database: "productsdb", Connection = "KustoConnectionString", TableName = "Products")]
        public static async Task<Product> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "addproductuni")]
            HttpRequestData req)
        {
            Product? prod = await req.ReadFromJsonAsync<Product>();
            return prod ?? new Product { };
        }
    }
}

HTTP トリガー、マッピングを使用したレコードの書き込み

次の例では、一連のレコードをデータベースに追加する C# 関数を示します。関数は、Product を Item に変換するマッピングを使用します。

Product から Item にデータを変換するために、この関数ではマッピング参照を使用しています。

.create-merge table Item (ItemID:long, ItemName:string, ItemCost:float)


-- Create a mapping that transforms an Item to a Product

.create-or-alter table Product ingestion json mapping "item_to_product_json" '[{"column":"ProductID","path":"$.ItemID"},{"column":"Name","path":"$.ItemName"},{"column":"Cost","path":"$.ItemCost"}]'

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.SamplesOutOfProc.OutputBindingSamples.Common
{
    public class Item
    {
        public long ItemID { get; set; }

        public string? ItemName { get; set; }

        public double ItemCost { get; set; }
    }
}

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Extensions.Kusto;
using Microsoft.Azure.Functions.Worker.Http;
using Microsoft.Azure.WebJobs.Extensions.Kusto.SamplesOutOfProc.OutputBindingSamples.Common;

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.SamplesOutOfProc.OutputBindingSamples
{
    public static class AddProductsWithMapping
    {
        [Function("AddProductsWithMapping")]
        [KustoOutput(Database: "productsdb", Connection = "KustoConnectionString", TableName = "Products", MappingRef = "item_to_product_json")]
        public static async Task<Item> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "addproductswithmapping")]
            HttpRequestData req)
        {
            Item? item = await req.ReadFromJsonAsync<Item>();
            return item ?? new Item { };
        }
    }
}

Azure Data Explorer 出力バインドのその他のサンプルが、GitHub リポジトリで入手できます。

このセクションには、次の例が含まれています。

HTTP トリガー、1 つのレコードを書き込む
HTTP トリガー、2 つのテーブルに書き込む
HTTP トリガー、IAsyncCollector を使用してレコードを書き込む

この例では Product クラスとそれに対応するデータベーステーブルを参照します。

public class Product
{
    [JsonProperty(nameof(ProductID))]
    public long ProductID { get; set; }

    [JsonProperty(nameof(Name))]
    public string Name { get; set; }

    [JsonProperty(nameof(Cost))]
    public double Cost { get; set; }
}

.create-merge table Products (ProductID:long, Name:string, Cost:double)

HTTP トリガー、1 つのレコードを書き込む

次の例は、データベースにレコードを追加する C# 関数を示しています。関数では、JSON 本文として HTTP POST 要求に含まれるデータを使用しています。

using System.Globalization;
using System.IO;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.Common;
using Microsoft.Azure.WebJobs.Kusto;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.OutputBindingSamples
{
    public static class AddProduct
    {
        [FunctionName("AddProductUni")]
        public static IActionResult Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "addproductuni")]
            HttpRequest req, ILogger log,
            [Kusto(Database:"productsdb" ,
            TableName ="Products" ,
            Connection = "KustoConnectionString")] out Product product)
        {
            log.LogInformation($"AddProduct function started");
            string body = new StreamReader(req.Body).ReadToEnd();
            product = JsonConvert.DeserializeObject<Product>(body);
            return new CreatedResult($"/api/addproductuni", product);
        }
    }
}

HTTP トリガー、2 つのテーブルに書き込む

次の例は、2 つの異なるテーブル (Products と ProductsChangeLog) でデータベースにレコードを追加する C# 関数を示しています。関数では、JSON 本文として HTTP POST 要求に含まれるデータと複数の出力バインドを使用しています。

.create-merge table ProductsChangeLog (ProductID:long, CreatedAt:datetime)

using System;
using Newtonsoft.Json;

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.Common
{
    public class ProductsChangeLog
    {
        [JsonProperty(nameof(ProductID))]
        public long ProductID { get; set; }

        [JsonProperty(nameof(CreatedAt))]
        public DateTime CreatedAt { get; set; }

    }
}

using System;
using System.IO;
using Kusto.Cloud.Platform.Utils;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.Common;
using Microsoft.Azure.WebJobs.Kusto;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.OutputBindingSamples
{
    public static class AddMultiTable
    {
        [FunctionName("AddMultiTable")]
        public static IActionResult Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "addmulti")]
            HttpRequest req, ILogger log,
            [Kusto(Database:"productsdb" ,
            TableName ="Products" ,
            Connection = "KustoConnectionString")] IAsyncCollector<Product> productsCollector,
                        [Kusto(Database:"productsdb" ,
            TableName =S"ProductsChangeLog" ,
            Connection = "KustoConnectionString")] IAsyncCollector<ProductsChangeLog> changeCollector)
        {
            log.LogInformation($"AddProducts function started");
            string body = new StreamReader(req.Body).ReadToEnd();
            Product[] products = JsonConvert.DeserializeObject<Product[]>(body);
            products.ForEach(p =>
            {
                productsCollector.AddAsync(p);
                changeCollector.AddAsync(new ProductsChangeLog { CreatedAt = DateTime.UtcNow, ProductID = p.ProductID });
            });
            productsCollector.FlushAsync();
            changeCollector.FlushAsync();
            return products != null ? new ObjectResult(products) { StatusCode = StatusCodes.Status201Created } : new BadRequestObjectResult("Please pass a well formed JSON Product array in the body");
        }
    }
}

HTTP トリガー、IAsyncCollector を使用してレコードを書き込む

次の例では、一連のレコードをテーブルに取り込む C# 関数を示します。関数では、HTTP POST 本文 JSON 配列で提供されるデータを使用しています。

using System.IO;
using Kusto.Cloud.Platform.Utils;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.Common;
using Microsoft.Azure.WebJobs.Kusto;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace Microsoft.Azure.WebJobs.Extensions.Kusto.Samples.OutputBindingSamples
{
    public static class AddProductsAsyncCollector
    {
        [FunctionName("AddProductsAsyncCollector")]
        public static IActionResult Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "addproductsasynccollector")]
            HttpRequest req, ILogger log,
            [Kusto(Database:"productsdb" ,
            TableName ="Products" ,
            Connection = "KustoConnectionString")] IAsyncCollector<Product> collector)
        {
            log.LogInformation($"AddProductsAsyncCollector function started");
            string body = new StreamReader(req.Body).ReadToEnd();
            Product[] products = JsonConvert.DeserializeObject<Product[]>(body);
            products.ForEach(p =>
            {
                collector.AddAsync(p);
            });
            collector.FlushAsync();
            return products != null ? new ObjectResult(products) { StatusCode = StatusCodes.Status201Created } : new BadRequestObjectResult("Please pass a well formed JSON Product array in the body");
        }
    }
}

Java の Azure Data Explorer 入力バインドのその他のサンプルは、GitHub リポジトリにあります。

このセクションには、次の例が含まれています。

HTTP トリガー、レコードをテーブルに書き込む
HTTP トリガー、2 つのテーブルに書き込む

この例では Products クラス (別個のファイル Product.java 内) とそれに対応するデータベーステーブル Products (前に定義したもの) を参照します。

package com.microsoft.azure.kusto.common;

import com.fasterxml.jackson.annotation.JsonProperty;

public class Product {
    @JsonProperty("ProductID")
    public long ProductID;
    @JsonProperty("Name")
    public String Name;
    @JsonProperty("Cost")
    public double Cost;

    public Product() {
    }

    public Product(long ProductID, String name, double Cost) {
        this.ProductID = ProductID;
        this.Name = name;
        this.Cost = Cost;
    }
}

HTTP トリガー、レコードをテーブルに書き込む

次の例は、商品レコードをテーブルに追加する Java 関数の Azure Data Explorer 出力バインドを示します。関数では、JSON 本文として HTTP POST 要求に含まれるデータを使用しています。この関数には、JSON 本文を解析するために com.fasterxml.jackson.core ライブラリに対する追加の依存関係があります。

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.13.4.1</version>
</dependency>

package com.microsoft.azure.kusto.outputbindings;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.microsoft.azure.functions.HttpMethod;
import com.microsoft.azure.functions.HttpRequestMessage;
import com.microsoft.azure.functions.HttpResponseMessage;
import com.microsoft.azure.functions.HttpStatus;
import com.microsoft.azure.functions.OutputBinding;
import com.microsoft.azure.functions.annotation.AuthorizationLevel;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.HttpTrigger;
import com.microsoft.azure.functions.kusto.annotation.KustoOutput;
import com.microsoft.azure.kusto.common.Product;

import java.io.IOException;
import java.util.Optional;

import static com.microsoft.azure.kusto.common.Constants.*;

public class AddProduct {
    @FunctionName("AddProduct")
    public HttpResponseMessage run(@HttpTrigger(name = "req", methods = {
            HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS, route = "addproductuni") HttpRequestMessage<Optional<String>> request,
            @KustoOutput(name = "product", database = "productsdb", tableName = "Products", connection = KUSTOCONNSTR) OutputBinding<Product> product)
            throws IOException {

        if (request.getBody().isPresent()) {
            String json = request.getBody().get();
            ObjectMapper mapper = new ObjectMapper();
            Product p = mapper.readValue(json, Product.class);
            product.setValue(p);
            return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(product)
                    .build();
        } else {
            return request.createResponseBuilder(HttpStatus.NO_CONTENT).header("Content-Type", "application/json")
                    .build();
        }
    }
}

HTTP トリガー、2 つのテーブルに書き込む

次の例は、レコードを 2 つの異なるテーブル (Product と ProductChangeLog) でデータベースに追加する Java 関数の Azure Data Explorer 出力バインドを示します。関数では、JSON 本文として HTTP POST 要求に含まれるデータと複数の出力バインドを使用しています。この関数には、JSON 本文を解析するために com.fasterxml.jackson.core ライブラリに対する追加の依存関係があります。

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.13.4.1</version>
</dependency>

2 番目のテーブル ProductsChangeLog は、次の定義に対応します。

.create-merge table ProductsChangeLog (ProductID:long, CreatedAt:datetime)

および ProductsChangeLog.java の Java クラス:

package com.microsoft.azure.kusto.common;

import com.fasterxml.jackson.annotation.JsonProperty;

public class ProductsChangeLog {
    @JsonProperty("ProductID")
    public long ProductID;
    @JsonProperty("CreatedAt")
    public String CreatedAt;

    public ProductsChangeLog() {
    }

    public ProductsChangeLog(long ProductID, String CreatedAt) {
        this.ProductID = ProductID;
        this.CreatedAt = CreatedAt;
    }
}

package com.microsoft.azure.kusto.outputbindings;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.microsoft.azure.functions.HttpMethod;
import com.microsoft.azure.functions.HttpRequestMessage;
import com.microsoft.azure.functions.HttpResponseMessage;
import com.microsoft.azure.functions.HttpStatus;
import com.microsoft.azure.functions.OutputBinding;
import com.microsoft.azure.functions.annotation.AuthorizationLevel;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.HttpTrigger;
import com.microsoft.azure.functions.kusto.annotation.KustoOutput;
import com.microsoft.azure.kusto.common.Product;
import com.microsoft.azure.kusto.common.ProductsChangeLog;

import static com.microsoft.azure.kusto.common.Constants.*;

import java.io.IOException;
import java.time.Clock;
import java.time.Instant;
import java.util.Optional;

public class AddMultiTable {
    @FunctionName("AddMultiTable")
    public HttpResponseMessage run(@HttpTrigger(name = "req", methods = {
            HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS, route = "addmultitable") HttpRequestMessage<Optional<String>> request,
            @KustoOutput(name = "product", database = "productsdb", tableName = "Products", connection = KUSTOCONNSTR) OutputBinding<Product> product,
            @KustoOutput(name = "productChangeLog", database = "productsdb", tableName = "ProductsChangeLog",
                    connection = KUSTOCONNSTR) OutputBinding<ProductsChangeLog> productChangeLog)
            throws IOException {

        if (request.getBody().isPresent()) {
            String json = request.getBody().get();
            ObjectMapper mapper = new ObjectMapper();
            Product p = mapper.readValue(json, Product.class);
            product.setValue(p);
            productChangeLog.setValue(new ProductsChangeLog(p.ProductID, Instant.now(Clock.systemUTC()).toString()));
            return request.createResponseBuilder(HttpStatus.OK).header("Content-Type", "application/json").body(product)
                    .build();
        } else {
            return request.createResponseBuilder(HttpStatus.NO_CONTENT).header("Content-Type", "application/json")
                    .build();
        }
    }
}

Azure Data Explorer 出力バインドのその他のサンプルが、GitHub リポジトリで入手できます。

このセクションには、次の例が含まれています。

HTTP トリガー、レコードをテーブルに書き込む
HTTP トリガー、2 つのテーブルに書き込む

この例では、次のデータベーステーブルを参照します。

例では、テーブル Products と ProductsChangeLog (前に定義したもの) を参照しています。

HTTP トリガー、レコードをテーブルに書き込む

次の例は、function.json ファイルの Azure Data Explorer 出力バインドと、テーブルにレコードを追加する JavaScript 関数を示しています。関数では、JSON 本文として HTTP POST 要求に含まれるデータを使用しています。

function.json ファイルのバインドデータの例を次に示します。

{
  "bindings": [
    {
      "authLevel": "function",
      "name": "req",
      "direction": "in",
      "type": "httpTrigger",
      "methods": [
        "post"
      ],
      "route": "addproduct"
    },
    {
      "name": "$return",
      "type": "http",
      "direction": "out"
    },
    {
      "name": "product",
      "type": "kusto",
      "database": "productsdb",
      "direction": "out",
      "tableName": "Products",
      "connection": "KustoConnectionString"
    }
  ],
  "disabled": false
}

これらのプロパティについては、「構成」セクションを参照してください。

次のスニペットは、JavaScript コードの例です。

// Insert the product, which will insert it into the Products table.
module.exports = async function (context, req) {
    // Note that this expects the body to be a JSON object or array of objects which have a property
    // matching each of the columns in the table to insert to.
    context.bindings.product = req.body;
    return {
        status: 201,
        body: req.body
    };
}

HTTP トリガー、2 つのテーブルに書き込む

次の例は、function.json ファイルの Azure Data Explorer 出力バインドと、2 つの異なるテーブル (Products と ProductsChangeLog) でデータベースにレコードを追加する JavaScript 関数を示しています。関数では、JSON 本文として HTTP POST 要求に含まれるデータと複数の出力バインドを使用しています。

2 番目のテーブル ProductsChangeLog は、次の定義に対応します。

.create-merge table ProductsChangeLog (ProductID:long, CreatedAt:datetime)

次のスニペットは、function.json ファイルのバインドデータの例です。

{
  "bindings": [
    {
      "authLevel": "function",
      "name": "req",
      "direction": "in",
      "type": "httpTrigger",
      "methods": [
        "post"
      ],
      "route": "addmultitable"
    },
    {
      "name": "res",
      "type": "http",
      "direction": "out"
    },
    {
      "name": "product",
      "type": "kusto",
      "database": "productsdb",
      "direction": "out",
      "tableName": "Products",
      "connection": "KustoConnectionString"
    },
    {
      "name": "productchangelog",
      "type": "kusto",
      "database": "productsdb",
      "direction": "out",
      "tableName": "ProductsChangeLog",
      "connection": "KustoConnectionString"
    }
  ],
  "disabled": false
}

これらのプロパティについては、「構成」セクションを参照してください。

次のスニペットは、JavaScript コードの例です。

module.exports = async function (context, req) {
    context.log('JavaScript HTTP trigger and Kusto output binding function processed a request.');
    context.log(req.body);

    if (req.body) {
        var changeLog = {ProductID:req.body.ProductID, CreatedAt: new Date().toISOString()};
        context.bindings.product = req.body;
        context.bindings.productchangelog = changeLog;
        context.res = {
            body: req.body,
            mimetype: "application/json",
            status: 201
        }
    } else {
        context.res = {
            status: 400,
            body: "Error reading request body"
        }
    }
}

Azure Data Explorer 出力バインドのその他のサンプルが、GitHub リポジトリで入手できます。

このセクションには、次の例が含まれています。

HTTP トリガー、レコードをテーブルに書き込む
HTTP トリガー、2 つのテーブルに書き込む

例では、テーブル Products と ProductsChangeLog (前に定義したもの) を参照しています。

HTTP トリガー、レコードをテーブルに書き込む

次の例は、function.json ファイルの Azure Data Explorer 出力バインドと、テーブルにレコードを追加する Python 関数を示しています。関数では、JSON 本文として HTTP POST 要求に含まれるデータを使用しています。

次のスニペットは、function.json ファイルのバインドデータの例です。

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "Anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "post"
      ],
      "route": "addproductuni"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "name": "product",
      "type": "kusto",
      "database": "sdktestsdb",
      "direction": "out",
      "tableName": "Products",
      "connection": "KustoConnectionString"
    }
  ]
}

これらのプロパティについては、「構成」セクションを参照してください。

次のスニペットは、Python コードの例です。

import azure.functions as func
from Common.product import Product


def main(req: func.HttpRequest, product: func.Out[str]) -> func.HttpResponse:
    body = str(req.get_body(),'UTF-8')
    product.set(body)
    return func.HttpResponse(
        body=body,
        status_code=201,
        mimetype="application/json"
    )

HTTP トリガー、2 つのテーブルに書き込む

.create-merge table ProductsChangeLog (ProductID:long, CreatedAt:datetime)

次のスニペットは、function.json ファイルのバインドデータの例です。

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "Anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "post"
      ],
      "route": "addmultitable"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "name": "product",
      "type": "kusto",
      "database": "sdktestsdb",
      "direction": "out",
      "tableName": "Products",
      "connection": "KustoConnectionString"
    },
    {
      "name": "productchangelog",
      "type": "kusto",
      "database": "sdktestsdb",
      "direction": "out",
      "tableName": "ProductsChangeLog",
      "connection": "KustoConnectionString"
    }
  ]
}

これらのプロパティについては、「構成」セクションを参照してください。

次のスニペットは、Python コードの例です。

import json
from datetime import datetime

import azure.functions as func
from Common.product import Product


def main(req: func.HttpRequest, product: func.Out[str],productchangelog: func.Out[str]) -> func.HttpResponse:
    body = str(req.get_body(),'UTF-8')
    # parse x:
    product.set(body)
    id = json.loads(body)["ProductID"]

    changelog = {
        "ProductID": id,
        "CreatedAt": datetime.now().isoformat(),
    }
    productchangelog.set(json.dumps(changelog))
    return func.HttpResponse(
        body=body,
        status_code=201,
        mimetype="application/json"
    )

属性

C# ライブラリでは KustoAttribute 属性を使用して、次のプロパティを持つ関数に対して Azure Data Explorer バインドを宣言します。

属性のプロパティ	説明
データベース	必須。クエリを実行する必要があるデータベース。
接続	必須。環境変数または関数アプリの設定によって解決される接続文字列を保持する変数の名前。既定では、変数 `KustoConnectionString` を検索します。実行時に、環境に対してこの変数が検索されます。接続文字列のドキュメントについては、「Kusto 接続文字列」を参照してください。 (例: `"KustoConnectionString": "Data Source=https://your_cluster.kusto.windows.net;Database=your_Database;Fed=True;AppClientId=your_AppId;AppKey=your_AppKey;Authority Id=your_TenantId`)。
TableName	必須。データを取り込むテーブル。
MappingRef	省略可能。クラスターで既に定義されているマッピング参照を渡す属性。
ManagedServiceIdentity	省略可能。マネージド ID を使用して、Azure Data Explorer に接続できます。システムマネージド ID を使用するには、"system" を使用します。その他の ID 名はユーザーマネージド ID として解釈されます。
DataFormat	省略可能。既定のデータ形式は `multijson/json` です。これは、`datasource` 形式列挙型でサポートされている "テキスト" 形式に設定できます。サンプルは検証され、CSV 形式と JSON 形式用に提供されます。

注釈

Java 関数ランタイムライブラリでは、@KustoInput 注釈 (com.microsoft.azure.functions.kusto.annotation.KustoOutput) が使用されます。

要素	説明
name	必須。関数コード内のクエリ結果を表す変数の名前。
database	必須。クエリを実行する必要があるデータベース。
connection	必須。環境変数または関数アプリの設定によって解決される接続文字列を保持する変数の名前。既定では、変数 `KustoConnectionString` を検索します。実行時に、環境に対してこの変数が検索されます。接続文字列のドキュメントについては、「Kusto 接続文字列」を参照してください。 (例: `"KustoConnectionString": "Data Source=https://your_cluster.kusto.windows.net;Database=your_Database;Fed=True;AppClientId=your_AppId;AppKey=your_AppKey;Authority Id=your_TenantId`)。
tableName	必須。データを取り込むテーブル。
mappingRef	省略可能。クラスターで既に定義されているマッピング参照を渡す属性。
dataFormat	省略可能。既定のデータ形式は `multijson/json` です。これは、`datasource` 形式列挙型でサポートされている "テキスト" 形式に設定できます。サンプルは検証され、CSV 形式と JSON 形式用に提供されます。
managedServiceIdentity	マネージド ID を使用して、Azure Data Explorer に接続できます。システムマネージド ID を使用するには、"system" を使用します。その他の ID 名はユーザーマネージド ID として解釈されます。

構成

次の表は、function.json ファイルで設定したバインド構成のプロパティを説明しています。

function.json のプロパティ	説明
type	必須。 `kusto` に設定する必要があります。
方向	必須。 `out` に設定する必要があります。
name	必須。関数コード内のクエリ結果を表す変数の名前。
database	必須。クエリを実行する必要があるデータベース。
connection	必須。環境変数または関数アプリの設定によって解決される接続文字列を保持する変数の "名前"。既定では、変数 `KustoConnectionString` を検索します。実行時に、環境に対してこの変数が検索されます。接続文字列のドキュメントについては、「Kusto 接続文字列」を参照してください。 (例: `"KustoConnectionString": "Data Source=https://your_cluster.kusto.windows.net;Database=your_Database;Fed=True;AppClientId=your_AppId;AppKey=your_AppKey;Authority Id=your_TenantId`)。
tableName	必須。データを取り込むテーブル。
mappingRef	省略可能。クラスターで既に定義されているマッピング参照を渡す属性。
dataFormat	省略可能。既定のデータ形式は `multijson/json` です。これは、`datasource` 形式列挙型でサポートされている "テキスト" 形式に設定できます。サンプルは検証され、CSV 形式と JSON 形式用に提供されます。
managedServiceIdentity	マネージド ID を使用して、Azure Data Explorer に接続できます。システムマネージド ID を使用するには、"system" を使用します。その他の ID 名はユーザーマネージド ID として解釈されます。

ローカルで開発する場合は、Values コレクション内の local.settings.json ファイルにアプリケーション設定を追加します。

使用方法

属性のコンストラクターは、データベースと、属性 TableName、MappingRef、DataFormat、および接続設定名を受け取ります。 KQL コマンドには、KQL ステートメントまたは KQL 関数を指定できます。接続文字列の設定名は、Kusto 接続文字列を含むアプリケーション設定 (ローカル開発の場合は local.settings.json にあります) に対応します。たとえば、"KustoConnectionString": "Data Source=https://your_cluster.kusto.windows.net;Database=your_Database;Fed=True;AppClientId=your_AppId;AppKey=your_AppKey;Authority Id=your_TenantId となります。入力バインディングによって実行されるクエリはパラメーター化されます。 KQL パラメーターで指定された値は、実行時に使用されます。

次の手順

テーブルからデータを読み取る (入力バインド)

Azure Functions 用の Azure Data Explorer 出力バインド (プレビュー)

例

HTTP トリガー、1 つのレコードを書き込む

HTTP トリガー、マッピングを使用したレコードの書き込み

HTTP トリガー、レコードをテーブルに書き込む

HTTP トリガー、2 つのテーブルに書き込む

HTTP トリガー、レコードをテーブルに書き込む

HTTP トリガー、2 つのテーブルに書き込む

HTTP トリガー、レコードをテーブルに書き込む

HTTP トリガー、2 つのテーブルに書き込む

属性

注釈

構成

使用方法

次の手順

その他のリソース