Azure Functions 的 Azure 數據總管輸出系結（預覽）

發行項
04/07/2024

當函式執行時，Azure 數據總管輸出系結會將數據內嵌至 Azure 數據總管。

如需安裝和組態詳細數據的詳細資訊，請參閱概觀。

範例

您可以使用下列其中一種 C# 模式來建立 C# 函式：

隔離的背景工作模型：在與運行時間隔離的背景工作進程中執行的已編譯 C# 函式。需要隔離的背景工作進程，才能支援在 LTS 和非 LTS 版本 .NET 和 .NET Framework 上執行的 C# 函式。
同進程模型：在與 Functions 運行時間相同的進程中執行的已編譯 C# 函式。
C# 文稿：主要用於在 Azure 入口網站中建立 C# 函式。

重要

支援將於 2026 年 11 月 10 日結束進程模型。強烈建議您將應用程式移轉至隔離的背景工作模型，以取得完整支援。

隔離式背景工作角色模型
內含式模型

GitHub 存放庫中提供 Azure 數據總管輸出系結的更多範例。

本區段包含下列範例：

HTTP 觸發程式，寫入一筆記錄
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 觸發程式，寫入一筆記錄

下列範例顯示將記錄新增至資料庫的 C# 函式。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體。

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# 函式。函式會使用將轉換成的ProductItem對應。

若要將資料從 ProductItem轉換成，函式會使用對應參考：

.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 { };
        }
    }
}

GitHub 存放庫中提供 Azure 數據總管輸出系結的更多範例。

本區段包含下列範例：

HTTP 觸發程式，寫入一筆記錄
HTTP 觸發程序，寫入至兩個資料表
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 觸發程式，寫入一筆記錄

下列範例顯示將記錄新增至資料庫的 C# 函式。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體。

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 觸發程序，寫入至兩個資料表

下列範例顯示 C# 函式，可將記錄新增至兩個不同數據表中的資料庫（Products 和 ProductsChangeLog）。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體和多個輸出系結。

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

GitHub 存放庫中提供 Java Azure 數據總管輸入系結的更多範例。

本區段包含下列範例：

HTTP 觸發程式，將記錄寫入數據表
HTTP 觸發程序，寫入至兩個資料表

這些範例會參考類別 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 數據總管輸出系結，可將產品記錄新增至數據表。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體。函式會採用 com.fasterxml.jackson.core 連結庫的另一個相依性來剖析 JSON 主體。

<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 觸發程序，寫入至兩個資料表

下列範例顯示 Java 函式中的 Azure 數據總管輸出系結，可將記錄新增至兩個不同數據表中的資料庫（Product 和 ProductChangeLog）。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體和多個輸出系結。函式會採用 com.fasterxml.jackson.core 連結庫的另一個相依性來剖析 JSON 主體。

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

第二個資料表 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();
        }
    }
}

GitHub 存放庫中提供 Azure 數據總管輸出系結的更多範例。

本區段包含下列範例：

HTTP 觸發程序，將記錄寫入至資料表
HTTP 觸發程序，寫入至兩個資料表

這些範例會參考資料庫數據表。

這些範例會參考數據表 Products 和 ProductsChangeLog （稍早定義）。

HTTP 觸發程序，將記錄寫入至資料表

下列範例示範function.json檔案中的 Azure 數據總管輸出系結，以及將記錄新增至數據表的 JavaScript 函式。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體。

下列範例是系結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 觸發程序，寫入至兩個資料表

下列範例顯示function.json檔案中的 Azure 數據總管輸出系結，以及 JavaScript 函式，可將記錄新增至兩個不同數據表中的資料庫（Products和 ProductsChangeLog）。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體和多個輸出系結。

第二個資料表 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"
        }
    }
}

GitHub 存放庫中提供 Azure 數據總管輸出系結的更多範例。

本區段包含下列範例：

HTTP 觸發程序，將記錄寫入至資料表
HTTP 觸發程序，寫入至兩個資料表

這些範例會參考數據表 Products 和 ProductsChangeLog （稍早定義）。

HTTP 觸發程序，將記錄寫入至資料表

下列範例示範function.json檔案中的 Azure 數據總管輸出系結，以及將記錄新增至數據表的 Python 函式。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體。

下列代碼段是系結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 觸發程序，寫入至兩個資料表

下列範例顯示function.json檔案中的 Azure 數據總管輸出系結，以及 JavaScript 函式，可將記錄新增至兩個不同數據表中的資料庫（Products和 ProductsChangeLog）。函式會使用 HTTP POST 要求中提供的數據做為 JSON 主體和多個輸出系結。第二個資料表 ProductsChangeLog，對應至下列定義：

.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 數據總管系結，其具有下列屬性。

Attribute 屬性	描述
資料庫	必要。必須對其執行查詢的資料庫。
連線	必要。保留連接字串的變數名稱，該變數會透過環境變數或函式應用程式設定解析。預設會查閱變數 `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	選擇性。傳遞已在叢集中定義的對應 ref 屬性。
ManagedServiceIdentity	選擇性。受控識別可用來連線到 Azure 數據總管。若要使用系統受控識別，請使用「系統」。任何其他身分識別名稱會解譯為使用者受控識別。
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	選擇性。傳遞已在叢集中定義的對應 ref 屬性。
dataFormat	選擇性。預設資料格式為 `multijson/json`。它可以設定為格式列舉中`datasource`支援的文字格式。範例會針對 CSV 和 JSON 格式進行驗證並提供。
managedServiceIdentity	受控識別可用來連線到 Azure 數據總管。若要使用系統受控識別，請使用「系統」。任何其他身分識別名稱會解譯為使用者受控識別。

組態

下表說明您在 function.json 檔案中設定的繫結設定屬性。

function.json 屬性	描述
type	必要。必須設定為 `kusto`。
direction	必要。必須設定為 `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	選擇性。傳遞已在叢集中定義的對應 ref 屬性。
dataFormat	選擇性。預設資料格式為 `multijson/json`。它可以設定為格式列舉中`datasource`支援的文字格式。範例會針對 CSV 和 JSON 格式進行驗證並提供。
managedServiceIdentity	受控識別可用來連線到 Azure 數據總管。若要使用系統受控識別，請使用「系統」。任何其他身分識別名稱會解譯為使用者受控識別。

當您在本機開發時，請在集合中的 local.settings.json 檔案Values中新增應用程式設定。

使用方式

屬性的建構函式會採用資料庫和屬性 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 數據總管輸出系結 （預覽）

範例

HTTP 觸發程式，寫入一筆記錄

HTTP 觸發程式，使用對應寫入記錄

HTTP 觸發程式，將記錄寫入數據表

HTTP 觸發程序，寫入至兩個資料表

HTTP 觸發程序，將記錄寫入至資料表

HTTP 觸發程序，寫入至兩個資料表

HTTP 觸發程序，將記錄寫入至資料表

HTTP 觸發程序，寫入至兩個資料表

屬性

註釋

組態

使用方式

下一步

其他資源

Azure Functions 的 Azure 數據總管輸出系結（預覽）