跳到主要内容
版本：Next

Redis

Redis 源连接器

描述​

用于从 Redis 读取数据

主要功能​

配置选项​

名称类型是否必须默认值
hoststringmode=single时必须-
portint否6379
keysstring是-
batch_sizeint是10
data_typestring是-
userstring否-
authstring否-
db_numint否0
modestring否single
hash_key_parse_modestring否all
nodeslistmode=cluster 时必须-
schemaconfigformat=json 时必须-
formatstring否json
common-options否-

host [string]​

redis 主机地址

port [int]​

redis 端口号

hash_key_parse_mode [string]​

指定 hash key 解析模式, 支持 all kv 模式, 用于设定连接器如何解析 hash key。

当设定为 all 时，连接器会将 hash key 的值视为一行并根据 schema config 配置进行解析，当设定为 kv 时，连接器会将 hash key 的每个 kv 视为一行，并根据 schema config 进行解析。

例如，如果 hash key 的值如下设置：

{ 
  "001": {
    "name": "tyrantlucifer",
    "age": 26
  },
  "002": {
    "name": "Zongwen",
    "age": 26
  }
}

如果 hash_key_parse_mode 设置为 all 模式，且 schema config 如下所示，将会生成下表数据：

schema {
  fields {
    001 {
      name = string
      age = int
    }
    002 {
      name = string
      age = int
    }
  }
}

001002
Row(name=tyrantlucifer, age=26)Row(name=Zongwen, age=26)

如果 hash_key_parse_mode 设置为 kv 模式，且 schema config 如下所示，将会生成下表数据：

schema {
  fields {
    hash_key = string
    name = string
    age = int
  }
}

hash_keynameage
001tyrantlucifer26
002Zongwen26

hash key 中的每个 kv 将会被视为一行并被发送给上游。

提示：连接器将使用 scheme config 的第一个字段信息作为每个 kv 中每个 k 的字段名称

keys [string]​

keys 模式

batch_size [int]​

表示每次迭代尝试返回的键的数量，默认值为 10。

提示：Redis 连接器支持模糊键匹配，用户需要确保匹配的键类型相同

data_type [string]​

redis 数据类型, 支持 key hash list set zset。

  • key

将每个 key 的值将作为单行数据发送给下游。
例如，key 对应的值为 SeaTunnel test message，则下游接收到的数据为 SeaTunnel test message，并且仅会收到一条信息。

  • hash

hash 键值对将会被格式化为 json，并以单行数据的形式发送给下游。
例如，hash 值为 name:tyrantlucifer age:26，则下游接收到的数据为 {"name":"tyrantlucifer", "age":"26"}，并且仅会收到一条信息。

  • list

list 中的每个元素都将作为单行数据向下游发送。
例如，list 值为 [tyrantlucier, CalvinKirs]，则下游接收到的数据为 tyrantlucifer 和 CalvinKirs，并且仅会收到两条信息。

  • set

set 中的每个元素都将作为单行数据向下游发送。
例如，set 值为 [tyrantlucier, CalvinKirs]，则下游接收到的数据为 tyrantlucifer 和 CalvinKirs，并且仅会收到两条信息。

  • zset

zset 中的每个元素都将作为单行数据向下游发送。
例如，zset 值为 [tyrantlucier, CalvinKirs]，则下游接收到的数据为 tyrantlucifer 和 CalvinKirs，并且仅会收到两条信息。

user [string]​

Redis 认证身份用户，当连接到加密集群时需要使用

auth [string]​

Redis 认证密钥，当连接到加密集群时需要使用

db_num [int]​

Redis 数据库索引 ID，默认将连接到 db 0

mode [string]​

Redis 模式，single 或 cluster，默认值为 single

nodes [list]​

Redis 节点信息，在 cluster 模式下使用，必须设置为以下格式：

["host1:port1", "host2:port2"]

format [string]​

上游数据格式，目前仅支持 json text，默认为 json

当指定格式为 json 时，还需要指定 scheme option，例如：

当上游数据如下时：

{"code":  200, "data":  "get success", "success":  true}

需要指定 schema 为如下配置：

schema {
    fields {
        code = int
        data = string
        success = boolean
    }
}

连接器将会生成如下格式数据：

codedatasuccess
200get successtrue

当指定格式为 text 时，连接器不会对上游数据做任何处理，例如：

当上游数据如下时：

{"code":  200, "data":  "get success", "success":  true}

连接器将会生成如下格式数据：

content
{"code": 200, "data": "get success", "success": true}

schema [config]​

fields [config]​

Redis 数据的 schema 字段列表

common options​

源连接器插件通用参数，详情请参见 Source Common Options

示例​

简单使用示例：

Redis {
  host = localhost
  port = 6379
  keys = "key_test*"
  data_type = key
  format = text
}
Redis {
  host = localhost
  port = 6379
  keys = "key_test*"
  data_type = key
  format = json
  schema {
    fields {
      name = string
      age = int
    }
  }
}

读取 string 类型并附加到 list 示例：

source {
  Redis {
    host = "redis-e2e"
    port = 6379
    auth = "U2VhVHVubmVs"
    keys = "string_test*"
    data_type = string
    batch_size = 33
  }
}

sink {
  Redis {
    host = "redis-e2e"
    port = 6379
    auth = "U2VhVHVubmVs"
    key = "string_test_list"
    data_type = list
    batch_size = 33
  }
}

变更日志​

Change Log
ChangeCommitVersion
[Improve][Redis] Optimized Redis connection params (#8841)https://github.com/apache/seatunnel/commit/e56f06cdf0dev
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6eebdev
[improve] update Redis connector config option (#8631)https://github.com/apache/seatunnel/commit/f1c313eea6dev
[Feature][Redis] Flush data when the time reaches checkpoint.interval and update test case (#8308)https://github.com/apache/seatunnel/commit/e15757bcd72.3.9
Revert "[Feature][Redis] Flush data when the time reaches checkpoint interval" and "[Feature][CDC] Add 'schema-changes.enabled' options" (#8278)https://github.com/apache/seatunnel/commit/fcb29382862.3.9
[Feature][Redis] Flush data when the time reaches checkpoint.interval (#8198)https://github.com/apache/seatunnel/commit/2e24941e6a2.3.9
[Hotfix] Fix redis sink NPE (#8171)https://github.com/apache/seatunnel/commit/6b9074e7692.3.9
[Improve][dist]add shade check rule (#8136)https://github.com/apache/seatunnel/commit/51ef8000162.3.9
[Feature][Connector-Redis] Redis connector support delete data (#7994)https://github.com/apache/seatunnel/commit/02a35c39792.3.9
[Improve][Connector-V2] Redis support custom key and value (#7888)https://github.com/apache/seatunnel/commit/ef2c3c72832.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d03c2.3.9
[improve][Redis]Redis scan command supports versions 5, 6, 7 (#7666)https://github.com/apache/seatunnel/commit/6e70cbe3342.3.8
[Improve][Connector] Add multi-table sink option check (#7360)https://github.com/apache/seatunnel/commit/2489f6446b2.3.7
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131)https://github.com/apache/seatunnel/commit/c4ca74122c2.3.6
[Improve][Redis] Redis reader use scan cammnd instead of keys, single mode reader/writer support batch (#7087)https://github.com/apache/seatunnel/commit/be37f05c072.3.6
[Feature][Kafka] Support multi-table source read (#5992)https://github.com/apache/seatunnel/commit/60104602d12.3.6
[Improve][Connector-V2]Support multi-table sink feature for redis (#6314)https://github.com/apache/seatunnel/commit/fed89ae3fc2.3.5
[Feature][Core] Upgrade flink source translation (#5100)https://github.com/apache/seatunnel/commit/5aabb14a942.3.4
[Feature][Connector-V2] Support TableSourceFactory/TableSinkFactory on redis (#5901)https://github.com/apache/seatunnel/commit/e84dcb8c102.3.4
[Improve][Common] Introduce new error define rule (#5793)https://github.com/apache/seatunnel/commit/9d1b2582b22.3.4
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de74081002.3.4
[Improve][Connector-v2][Redis] Redis support select db (#5570)https://github.com/apache/seatunnel/commit/77fbbbd0ee2.3.4
Support config column/primaryKey/constraintKey in schema (#5564)https://github.com/apache/seatunnel/commit/eac76b4e502.3.4
[Feature][Connector-v2][RedisSink]Support redis to set expiration time. (#4975)https://github.com/apache/seatunnel/commit/b5321ff1d22.3.3
Merge branch 'dev' into merge/cdchttps://github.com/apache/seatunnel/commit/4324ee19122.3.1
[Improve][Project] Code format with spotless plugin.https://github.com/apache/seatunnel/commit/423b5830382.3.1
[improve][api] Refactoring schema parse (#4157)https://github.com/apache/seatunnel/commit/b2f573a13e2.3.1
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd6010512.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab1665612.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb842.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Improve][Connector-V2][Redis] Unified exception for redis source & sink exception (#3517)https://github.com/apache/seatunnel/commit/205f7825852.3.0
options in conditional need add to required or optional options (#3501)https://github.com/apache/seatunnel/commit/51d5bcba102.3.0
[feature][api] add option validation for the ReadonlyConfig (#3417)https://github.com/apache/seatunnel/commit/4f824fea362.3.0
[Feature][Redis Connector V2] Add Redis Connector Option Rules & Improve Redis Connector doc (#3320)https://github.com/apache/seatunnel/commit/1c10aacb302.3.0
[Connector-V2][ElasticSearch] Add ElasticSearch Source/Sink Factory (#3325)https://github.com/apache/seatunnel/commit/38254e3f262.3.0
[Improve][Connector-V2][Redis] Support redis cluster connection & user authentication (#3188)https://github.com/apache/seatunnel/commit/c7275a49cc2.3.0
[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton pattern (#2706)https://github.com/apache/seatunnel/commit/cbf82f755c2.2.0-beta
[Feature][Connector-V2] Add redis sink connector (#2647)https://github.com/apache/seatunnel/commit/71a9e4b0192.2.0-beta
[#2606]Dependency management split (#2630)https://github.com/apache/seatunnel/commit/fc047be69b2.2.0-beta
[Feature][Connector-V2] Add redis source connector (#2569)https://github.com/apache/seatunnel/commit/405f7d6f992.2.0-beta