将 MQTT 源添加到 Eventstream(预览版)

本文介绍如何将 MQTT 源添加到 Eventstream。 

MQTT 是一种发布-订阅消息传输协议,专为受限环境而设计。 由于其高效性、可扩展性和可靠性,它是 IoT 方案的首选通信标准。 Microsoft Fabric 事件流支持连接到 MQTT 代理,其中 MQTT 代理中的消息可引入到 Fabric Eventstream 中,并路由到 Fabric 中的各种目标。

Note

工作区容量的以下区域不支持此源:美国西部 3瑞士西部。 

Prerequisites

在开始之前,必须完成以下先决条件:

  • 使用“参与者”或更高权限访问 Fabric 高级工作区。 
  • 收集用户名和密码以连接到 MQTT 代理。
  • 确保 MQTT 代理可公开访问,不受防火墙或虚拟网络限制。

若要了解如何配置此设置并通过 Azure 事件网格流式传输 MQTT 数据,请参阅 将 Azure 事件网格命名空间作为源添加到事件流

若要了解如何通过配置面向事件流自定义终结点的数据流终结点来流式传输 Azure IoT作 中的 MQTT 数据,请参阅 为 Microsoft Fabric Real-Time Intelligence 配置数据流终结点

启动“选择数据源”向导

如果您尚未向事件流添加任何源,请选择“使用外部源”选项。

显示选择了“使用外部源”磁贴的屏幕截图。

如果要向已发布的事件流添加源,请切换到“编辑”模式,在功能区中选择“添加源”,然后选择“外部源”

屏幕截图显示选择了“将源添加到外部源”菜单。

在“选择数据源”页面上,搜索并选择“MQTT”磁贴上的“连接”

显示在“获取事件”向导中选择 MQTT 作为源类型的屏幕截图。

配置 MQTT 连接器

  1. 在“连接”页上,选择“新建连接”。

    屏幕截图显示“连接”页中的“新建连接”链接被突出显示。

    如果存在与 MQTT 源的现有连接,请选择该现有连接。

  2. 在“连接设置”部分,

    1. 对于 MQTT 代理 URL,输入 MQTT 中转站的 URL,从 ssl://wss://开始。

      Note

      MQTT 源支持 MQTT 中转站和 Eventstream 之间的 TLS/SSL 保护的 MQTT 连接。 仅当服务器证书由 受信任的 CA 列表中包括的证书颁发机构(CA)签名时,才支持 TLS/SSL 连接。

    2. 对于“连接名称”,请输入与 MQTT 的连接的名称。

    3. 输入 MQTT 代理的用户名和密码。

      显示“连接设置”部分的屏幕截图。

    4. 选择 连接

  3. 现在,在向导的“连接”页上,必须输入单个主题名称。 尚不支持多个主题。

  4. 对于版本,目前仅支持 MQTT V5

  5. 然后,选择“下一步”

    显示“配置 MQTT 数据源”部分的屏幕截图。

  6. 在“查看 + 连接”页上,查看设置,然后选择“添加”或“连接”。

查看更新的事件流

  1. 你会看到 MQTT 源已添加到“编辑”模式中画布上的 Eventstream。 若要将其发布到实时状态,请选择功能区上的“发布”。

    显示编辑器的屏幕截图,其中选择了“发布”按钮。

  2. 完成这些步骤后,该数据源可在“实时视图”中进行可视化。 选择关系图中的MQTT磁贴,以查看类似以下所示的页面。

    显示实时视图中编辑器的屏幕截图。

有关所有受支持源的列表,请参阅添加和管理事件流