数据传输服务DTS

开服地域

在消息集成中创建消息流入任务时，支持将数据传输服务DTS作为消息流入任务源端的地域有华东1（杭州）、华东2（上海）、华北1（青岛）、华北2（北京）、华南1（深圳）、华南3（广州）、西南1（成都）和中国香港。

创建消息流入任务

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

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

3. 在消息流入创建面板，设置任务名称，选择流入类型为数据库 DTS，配置以下信息，然后单击确定。
   1. 在资源配置区域，设置以下参数。

      表 1. 源端数据传输服务DTS参数配置

      参数	说明	示例
      地域	默认选择创建消息流入任务时选择的地域。	华东1（杭州）
      数据订阅任务	选择您在数据传输服务DTS控制台上创建的数据订阅任务ID。	dts8jqe****
      接入方式	默认为创建的数据订阅任务的接入方式且不可更改。	RDS
      实例ID	默认为创建数据订阅任务时订阅的实例且不可更改。	dtso6m11cxt26q****
      消费组	在前提条件中创建的用于消费订阅任务数据的消费组名称。 重要 请确保该消费组没有在其他客户端的实例上运行，否则可能导致传入的消费位点失效。	test
      账号	创建消费组时设置的账号。	username
      密码	创建消费组时设置的密码。	******
      消费位点	期望消费第一条数据的时间戳。消费位点必须在订阅实例的数据范围之内。 说明 消费位点仅在新消费组第一次运行时生效，若后续任务重启，则会基于上次消费位点继续消费。	2022-08-11 00:00:00

      表 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秒的延迟时间，您可以在消息流入页面的状态栏查看启动进度。

其他操作

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

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