写回配置文件
写回配置文件参考
写回配置文件
属性
| 名称 | 类型 | 描述 | 必填 |
|---|---|---|---|
| applier (写回 Applier Gear 的配置详情) |
object, null |
||
| connections | object |
applier: 写回 Applier Gear 的配置详情
属性
| 名称 | 类型 | 描述 | 必填 | ||
|---|---|---|---|---|---|
| on_failed_retry_interval (失败时执行重试的间隔（秒）) |
integer, string |
默认值: 5模式: ^\${.*}$最小值: 1 |
|||
| read_batch_size (从源数据库读取数据的批处理大小) |
integer, string |
默认值: 2000模式: ^\${.*}$最小值: 1 |
|||
| debezium_lob_encoded_placeholder (启用 Debezium LOB 占位符) |
string |
默认值: "X19kZWJlemiumV91bmF2YWlsYWJsZV92YWx1ZQ==" |
|||
| dedup (启用去重机制) |
boolean |
默认值: false |
|||
| dedup_max_size (去重集合的最大大小) |
integer |
默认值: 1024最小值: 1 |
|||
| 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`` |
|
| dlq_max_messages (每个流的死信队列最大消息数) |
integer, string |
默认值: 1000模式: ^\${.*}$最小值: 1 |
|||
| target_data_type (目标数据类型：hash/json - 目标数据库必须使用 RedisJSON 模块) |
string |
默认值: "hash"模式: ``^${.*}$ |
hash | json`` |
|
| json_update_strategy (目标更新策略：replace/merge - 目标数据库必须使用 RedisJSON 模块) |
string |
(已弃用) 属性 'json_update_strategy' 将在未来版本中弃用。请使用 'on_update' 作业级别属性来定义 json 更新策略。 默认值: "replace"模式: ``^${.*}$ |
replace | merge`` |
|
| initial_sync_processes (写回引擎为处理与源的初始同步而创建的进程数) |
integer, string |
默认值: 4模式: ^\${.*}$最小值: 1最大值: 32 |
|||
| wait_enabled (检查数据是否已写入副本分片) |
boolean |
默认值: false |
|||
| wait_timeout (检查写入副本分片时的超时时间（毫秒）) |
integer, string |
默认值: 1000模式: ^\${.*}$最小值: 1 |
|||
| retry_on_replica_failure (确保数据已写入副本分片，如果未写入则不断重试) |
boolean |
默认值: true |
connections: 连接
属性 (模式)
| 名称 | 类型 | 描述 | 必填 |
|---|---|---|---|
| .* | |||
| additionalProperties |