通过

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

Azure Functions 的 Dapr 主题触发器

  • 项目

可使用以下 Dapr 事件在订阅 Dapr 主题时触发 Azure Functions。

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

示例

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

执行模型 说明
独立工作模型 函数代码在单独的 .NET 工作进程中运行。 与受支持的 .NET 和 .NET Framework 版本结合使用。 若要了解详细信息，请参阅开发 .NET 独立工作进程函数。
进程模型 函数代码与 Functions 宿主进程在同一进程中运行。 仅支持 .NET 的长期支持 (LTS) 版本。 若要了解详细信息，请参阅开发 .NET 类库函数。 
[FunctionName("TransferEventBetweenTopics")]
public static void Run(
    [DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "B")] out DaprPubSubEvent pubEvent,
    ILogger log)
{
    log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");


    pubEvent = new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}

下面是使用 Dapr 主题触发器订阅主题的 Java 代码：

@FunctionName("PrintTopicMessage")
public String run(
        @DaprTopicTrigger(
            pubSubName = "%PubSubName%",
            topic = "B")
        String payload,
        final ExecutionContext context) throws JsonProcessingException {
    Logger logger = context.getLogger();
    logger.info("Java function processed a PrintTopicMessage request from the Dapr Runtime.");

使用 app 对象注册 daprTopicTrigger：

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

app.generic('TransferEventBetweenTopics', {
    trigger: trigger.generic({
        type: 'daprTopicTrigger',
        name: "subEvent",
        pubsubname: "%PubSubName%",
        topic: "A"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
        context.log(context.triggerMetadata.subEvent.data);

        return { payload: context.triggerMetadata.subEvent.data };
    }
});

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

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

{
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "%PubSubName%",
      "topic": "B",
      "name": "subEvent",
      "direction": "in"
    }
  ]
}

有关 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 (
    $subEvent
)

Write-Host "PowerShell function processed a PrintTopicMessage request from the Dapr Runtime."

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"] | ConvertTo-Json -Compress

Write-Host "Topic B received a message: $jsonString"

以下示例显示了一个 Dapr 主题触发器，该触发器使用 v2 Python 编程模型。 在 Python 函数应用代码中使用 daprTopicTrigger：

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="PrintTopicMessage")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
def main(subEvent) -> None:
    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    logging.info("Topic B received a message: " + subEvent_json["data"])

属性

在进程内模型中，使用 DaprTopicTrigger 触发 Dapr 发布/订阅绑定，该绑定支持以下属性。

参数 说明
PubSubName Dapr 发布/订阅的名称。
主题 Dapr 主题的名称。

批注

使用 DaprTopicTrigger 注释，可以创建在收到主题时要运行的函数。

元素 说明
pubSubName Dapr 发布/订阅的名称。
topic Dapr 主题的名称。

配置

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

properties 说明
pubsubname Dapr 发布/订阅组件类型的名称。
topic 主题名称。

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

“function.json”属性 说明
pubsubname Dapr 发布/订阅组件类型的名称。
topic 主题名称。

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

properties 说明 可通过 Attribute 发送 可通过 RequestBody 发送
pub_sub_name Dapr 订阅组件类型的名称。 ✔ ❌
topic 订阅主题。 ✔ ❌

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

使用情况

要使用 Dapr 主题触发器，请首先设置 Dapr 发布/订阅组件。 可在 Dapr 官方文档中详细了解可使用的组件及其设置方式。

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

  1. 创建并激活虚拟环境。

  2. 在 requirements.text 文件中添加以下行：

    azure-functions==1.18.0b3

  3. 在终端中安装 Python 库。

    pip install -r .\requirements.txt

  4. 使用以下配置修改 local.setting.json 文件：

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

后续步骤

详细了解 Dapr 发布和订阅。