Redis Input Connector


链接库路径为'RedisInputConnector'。 默认ID为'redisin'。 支持参数:

  • hosts: (必需提供) STRING格式。 集群的主机名或区域(以' - '表示),多主机名或区域以逗号分隔。如: node1, 10.5.3.2, node2 - node19, node20.acme.com - node99.acme.com, 10.5.3.3 - 10.5.3.99。
  • database: (必需提供) INT格式。 数据库的ID。默认值为 0。
  • password: (必需提供) STRING格式。 数据库的密码。
  • key_scan_pattern: (非必需) STRING格式。 以key名模式过滤数据。(例: mytable.*)。
  • key_content_pattern: (非必需) STRING格式。 从key内容模式里摘取列名。(例:mytable.*(\d+))。
  • value_type: (非必需) STRING格式。 读入value的格式。支持格式包括 'hash' 和 'string'。 默认值为'hash'。
  • port: (非必需) INT格式。 连接的端口。默认值为6379。
  • batch_size: (非必需) INT格式。 每批写出的最大数据行数。默认值为80000。
  • connection_timeout: (非必需) INT格式。 最大连接超时等待限制(秒)。默认值为60。
  • password_decrypt_class: (非必需) STRING格式。 解密密码的class名。
  • include_key_in_dynamic_schema: (非必需) BOOLEAN格式。 是否在非结构化schema里带入key。默认值为TRUE。