文档

云消息队列 MQTT 版

更新时间:
一键部署

本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息流入任务,将云消息队列 MQTT 版中的数据快速导入至云消息队列 RabbitMQ 版

前提条件

创建消息流入任务

  1. 登录云消息队列 RabbitMQ 版控制台,然后左侧导航栏选择消息集成 > 消息流入

  2. 在顶部菜单栏选择地域,如华东1(杭州),然后在消息流入页面,单击创建任务

  3. 消息流入创建面板,设置任务名称,选择流入类型微消息队列 MQTT版,配置以下信息,然后单击确定
    1. 资源配置区域,设置以下参数。
      表 1. 源端微消息队列MQTT版参数配置
      参数说明示例
      地域默认选择创建消息流入任务时选择的地域且不可更改。华东1(杭州)
      MQTT实例选择提前创建好的云消息队列 MQTT 版实例。mqtt-cn-******rtm03
      MQTT Topic选择云消息队列 MQTT 版实例中的Topic。testtopic
      表 2. 目标端消息队列RabbitMQ版参数配置
      参数说明示例
      地域选择接收源端数据的目标实例所在的地域。华东1(杭州)
      实例ID选择接收源端数据的目标云消息队列 RabbitMQ 版实例ID。amqp-cn-******03o002
      Vhost选择目标云消息队列 RabbitMQ 版实例的Vhost。test
      目标类型选择数据路由的目标类型。
      • Exchange:生产者向云消息队列 RabbitMQ 版发送消息时,不会直接将消息发送到Queue,而是先将消息发送到Exchange,由Exchange将消息路由到一个或多个Queue。
      • Queue:将消息直接路由至一个或多个Queue中。
      Exchange
      Exchange选择云消息队列 RabbitMQ 版的Exchange。

      仅当目标类型选择Exchange时需要设置。

      amq.topic
      Queue选择云消息队列 RabbitMQ 版的Queue。

      仅当目标类型选择Queue时需要设置。

      queue_test
    2. 数据处理区域,设置消息的过滤、转换、重试和死信。
      • 消息过滤
        • 无需过滤:默认投递全部事件。
        • 自定义配置:使用事件模式匹配特定事件。详细规则,请参见消息过滤
      • 消息转换
        • 默认配置:默认将消息内容或相关属性映射到目标端。映射关系,请参见默认配置映射关系
        • 自定义配置:根据自身需求配置自定义参数投递至目标端。
          参数说明示例
          Body需要投递的事件的消息内容。配置规则,请参见消息转换。则,请参见控制台提示。部分事件
          $.data.body
          Properties需要投递的事件的属性。配置规则,请参见消息转换部分事件
          $.data.props
          Keys需要投递的事件的过滤属性。配置规则,请参见消息转换部分事件
          $.data.systemProperties.KEYS
          Tags需要投递的事件的过滤属性。配置规则,请参见消息转换部分事件
          $.data.systemProperties.TAGS
      • 重试和死信:配置事件推送失败时的重试策略及错误发生时的处理方式。更多信息,请参见重试和死信
  4. 返回消息流入页面,找到创建好的任务,在其右侧操作列,单击启用
  5. 提示对话框,阅读提示信息,然后单击确认
    启用任务后,会有30秒~60秒的延迟时间,您可以在消息流入页面的状态栏查看启动进度。

其他操作

消息流入页面,找到目标任务,在其右侧操作列,执行其他操作。

  • 查看任务详情:单击详情,在消息流入详情页面,查看任务的源端配置、目标端配置及资源信息。
  • 编辑任务配置:单击编辑,在消息流入编辑面板,修改资源配置规则配置
  • 启停任务:单击启用或者停用,然后在提示对话框,单击确认
  • 删除任务:单击删除,然后在提示对话框,单击确认
  • 本页导读 (1)