flinksql读写redis( 六 )

5、配置说明配置项描述hostredis的hostportredis的portpasswordredis的passwordcluster-nodesredis的集群节点,ip和端口之间用英文冒号分隔,多个ip端口用英文逗号分割master.nameredis的sentinel模式的master节点的名称sentinels.inforedis的sentinel模式的info信息sentinels.passwordredis的sentinel模式的密码databaseredis的database,一般是0~15commandredis的命令,作为流表时支持BLPOP、BRPOP、LPOP、RPOP、SPOP;作为维表时支持GET、HGET;作为sink表时支持LPUSH、RPUSH、SADD、SET、HSETredis-moderedis的部署模式,single、cluster、sentinelkeyredis需要访问的key,比如数据是以某个固定的key存放在redis里,值是一个list;redis执行lpush、rpush、sadd、hset等sink使用的命令时的key;timeout连接redis的超时时间,单位毫秒max-total连接redis的连接池的最大连接数max-idle连接redis的连接池的最大空闲数min-idle连接redis的连接池的最小空闲数format格式化数据格式,如json、csvbatch-fetch-rows像LPOP、BLPOP、RPOP、BRPOP这种命令每次从redis拿到数据的条数lookup.cache.max-rows作为维表lookup模式,缓存在内存中的数据的最大条数lookup.cache.ttl作为维表lookup模式,缓存在内存中的数据的ttl超时时间,单位秒lookup.max-retries作为维表lookup模式,查找数据的失败重试次数lookup.cache.load-all作为维表lookup模式,查找数据是否加载所有,主要是针对hget命令,如:HGET KEY_NAME FIELD_NAME;是否根据key查出所有field的值,这里可以根据实际hash表的大小决定是否要查询所有出来缓存起来sink.max-retriesredis作为sink源时,最大重试次数sink.parallelismredis作为sink源时,sink的并行数,默认并行度为核心数sink.key.ttlredis作为sink源时,sink的数据保存在redis的ttl超时时间,单位秒,默认为-1表示长期保存lookup.max-retries作为维表lookup模式,查找数据的失败重试次数源码地址:https://gitee.com/rongdi/flinksql-connector-redis/

经验总结扩展阅读