Redis

Redis sink connector

Description

Write Rows to a Redis.

提示

Engine Supported and plugin name

• Spark: Redis
• Flink

Options

name	type	required	default value
host	string	no	"localhost"
port	int	no	6379
auth	string	no
db_num	int	no	0
data_type	string	no	"KV"
hash_name	string	no
list_name	string	no
set_name	string	no
zset_name	string	no
timeout	int	no	2000
ttl	int	no	0
is_self_achieved	boolean	no	false

host [string]

Redis server address, default "localhost"

port [int]

Redis service port, default 6379

auth [string]

Redis authentication password

db_num [int]

Redis database index ID. It is connected to db 0 by default

redis_timeout [int]

Redis timeout

data_type [string]

Redis data type eg: KV HASH LIST SET ZSET

hash_name [string]

if redis data type is HASH must config hash name

list_name [string]

if redis data type is LIST must config list name

zset_name [string]

if redis data type is ZSET must config zset name

set_name [string]

if redis data type is SET must config set name

ttl [int]

redis data expiration ttl, 0 means no expiration.

is_self_achieved [boolean]

If a redis access by a self-achieved redis proxy, which is not support redis function of "info Replication"

Examples

redis {
  host = "localhost"
  port = 6379
  auth = "myPassword"
  db_num = 1
  data_type = "HASH"
  hash_name = "test"
  is_self_achieved = false
}