配置目标端数据信息_应用与数据集成平台 ROMA Connect

本节主要提供数据集成任务目标端信息的配置说明。目标端信息用于告诉ROMA Connect如何将待集成的数据写入到目标端，包括数据源、数据存储信息等。对于不同的数据源类型，其目标端信息配置有所差异。

数据迁移过程中若目标端数据存在主键冲突，则根据主键自动更新数据。

支持“定时&实时”模式的目标端数据类型		仅支持“定时”模式的目标端数据类型
API ActiveMQ ArtemisMQ DB2 DIS DWS DM Gauss100 HL7 HANA IBM MQ Kafka	MySQL MongoDB MQS MRS Hive MRS HDFS MRS HBase MRS Kafka Oracle PostgreSQL Redis RocketMQ RabbitMQ SQL Server GaussDB(for MySQL) 自定义数据源	FTP OBS

任务的“集成模式”为“定时”或“实时”时，可以选择API作为目标端数据源。

在创建任务页面中配置目标端信息。

表1 目标端API信息
参数	配置说明
目标端实例	配置为当前正在使用的ROMA Connect实例，源端实例配置后目标端自动关联，无需配置。
目标端集成应用	选择API数据源所属的集成应用，在接入数据源时已配置。
目标端数据类型	选择“API”。
数据源名称	选择接入数据源中已配置的API数据源。
请求参数	构造API请求的参数定义，例如要集成到目标端的数据，需要在Body中携带。请根据API数据源的定义如实填写。 Params：请求URL中问号后面定义的参数，只能对参数传递固定值。Params参数的填写跟Body参数的form-data方式类似。 Headers：RESTful请求的消息头参数，只能对参数传递固定值。Headers参数的填写跟Body参数的form-data方式类似。 Body：RESTful请求消息体的底层参数，与“数据根字段”组成发给目标端API的Body消息体，源端数据通过Body参数传递到目标端。Body支持“form-data”和“raw”两种形式，具体请参见Body参数配置说明。
数据根字段	发送到目标端的JSON格式Body消息体中，参数字段集上层公共字段的路径。“数据根字段”与“请求参数”中配置的Body参数组成发给目标端API的Body消息体。例如Body参数为：{"c":"xx","d":"xx"}，数据根字段定义a.b，则封装后的请求数据为{"a":{"b":{"c":"xx","d":"xx"}}}。

Body参数配置说明：

form-data方式：
“键”填写为API数据源定义的Body参数名称，“键”的值设置为空。“键”在Mapping信息中作为“目标字段名”，以此映射和传递源端字段的值。

图1 form-data方式
raw方式：
raw方式持JSON、Array和嵌套JSON格式。填写发送给目标端API的JSON格式Body示例，ROMA Connect根据示例以及Mapping映射配置，替换示例中参数的值，最终将源端数据传递给目标端。raw方式的Body示例如下。
- JSON格式：
```
{
	"id": 1,
	"name": "name1"
}
```
  Body填写JSON，数据根字段无需写值，Mapping信息填写字段名。
- Array格式：
```
{
	"record":[
		{
			"id": 1,
			"name": ""
		}
	]
}
```
  数据根字段写入JSONArray对象名，例如：record。Mapping信息填写字段名。
- 嵌套JSON格式：
```
{
	"startDate":"",
	"record":[
		{
			"id": 1,
			"name": ""
		}
	]
}
```
  数据根字段无需填写值，Mapping信息中，json字段直接填写字段名，jsonArray中的字段填写具体路径，例如：record[0].id

表2 目标端ActiveMQ信息
参数	配置说明
目标端实例	配置为当前正在使用的ROMA Connect实例，源端实例配置后目标端自动关联，无需配置。
目标端集成应用	选择ActiveMQ数据源所属的集成应用，在接入数据源时已配置。
目标端数据类型	选择“ActiveMQ”。
数据源名称	选择接入数据源中已配置的ActiveMQ数据源。
目标端类型	选择ActiveMQ数据源的消息传递模型，可选择“Topic”和“Queue”。
目标端名称	填写待集成数据要发送到的Topic或Queue名称，请确保该Topic或Queue已存在。
元数据	定义写入到目标端的JSON格式数据中，每一个底层key-value型数据元素。源端有多少个字段需要集成，则目标端需要定义相同个数的元数据。别名：对元数据的自定义名称。类型：元数据的数据类型，需要与源端数据中对应字段的数据类型一致。解析路径：元数据的完整路径，具体请参见元数据解析路径配置说明。

表3 目标端ArtemisMQ信息
参数	配置说明
目标端实例	配置为当前正在使用的ROMA Connect实例，源端实例配置后目标端自动关联，无需配置。
目标端集成应用	选择ArtemisMQ数据源所属的集成应用，在接入数据源时已配置。
目标端数据类型	选择“ArtemisMQ”。
数据源名称	选择接入数据源中已配置的ArtemisMQ数据源。
目标端类型	选择ArtemisMQ数据源的消息传递模型，可选择“Topic”和“Queue”。
目标端名称	填写待集成数据要发送到的Topic或Queue名称，请确保该Topic或Queue已存在。
元数据	定义写入到目标端的JSON格式数据中，每一个底层key-value型数据元素。源端有多少个字段需要集成，则目标端需要定义相同个数的元数据。别名：对元数据的自定义名称。类型：元数据的数据类型，需要与源端数据中对应字段的数据类型一致。解析路径：元数据的完整路径，具体请参见元数据解析路径配置说明。

表4 目标端DB2信息
参数	配置说明
目标端实例	配置为当前正在使用的ROMA Connect实例，源端实例配置后目标端自动关联，无需配置。
目标端集成应用	选择DB2数据源所属的集成应用，在接入数据源时已配置。
目标端数据类型	选择“DB2”。
数据源名称	选择接入数据源中已配置的DB2数据源。
目标端表	选择待集成数据要写入的数据表。选择数据表后，单击“选择表字段”，可以选择只需要写入的数据列字段。
批次号字段	选择目标表中类型为string并且字段长度大于14的字段作为批次号字段，且该批次号字段不能和Mapping信息中的目标字段重复。该字段值将为一个随机数，用来标识同一批次的数据，同一批次插入的数据具有相同的批次号，表示这些数据是同一批次插入的，可以用来定位或者解析回滚。
批次号格式	批次号格式支持yyyyMMddHHmmss和UUID，yyyyMMddHHmmss可能会有重复，请尽可能使用UUID以确保唯一性。

表6 目标端DWS信息
参数	配置说明
目标端实例	配置为当前正在使用的ROMA Connect实例，源端实例配置后目标端自动关联，无需配置。
目标端集成应用	选择DWS数据源所属的集成应用，在接入数据源时已配置。
目标端数据类型	选择“DWS”。
数据源名称	选择接入数据源中已配置的DWS数据源。
目标端表	选择待集成数据要写入的数据表。选择数据表后，单击“选择表字段”，可以选择只需要写入的数据表字段。
批次号字段	选择目标表中类型为string并且字段长度大于14的字段作为批次号字段，且该批次号字段不能和Mapping信息中的目标字段重复。该字段值将为一个随机数，用来标识同一批次的数据，同一批次插入的数据具有相同的批次号，表示这些数据是同一批次插入的，可以用来定位或者解析回滚。
批次号格式	批次号格式支持yyyyMMddHHmmss和UUID，yyyyMMddHHmmss可能会有重复，请尽可能使用UUID以确保唯一性。
是否清空表	每次调度任务时是否先清空目标表。

配置目标端数据信息