Redis Source 用于支持DataFlow从Redis系统中加载Dataset。Redis的数据结构是 Key-Value,而Value 支持 String、List、ZSet、Hash 等多种格式。Redis Source支持Redis 的 String 和 Hash 两种类型的读取。当作为String类型读取时,需指定一列为Key,其值VALUE序列化应为JSON String 格式。当采用 Hash 读取时,指定一列key,Redis VALUE应为 Hash 类型,其他字段也从 Hash中读取。
xml
<source type="redis"
table_name="et_rel_pty_cong"
source_table_name="0"
columns_mapping="id,name1,cust_id,name,gender1,age1:int,age:int"
read_type="MAP"
host="${redis.host}"
port="${redis.port}"/>
配置说明:
- Source_table_name:为 redis db index,支持 0-16 之间的整数;
- columns_mapping:为 redis的列映射,如果存在key字段,则把key 字段作为 Redis KEY;否则会选择第一列作为 redis KEY。其他列则从redis VALUE 中获取。columns_mapping指定列的同时,也可指定列的类型,切分逻辑为 Field:type 。
- read_type:为指定从Redis 中读取的类型,支持 JSON、MAP两个值。