Streamsets 数据收集器：用其子值替换字段

Question

我有这样的数据结构

{
  "id": 926267,
  "updated_sequence": 2304899,
  "published_at": {
      "unix": 1589574240,
      "text": "2020-05-15 21:24:00 +0100",
      "iso_8601": "2020-05-15T20:24:00Z"
  },
  "updated_at": {
      "unix": 1589574438,
      "text": "2020-05-15 21:27:18 +0100",
      "iso_8601": "2020-05-15T20:27:18Z"
  },

 }

我想使用 Streamsets 数据收集器将 updated_at 字段替换为其 unix 字段值。据我所知，可以使用现场替换器来完成。但是我仍然不明白如何制作映射表达式。我怎样才能做到这一点？

Answer 1

在 Field Replacer 中，将 Fields 设置为 /rec/updated_at，将 New value 设置为 ${record:value('/rec/updated_at/unix')}，它将替换价值。见下文。

干杯，破折号

Streamsets 数据收集器：用其子值替换字段

Streamsets Data Collector: Replace a Field With Its Child Value

etl

streamsets

data-pipeline