如需将其他阿里云产品的数据导入云消息队列 MQTT 版,您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端,从而实现直接调用阿里云产品的API发送数据到MQTT客户端。
流程说明
注意事项
云消息队列 MQTT 版通过配置的流入规则和云消息队列 RocketMQ 版进行跨云产品的消息交互时,若云消息队列 RocketMQ 版的服务端进行升级,则在升级期间,可能会造成云消息队列 MQTT 版客户端消费消息延迟。产品升级动态,请参见通知列表。
创建数据流入规则
登录云消息队列 MQTT 版控制台,并在左侧导航栏单击实例列表。
在顶部菜单栏选择目标地域,然后在实例列表中单击实例名称进入实例详情页面。
在左侧导航栏单击规则管理,然后在页面左上角,单击创建规则。
在创建规则页面完成以下操作。
在配置基本信息配置向导页面,填写规则的基本信息,然后单击下一步。
参数
取值示例
说明
规则ID
111111
规则的全局唯一标识,说明如下:
只能包含字母、数字、短划线(-)和下划线(_),至少包含一个字母或数字。
名称长度限制在3~64字符之间,长于64字符将被自动截取。
创建后无法更新。
描述
migrate from rocketmq
对规则的描述。
状态
启用
是否启用当前规则,取值说明如下:
启用
停用
规则类型
数据流入
创建的规则类型,取值说明如下:
数据流出:用于将云消息队列 MQTT 版的数据导出至其他阿里云产品。详细信息,请参见跨云产品的数据流出。
数据流入:用于将其他阿里云产品的数据导入至云消息队列 MQTT 版。详细信息,请参见跨云产品数据流入。
上下线通知:用于将获取的云消息队列 MQTT 版客户端上下线事件数据导出至其他阿里云产品。详细信息,请参见MQTT客户端上下线事件数据流出。
在配置规则源配置向导页面,配置数据源,然后单击下一步。
参数
取值示例
说明
源服务类型
消息队列 RocketMQ 版
指定您需将哪个源云产品的数据流入至云消息队列 MQTT 版。
说明当前仅支持云消息队列 RocketMQ 版。
RocketMQ 实例
MQ_INST_13801563067*****_BbyOD2jQ
指定源云产品的实例ID,即云消息队列 RocketMQ 版的实例ID。
说明仅支持选择和云消息队列 MQTT 版实例为同一地域的云产品实例。
Topic
TopicA
指定源云产品的资源键值,即云消息队列 RocketMQ 版的Topic。TopicA的消息将流转至目标云消息队列 MQTT 版的Topic。
在配置规则目标配置向导页面,配置数据的流转目标,然后单击创建。
参数
取值示例
说明
Topic
TopicB
指定您需要将其他源云产品的数据导入至云消息队列 MQTT 版的哪个目标Topic。
重要在云消息队列 MQTT 版中Topic是多级结构,而云消息队列 RocketMQ 版的Topic仅有一级,因此,云消息队列 MQTT 版中的一级Topic映射到云消息队列 RocketMQ 版的Topic,而子级Topic,包括二级、三级、n级Topic则映射到云消息队列 RocketMQ 版的消息属性(Properties)中。具体映射关系,请参见MQTT与RocketMQ的消息结构映射。
您可以在规则管理的规则列表查看到刚创建的数据流入规则。
编辑数据流入规则
- 在规则列表,找到您想编辑的规则,并在其操作列选择 。
- 在编辑规则页面,您可以更新除规则ID以外的所有参数。
- 编辑完成后,在配置规则目标向导页面单击保存。
删除数据流入规则
- 在规则列表,找到您想删除的规则,并在其操作列选择 。
- 在弹出的提示对话框,单击确认。
启用流入规则
- 在规则列表,找到您想启用的规则,并在其操作列选择 。
- 在弹出的提示对话框,单击确认。
停用流入规则
- 在规则列表,找到您想停用的规则,并在其操作列选择 。
- 在弹出的提示对话框,单击确认。
相关文档
如需将客户端数据推送至其他阿里云产品,请参见数据流出规则管理。