如何为druid展平json中的timestampspec列?

ia2d9nvy  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(291)

我有一个场景,其中timestamp列位于json中,如下所示。

{
          "version":"1.1",
          "header": {
            "name": "PlaceOrder",
            "schemaVersion": "1.2.0",
            "appName": "data-services-api",
            "appVersion": "1.0.0",
            "experimentId": "",
            "uuid": "27811b74-2333-494d-9623-00d36cbefb9b",
            "eventId": 35299,
            "timestamp": 1528351708570
         }
      }

有人知道如何在配置文件的timestampspec列中指定它吗?

"timestampSpec": {
            "column": ???,
            "format": "millis"
          }
p8h8hvxi

p8h8hvxi1#

您可以在您的摄取任务配置中执行以下操作-

"$.header.timestamp"

我假设您知道在config中使用“flattenspec”和“usefielddiscovery”。

相关问题