Flink ＜--＞Redis的使用介绍+with参数

介绍

Redis Connector 提供了对 Redis 写入支持。

使用范围

可以作为 Tuple、Upsert 数据流的目的表。

示例

set 命令（字符串键）

-- 第1列为 key，第2列为 value。Redis 命令为 set key value CREATE TABLE `DataOutput` (  `key` STRING, `value` STRING ) WITH (  'connector' = 'redis',     -- 输出到 Redis  'command' = 'set',         -- set 命令  'nodes' = '<host>:<port>', -- redis 连接地址  'password' = '<password>',  'database' = '<database>'  );

lpush 命令（列表键）

-- 第1列为 key，第2列为 value。Redis 命令为 lpush key value CREATE TABLE `DataOutput` (  `key` STRING, `value` STRING ) WITH (  'connector' = 'redis',     -- 输出到 Redis  'command' = 'lpush',       -- lpush 命令  'nodes' = '<host>:<port>', -- redis 连接地址  'password' = '<password>',  'database' = '<database>'  );

sadd 命令（集合键）

-- 第1列为 key，第2列为 value。Redis 命令为 sadd key value CREATE TABLE `DataOutput` (  `key`   STRING, `value` STRING ) WITH ( 'connector' = 'redis',     -- 输出到 Redis 'command' = 'sadd',        -- sadd 命令 'nodes' = '<host>:<port>', -- redis 连接地址 'password' = '<password>', 'database' = '<database>'  );

hset 命令（哈希键）

-- 第1列为 hash_key，第2列为 hash_value。Redis 命令为 hset key hash_key hash_value。 CREATE TABLE `DataOutput` (  `hash_key`   STRING, `hash_value` STRING ) WITH ( 'connector' = 'redis',     -- 输出到 Redis 'command' = 'hset',        -- hset 命令 'nodes' = '<host>:<port>', -- redis 连接地址 'password' = '<password>', 'database' = '<database>', 'additional-key' = '<key>' -- 哈希键 );

zadd 命令（有序集合键）

-- 第1列为 hash_key，第2列为 hash_value。zadd key score value。 CREATE TABLE `DataOutput` (  `value` STRING, `score` DOUBLE ) WITH ( 'connector' = 'redis',     -- 输出到 Redis 'command' = 'zadd',        -- zadd 命令 'nodes' = '<host>:<port>', -- redis 连接地址 'password' = '<password>', 'database' = '<database>', 'additional-key' = '<key>' -- 有序集合键 );

通用 WITH 参数

参数值	必填	默认值	描述
connector	是	-	固定值为 redis
command	是	-	操作命令。取值与对应的键类型如下： set：字符串键 lpush：类别键 sadd：集合键 hset：哈希键 zadd：有序集合键
nodes	是	-	redis server 连接地址，示例：127.0.0.1:6379。集群架构下多个节点使用','分隔
password	否	空	redis 密码，默认值为空，不进行权限验证
database	否	0	要操作的数据库的 DB number，默认值0
redis-mode	否	standalone	redis 部署模式 standalone：标准架构，单机 cluster：集群架构，分布式
ignore-delete	否	false	是否忽略 Retraction 消息
additional-ttl	否	-	过期时间，单位：秒。示例：60，设置过期是时间为60秒。只有 set 命令支持设置过期时间
additional-key	-	-	用于指定 hset 和 zadd 的 key。执行 hset 和 zadd 命令时必须设置

赞