应用与数据集成平台 ROMA CONNECT-配置目标端数据信息:Redis

时间：2024-11-08 14:31:36

Redis

返回页首

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

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

**表24** 目标端Redis信息
参数	配置说明
目标端实例	配置为当前正在使用的ROMA Connect实例，源端实例配置后目标端自动关联，无需配置。
目标端集成应用	选择Redis数据源所属的集成应用，在接入数据源时已配置。
目标端数据类型	选择“Redis”。
数据源名称	选择接入数据源中已配置的Redis数据源。
key前缀	填写Redis数据源中存储待集成数据的key名称前缀，“key前缀”+“分隔符”+“key后缀字段”组成Redis数据源中的key名称，每一行数据作为key的value存储到Redis中。具体key格式请参考key和value格式说明。
key后缀字段	选择源端数据中值不允许重复的字段作为key后缀，“key前缀”+“分隔符”+“key后缀字段”组成Redis数据源中的key名称，如此可以确保每一行数据都能被集成到Redis数据源的不同key中。 “数据类型”选择“List”、“Set”或“ZSet”时，“key后缀字段”可以为空，即只由“key前缀”生成一个key，此时所有数据行作为元素被集成到Redis数据源的同一个key中。
分隔符	仅当“key后缀字段”不为空时需要配置。填写“key前缀”与“key后缀字段”之间的分隔符，“key前缀”+“分隔符”+“key后缀字段”组成Redis数据源中的key名称。
数据类型	选择Redis数据源中key的数据类型。支持以下类型： String List Map Set ZSet
List追加方式	仅当“数据类型”选择“List”时需要配置。选择List类型key的数据追加写入方式。 lpush：表示当前数据插入到List的头部。 rpush：表示当前数据插入到List的尾部。
sortColumn	仅当“数据类型”选择“ZSet”时需要配置。选择使用源端哪一个数据字段进行数据元素的排序。
失效时间（秒）	Redis数据源中key的失效时间，0表示永不失效。
写入格式	仅当“数据类型”选择“String”、“List”、“Set”或“ZSet”时需要配置，“数据类型”选择“Map”时默认为JSON格式。选择待集成数据写入Redis数据源的数据格式，可选择“JSON”和“CUSTOMIZE”。
元数据	定义写入到目标端key的value格式。源端有多少个字段需要集成，则目标端需要定义相同个数的元数据。别名：对元数据的自定义名称。类型：元数据的数据类型，需要与源端数据中对应字段的数据类型一致。若“写入格式”为“JSON”，则元数据以JSON格式在Redis数据源中作为key的value存储。若“写入格式”为“CUSTOMIZE”，则自定义目标端value的拼接格式，全部元数据与拼接前缀、拼接后缀进行拼接，并在Redis数据源中作为key的value存储。具体value格式请参考key和value格式说明。

key和value格式说明：

假设有如下源端数据，目标端信息中“key前缀”设置为“roma”，选择源数据的唯一键“aaa”字段作为“key后缀字段”，确保key名称不重复，并设置“|”作为key前缀与后缀的分隔符。

+-------+-------+
|  aaa  |  bbb  |
+-------+-------+
|   1   |   x   |
|   2   |   y   |
|   3   |   z   |
+-------+-------+

若“数据类型”为“String”，“写入格式”为“JSON”，元数据配置如图9所示，则写入到Redis数据源中的key和value如下。
```
 key               value
--------------------------------
roma|1     "{"bbb":"x","aaa":1}"
roma|2     "{"bbb":"y","aaa":2}"
roma|3     "{"bbb":"z","aaa":3}"
```
图9 元数据配置（JSON）
若“数据类型”为“String”，“写入格式”为“CUSTOMIZE”，元数据配置如图10所示，则写入到Redis数据源中的key和value如下。
```
 key           value
------------------------
roma|1     "bbb_x&aaa_1"
roma|2     "bbb_y&aaa_2"
roma|3     "bbb_z&aaa_3"
```
图10 元数据配置（CUSTOMIZE）