将操作码添加到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
RATE THIS PAGE
Back to top ↑