消息服务MNS

开服地域

在消息集成中创建消息流入任务时，支持将消息服务MNS作为消息流入任务源端的地域有华东1（杭州）、华东2（上海）、华北1（青岛）、华北2（北京）、华北3（张家口）、华北5（呼和浩特）、华北6（乌兰察布）、华南1（深圳）、西南1（成都）、华南2（河源）、华南3（广州）、中国香港、美国（硅谷）、美国（弗吉尼亚）、德国（法兰克福）、新加坡、日本（东京）、马来西亚（吉隆坡）和印度尼西亚（雅加达）。

创建消息流入任务

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

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

3. 在创建任务面板，设置任务名称和描述，配置以下参数。

   • 任务创建

     1. 在Source（源）配置向导，选择数据提供方为消息服务MNS，设置以下参数，然后单击下一步。

        参数	说明	示例
        队列名称	选择MNS的队列。	test-queue
        Base64 解码	勾选此项会帮助您将MNS的数据解码后进行投递。	test
        批量推送条数	调用函数发送的最大批量消息条数，当积压的消息数量到达设定值时才会发送请求，取值范围为 [1,10000]。	100
        批量推送间隔（单位：秒）	调用函数的间隔时间，系统每到间隔时间点会将消息聚合后发给函数计算，取值范围为[0,15]，单位为秒。0秒表示无等待时间，直接投递。	3

     2. 在Filtering（过滤）配置向导，定义数据模式过滤发送的请求。更多信息，请参见消息过滤。

     3. 在Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见使用函数计算实现消息数据清洗。

     4. 在Sink（目标）配置向导，选择服务类型为消息队列 RocketMQ 版，配置以下参数。

        参数	说明	示例
        版本	选择云消息队列 RocketMQ 版实例的版本。 RocketMQ 4.x：服务端4.x版本。 RocketMQ 5.x：服务端5.x版本。	RocketMQ 5.x
        实例ID	选择云消息队列 RocketMQ 版消息的目标实例。	rmq-cn-****
        Topic	选择目标实例的Topic。	topic
        消息体（body）	完整数据。 数据提取。 固定值。 模板。	数据提取 $.data.body
        自定义属性（Properties）	空。 数据提取。 模板。	模板 变量： { "userProperties":"$.data.userProperties", "msgId":"$.data.systemProperties.UNIQ_KEY" } 模板： { "EB_SYS_EMBED_OBJECT":"${userProperties}", "UNIQ_KEY":"${msgId}" }
        消息索引（Keys）	空。 数据提取。 固定值。 模板。	数据提取 $.data.systemProperties.KEYS
        消息标签（Tags）	空。 数据提取。 固定值。 模板。	数据提取 $.data.systemProperties.TAGS

   • 任务属性

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

4. 完成上述配置后，单击保存。在任务列表页面，找到刚创建的任务，此时状态栏为启动中，当状态变为运行中时，任务创建成功。

其他操作