你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

Azure Functions 的 Dapr 状态输出绑定

2025-05-12

Dapr 状态输出绑定允许在函数执行期间将值保存到 Dapr 状态。

若要了解 Dapr 扩展的设置和配置详细信息，请参阅 Dapr 扩展概述。

示例：

可以使用以下 C# 模式之一创建 C# 函数：

执行模型	DESCRIPTION
独立工作模型	函数代码在单独的 .NET 工作进程中运行。与支持的 .NET 和 .NET Framework 版本一起使用。若要了解详细信息，请参阅独立辅助角色模型中运行 C# Azure Functions 的指南。
进程内模型	函数代码与 Functions 宿主进程在同一进程中运行。仅支持 .NET 的长期支持（LTS）版本。若要了解详细信息，请参阅使用 Azure Functions 开发 C# 类库函数。

进行中
独立进程

以下示例演示如何使用 Dapr 状态输出绑定将新状态保存到状态存储中。

[FunctionName("StateOutputBinding")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "state/{key}")] HttpRequest req,
    [DaprState("statestore", Key = "{key}")] IAsyncCollector<string> state,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
    await state.AddAsync(requestBody);

    return new OkResult();
}

GitHub 存储库中提供了有关 Dapr 输出状态绑定的更多示例。

[Function("StateOutputBinding")]
[DaprStateOutput("statestore", Key = "{key}")]
public static string Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "state/{key}")] HttpRequestData req,
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("StateOutputBinding");
    log.LogInformation("C# HTTP trigger function processed a request.");

    string requestBody = new StreamReader(req.Body).ReadToEnd();

    return requestBody;
}

以下示例使用DaprStateOutput绑定和以下内容创建一个"CreateNewOrderHttpTrigger"HttpTrigger函数：

@FunctionName("CreateNewOrderHttpTrigger")
public String run(
        @HttpTrigger(
            name = "req",
            methods = {HttpMethod.POST},
            authLevel = AuthorizationLevel.ANONYMOUS)
            HttpRequestMessage<Optional<String>> request,
        @DaprStateOutput(
            stateStore = "%StateStoreName%",
            key = "product")
        OutputBinding<String> product,
        final ExecutionContext context) {
    context.getLogger().info("Java HTTP trigger (CreateNewOrderHttpTrigger) processed a request.");
}

Node.js v4
Node.js v3

在以下示例中，Dapr 状态输出绑定与 HTTP 触发器配对，该触发器由 app 对象注册：

const { app, trigger } = require('@azure/functions');

app.generic('StateOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "state/{key}",
        name: "req"
    }),
    return: daprStateOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { value : payload };
    }
});

以下示例显示了 function.json 文件中的 Dapr 触发器以及使用这些绑定的 JavaScript 代码。

下面是输出 daprStatefunction.json 文件：

{
  "bindings": 
    {
      "type": "daprState",
      "direction": "out",
      "name": "dapr",
      "stateStore": "statestore",
      "key": "{key}",
      "daprAddress": "%daprAddress%"
    }
}

有关 function.json 文件属性的详细信息，请参阅配置部分。

JavaScript 代码如下所示：

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

    context.bindings.dapr = {
        // stateStore: 'statestore-if-not-in-function.json'
        // key: 'key-if-not-in-function.json'
        value: req.body
    };
};

以下示例显示了 function.json 文件中的 Dapr 触发器以及使用这些绑定的 PowerShell 代码。

下面是输出 daprStatefunction.json 文件：

{
  "bindings": 
    {
      "type": "daprState",
      "stateStore": "%StateStoreName%",
      "direction": "out",
      "name": "order",
      "key": "order"
    }
}

有关 function.json 文件属性的详细信息，请参阅配置部分。

在代码中：

using namespace System
using namespace Microsoft.Azure.WebJobs
using namespace Microsoft.Extensions.Logging
using namespace Microsoft.Azure.WebJobs.Extensions.Dapr
using namespace Newtonsoft.Json.Linq

param (
    $payload
)

# C# function processed a CreateNewOrder request from the Dapr Runtime.
Write-Host "PowerShell function processed a CreateNewOrder request from the Dapr Runtime."

# Payload must be of the format { "data": { "value": "some value" } }

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $payload| ConvertTo-Json

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name order -Value $payload["data"]

Python v2
Python v1

以下示例演示使用 v2 Python 编程模型的 Dapr 状态输出绑定。在 Python 函数应用代码中使用 daprState：

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="HttpTriggerFunc")
@app.route(route="req", auth_level=dapp.auth_level.ANONYMOUS)
@app.dapr_state_output(arg_name="state", state_store="statestore", key="newOrder")
def main(req: func.HttpRequest, state: func.Out[str] ) -> str:
    # request body must be passed this way '{\"value\": { \"key\": \"some value\" } }'
    body = req.get_body()
    if body is not None:
        state.set(body.decode('utf-8'))
        logging.info(body.decode('utf-8'))
    else:
        logging.info('req body is none')
    return 'ok'

以下示例演示使用 v1 Python 编程模型的 Dapr 状态输出绑定。

的 function.json 文件如下所示daprState：

{
  "scriptFile": "__init__.py",
  "bindings": 
    {
      "type": "daprState",
      "stateStore": "%StateStoreName%",
      "direction": "out",
      "name": "order",
      "key": "order"
    }
}

有关 function.json 文件属性的详细信息，请参阅配置部分。

下面是 Python 代码：

import logging
import json
import azure.functions as func

def main(payload,
         order: func.Out[str]) -> None:
    logging.info('Python function processed a CreateNewOrder request from the Dapr Runtime.')  
    payload_json = json.loads(payload)
    logging.info(payload_json["data"])
    order.set(json.dumps(payload_json["data"]))

在进程内模型中，使用 DaprState 定义 Dapr 状态输出绑定，该绑定支持以下参数：

参数	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
StateStore	要保存状态的状态存储的名称。	✔️	❌
密钥	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

在隔离的辅助角色模型中，使用 DaprStateOutput 定义支持以下参数的 Dapr 状态输出绑定：

参数	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
StateStore	要保存状态的状态存储的名称。	✔️	❌
密钥	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

批注

该 DaprStateOutput 批注允许你函数访问状态存储。

元素	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
stateStore	要保存状态的状态存储的名称。	✔️	❌
键	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

配置

Node.js v4
Node.js v3

下表说明了在代码中设置的绑定配置属性。

资产	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
stateStore	要保存状态的状态存储的名称。	✔️	❌
键	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

下表解释了在 function.json 文件中设置的绑定配置属性。

“function.json”属性	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
stateStore	要保存状态的状态存储的名称。	✔️	❌
键	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

下表解释了在 function.json 文件中设置的绑定配置属性。

“function.json”属性	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
stateStore	要保存状态的状态存储的名称。	✔️	❌
键	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

Python v2
Python v1

下表介绍了在 Python 代码中设置的 @dapp.dapr_state_output 的绑定配置属性。

资产	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
stateStore	要保存状态的状态存储的名称。	✔️	❌
键	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

下表解释了在 function.json 文件中设置的绑定配置属性。

“function.json”属性	DESCRIPTION	可通过 Attribute 发送	可通过 RequestBody 发送
stateStore	要保存状态的状态存储的名称。	✔️	❌
键	在状态存储中保存状态的密钥的名称。	✔️	✔️
价值	必填。要存储的值。	❌	✔️

如果属性在 Attributes 和 RequestBody 中定义，则优先于 RequestBody 中提供的数据。

有关完整示例，请参阅示例部分。

用法

若要使用 Dapr 状态输出绑定，请首先设置 Dapr 状态存储组件。可在 Dapr 官方文档中详细了解可使用的组件及其设置方式。

Python v2
Python v1

要在 Python v2 中使用 daprState，请使用正确的依赖项设置项目。

创建并激活虚拟环境。
在 requirements.text 文件中添加以下行：
```
azure-functions==1.18.0b3
```
在终端中安装 Python 库。
```
pip install -r .\requirements.txt
```
使用以下配置修改 local.setting.json 文件：
```
"PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
```

后续步骤

详细了解 Dapr 状态管理。

通过

Azure Functions 的 Dapr 状态输出绑定

示例：

特性

批注

配置

用法

后续步骤

反馈

其他资源