文档

云消息队列 RocketMQ 版

更新时间:
一键部署

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

前提条件

创建消息流入任务

  1. 登录云消息队列 RabbitMQ 版控制台,在左侧导航栏选择消息集成 > 任务列表

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

  3. 创建任务面板,设置任务名称描述,配置以下参数,单击保存

    • 任务创建

      1. Source(源)配置向导,选择数据提供方消息队列RocketMQ版,设置以下参数,然后单击下一步

        参数

        说明

        示例

        地域

        默认选择创建消息流入任务时选择的地域且不可更改。

        华东1(杭州)

        版本

        选择云消息队列 RocketMQ 版实例的版本。

        • RocketMQ 4.x:服务端4.x版本。

        • RocketMQ 5.x:服务端5.x版本。

        RocketMQ5.x

        RocketMQ 实例

        选择生产消息的源云消息队列 RocketMQ 版实例。

        MQ_INST_115964845466****_ByBeUp3p

        Topic

        选择生产消息的源Topic。

        topic

        Tag

        云消息队列 RocketMQ 版中用于过滤消息的标签。

        test_tag

        Group ID

        • 快速创建:自动创建以GID_EVENTBRIDGE_xxx 命名的Group ID。

        • 使用已有:选择源实例中的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。

        GID_http_1

        消费位点

        选择开始消费消息的位点。

        • 最新位点:从最新位点开始消费。

        • 最早位点:从最初位点开始消费。

        • 指定时间戳:从指定时间开始消费。

        最新位点

        批量推送条数

        调用函数发送的最大批量消息条数,当积压的消息数量到达设定值时才会发送请求,取值范围为 [1,10000]。

        100

        批量推送间隔(单位:秒)

        调用函数的间隔时间,系统每到间隔时间点会将消息聚合后发给函数计算,取值范围为[0,15],单位为秒。0秒表示无等待时间,直接投递。

        3

      2. Filtering(过滤)配置向导,设置数据模式内容过滤发送的请求。更多信息,请参见消息过滤

      3. Transform(转换)配置向导,设置数据清洗,实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息,请参见数据清洗

      4. Sink(目标)配置向导,选择服务类型消息队列 RabbitMQ 版,配置以下参数。

        参数

        说明

        示例

        实例ID

        选择已创建的云消息队列 RabbitMQ 版实例。

        amqp-cn-zvp2pny6****

        Vhost

        选择已创建的Vhost。

        test

        目标类型

        • Exchange:生产者将消息发送到Exchange,由Exchange将消息路由到一个或多个Queue中。

        • Queue:每个消息都会被投入到一个或多个Queue里。

        Queue 模式

        Exchange

        目标类型Exchange时,选择云消息队列 RabbitMQ 版中的Exchange。

        exchange

        Queue

        目标类型Queue时,选择云消息队列 RabbitMQ 版中的选择接收消息的队列。

        queue

        消息路由规则(Routing Key)

        事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。当目标类型Exchange时需要配置。

        数据提取

        $.data.key

        消息体(body)

        事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。

        数据提取

        $.data.body

        MessageId

        事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。

        数据提取

        $.data.props.messageId

        自定义属性(Properties)

        事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。

        数据提取

        $.data.props
    • 任务属性

      配置事件推送失败时的重试策略及错误发生时的处理方式。更多信息,请参见重试和死信

其他操作

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

  • 查看任务详情:单击详情,在消息流入详情页面,查看任务的源端配置、目标端配置及资源信息。

  • 编辑任务配置:单击编辑,在消息流入编辑面板,修改资源配置规则配置

  • 启停任务:单击启用或者停用,然后在提示对话框,单击确认

  • 删除任务:单击删除,然后在提示对话框,单击确认