将操作码添加到Redis输出中
在下面的示例中,数据从名为 employee
的源表中捕获,并以 JSON 文档的形式写入 Redis 数据库。当您为作业指定 data_type
参数时,它将覆盖在 config.yaml
中定义的系统范围设置 target_data_type
。
在这里,结果将是Redis JSON文档,其中包含从源表捕获的字段
(employeeid
, firstname
, lastname
),并且还包含
使用merge
更新策略添加的额外字段my_opcode
(有关更多信息,请参见
JSON作业示例)。
opcode
表达式指的是从源捕获的操作代码。这是一个特定于数据库的值,指示生成更改的操作类型(插入、更新等)。
source:
schema: public
table: employee
row_format: full
transform:
- uses: add_field
with:
field: after.my_opcode
expression: opcode
language: jmespath
output:
- uses: redis.write
with:
data_type: json
mapping:
- employeeid
- firstname
- lastname
- my_opcode
connection: target
on_update: merge