Redis 数据集成配置文件

Redis 数据集成配置文件参考

属性

名称	类型	描述	是否必需
sources (源收集器)	`object`
processors (Redis 数据集成处理器的配置详情)	`object`, `null`
targets (目标连接)	`object`

sources: 源收集器

附加属性

名称	类型	描述	是否必需

processors: Redis 数据集成处理器的配置详情

属性

名称	类型	描述	是否必需
on_failed_retry_interval (失败时重试的间隔时间（以秒为单位）)	`integer`, `string`	默认值: `5` 模式: `^\${.*}$` 最小值: `1`
read_batch_size (从源数据库读取数据的批量大小)	`integer`, `string`	默认值: `2000` 模式: `^\${.*}$` 最小值: `1`
debezium_lob_encoded_placeholder (启用 Debezium LOB 占位符)	`string`	默认值: `"X19kZWJleml1bV91bmF2YWlsYWJsZV92YWx1ZQ=="`
dedup (启用去重机制)	`boolean`	默认值: `false`
dedup_max_size （去重集合的最大大小）	`integer`	默认值：`1024` 最小值：`1`
dedup_strategy (去重策略: reject - 拒绝消息(dlq), ignore - 忽略消息)	`string`	(已弃用) 属性 'dedup_strategy' 现已弃用。唯一支持的策略是 'ignore'。请从配置中移除。默认值: `"ignore"` 枚举: `"reject"`, `"ignore"`
duration (时间（以毫秒为单位），即使未达到read_batch_size，也会从流中读取数据)	`integer`, `string`	默认值: `100` 模式: `^\${.*}$` 最小值: `1`
write_batch_size (写入目标Redis数据库的数据批次大小。应小于或等于read_batch_size)	`integer`, `string`	默认值: `200` 模式: `^\${.*}$` 最小值: `1`
error_handling (错误处理策略：ignore - 跳过，dlq - 将拒绝的消息存储在死信队列中)	`string`	默认值：`"dlq"` 模式：``^${.*}$	ignore
dlq_max_messages (死信队列每个流的最大消息数)	`integer`, `string`	默认值: `1000` 模式: `^\${.*}$` 最小值: `1`
target_data_type (目标数据类型：hash/json - 目标数据库必须使用RedisJSON模块)	`string`	默认值：`"hash"` 模式：``^${.*}$	hash
json_update_strategy (目标更新策略：替换/合并 - 目标数据库必须使用RedisJSON模块)	`string`	(已弃用) 属性'json_update_strategy'将在未来的版本中弃用。使用'on_update'作业级别属性来定义json更新策略。默认值：`"replace"` 模式：``^${.*}$	replace
initial_sync_processes (RDI引擎创建的用于处理与源的初始同步的进程数)	`integer`, `string`	默认值: `4` 模式: `^\${.*}$` 最小值: `1` 最大值: `32`
idle_sleep_time_ms (批次之间的空闲睡眠时间（以毫秒为单位）)	`integer`, `string`	默认值: `200` 模式: `^\${.*}$` 最小值: `1` 最大值: `999999`
idle_streams_check_interval_ms (当流处理器空闲时检查新流的间隔时间（以毫秒为单位）)	`integer`, `string`	默认值: `1000` 模式: `^\${.*}$` 最小值: `1` 最大值: `999999`
busy_streams_check_interval_ms (当流处理器繁忙时检查新流的间隔时间（以毫秒为单位）)	`integer`, `string`	默认值: `5000` 模式: `^\${.*}$` 最小值: `1` 最大值: `999999`
wait_enabled （检查数据是否已写入副本分片）	`boolean`	默认值：`false`
wait_timeout (检查写入副本分片时的超时时间，单位为毫秒)	`integer`, `string`	默认值: `1000` 模式: `^\${.*}$` 最小值: `1`
retry_on_replica_failure (确保数据已写入副本分片，如果未写入则持续重试)	`boolean`	默认值: `true`

附加属性： 不允许

targets: 目标连接

属性

名称	类型	描述	是否必需
connection (连接详情)	`object`

targets.connection: 连接详情

属性（模式）

名称	类型	描述	是否必需
.*
additionalProperties

本页内容