本文介绍如何在事件总线EventBridge控制台添加微消息队列MQTT版作为事件流中的事件提供方。

前提条件

操作步骤

  1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流
  2. 在顶部菜单栏,选择地域,然后单击创建事件流
  3. 创建事件流面板,配置以下参数,然后单击创建
    1. 基本信息页签,设置事件流名称描述,单击下一步
    2. 事件源页签,选择事件提供方微消息队列 MQTT 版,配置生产消息的MQTT 实例MQTT Topic,然后单击下一步
    3. 规则目标页签,分别设置事件规则和事件目标。
    4. 返回事件流页面,找到创建好的事件流,在其右侧操作栏,单击启用
      启用事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。

事件示例

{
    "specversion":"1.0",
    "id":"AC1EC0C950650816F27D46F7D7CA****",
    "source":"acs:mqtt",
    "type":"mqtt:Topic:SendMessage",
    "subject":"acs:mq:cn-hangzhou:143998900779****:topic/mqtt-cn-2r42qam****/housekee****",
    "datacontenttype":"application/json; charset\u003dutf-8",
    "time":"2022-06-22T03:53:47.959Z",
    "aliyunaccountid":"143998900779****",
    "data":{
        "props":{
            "firstTopic":"housekee****",
            "secondTopic":"/testMq4****",
            "clientId":"GID_****"
        },
        "body":"TEST"
    }
}

CloudEvents规范中定义的参数解释,请参见事件概述

data字段包含的参数解释如下表所示。

参数 类型 示例 描述
props Map 消息属性。
firstTopic String housekee**** 用于收发消息的父级Topic。
secondTopic String /testMq4**** 子级Topic。
clientId String GID_**** 客户端ID。
body String TEST 消息内容。