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

教程：使用自定义主题将 Azure 事件网格中的 MQTT 消息路由到 Azure Functions - Azure 门户

2025-07-23

在本教程中，将使用事件网格自定义主题将 Azure 事件网格命名空间收到的 MQTT 消息路由到 Azure 函数。

如果没有 Azure 订阅，可以注册免费试用版。

使用事件网格触发器创建 Azure 函数

按照使用 Visual Studio Code 创建 Azure 函数中的说明作，但使用 Azure 事件网格触发器 ，而不是使用 HTTP 触发器。

重要

在同一区域中创建所有资源。

应会看到类似于以下示例的代码：

using System;
using Azure.Messaging;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace Company.Function
{
    public class MyEventGridTriggerFunc
    {
        private readonly ILogger<MyEventGridTriggerFunc> _logger;

        public MyEventGridTriggerFunc(ILogger<MyEventGridTriggerFunc> logger)
        {
            _logger = logger;
        }

        [Function(nameof(MyEventGridTriggerFunc))]
        public void Run([EventGridTrigger] CloudEvent cloudEvent)
        {
            _logger.LogInformation("Event type: {type}, Event subject: {subject}", cloudEvent.Type, cloudEvent.Subject);
        }
    }
}

在本教程的后面部分，将此 Azure 函数用作主题订阅的事件处理程序。

注释

本教程已使用使用 .NET 8.0（独立）运行时堆栈的 Azure 函数进行测试。

创建事件网格主题（自定义主题）

创建事件网格主题。请参阅使用 Azure 门户创建自定义主题。创建事件网格主题时，在“高级”选项卡上，为“事件架构”选择“云事件架构 v1.0”。

显示“创建主题”向导的“高级”页的屏幕截图。

注释

在本教程的任何地方使用 云事件架构 v1.0 。

使用函数向主题添加订阅

在此步骤中，使用前面创建的 Azure 函数创建事件网格主题的订阅。

在 “事件网格主题 ”页上，选择“ 订阅”。
在 “创建事件订阅 ”页上，执行以下步骤：
1. 为事件订阅输入名称。
2. 对于 事件架构，请选择 “云事件架构 1.0”。
3. 对于“终结点类型”，请选择“Azure Function”。
4. 然后选择“ 配置终结点”。
在 “选择 Azure 函数 ”页上，执行以下步骤：
1. 对于“订阅”，请选择你的 Azure 订阅。
2. 对于 资源组，请选择具有 Azure 函数的资源组。
3. 对于 函数应用，请选择具有函数的 Functions 应用。
4. 对于槽，请选择“生产”。
5. 对于“函数”，选择你的 Azure 函数。
6. 然后，选择“确认选择”。
在“ 创建事件订阅 ”页上，选择“ 创建”。
在 “事件订阅 ”页上，应会看到创建的订阅。

创建命名空间、客户端、主题空间和权限绑定

按照快速入门：在 Azure 门户中使用事件网格命名空间发布和订阅 MQTT 消息中的说明进行操作：

创建事件网格命名空间。
创建两个客户端。
创建主题空间。
创建发布者和订阅者权限绑定。
使用 MQTTX 应用进行测试，以确认客户端能够发送和接收消息。

为命名空间启用托管标识

在本部分中，将为事件网格命名空间启用系统分配的托管标识。然后，向标识授予“发送”事件网格自定义主题的权限。然后，它可以将消息路由到自定义主题。通过将托管标识添加到自定义主题上的“事件网格数据发送方”角色来启用它。

在 “事件网格命名空间 ”页上，选择“ 标识”。选择 “打开 ”，然后选择 “保存”。
导航到事件网格自定义主题的事件网格主题。
选择左侧导航栏上的 访问控制 。
在 “访问控制 ”页上，选择“ 添加”，然后选择“ 添加角色分配”。
在“添加角色分配向导”的“角色”页上，选择“事件网格数据发件人”角色，然后选择“下一步”。
在“添加角色分配”的“成员”页上，选择“托管身份”，然后选择“选择成员”。
在 “选择托管标识 ”页上，执行以下步骤：
1. 选择 Azure 订阅。
2. 对于“托管标识”，选择“事件网格命名空间”。
3. 选择与事件网格命名空间同名的托管标识。
4. 选择选择。
在 “添加角色分配 ”页上，选择“ 下一步”。
在 “审阅 + 分配 ”页上，查看设置，然后选择“ 审阅 + 分配”。