Jolt转换在每个json记录之前添加新的索引json记录

Question

输入JSON

[
    {
        "timestamp":"2020-01-28 12:13:43,561",
        "threadno":"5",
        "loglevel":"DEBUG",
        "class":"someclassname",
        "nanoseconds":"587800052",
        "message":null,
        "stackTrace":null
    },
    {
        "timestamp":"2020-01-28 12:33:57,328",
        "threadno":"12",
        "loglevel":"DEBUG",
        "class":"someclassname",
        "nanoseconds":"6419049968",
        "message":null,
        "stackTrace":null
    }
]

输出JSON

[
    {
        "index":{
            "_index":"test",
            "_type":"doc",
            "_id":"20200128121343561"
        }
    },
    {
        "timestamp":"2020-01-28 12:13:43,561",
        "threadno":"5",
        "loglevel":"DEBUG",
        "class":"someclassname",
        "nanoseconds":"587800052",
        "message":null,
        "stackTrace":null
    },
    {
        "index":{
            "_index":"test",
            "_type":"doc",
            "_id":"20200128123357328"
        }
    },
    {
        "timestamp":"2020-01-28 12:33:57,328",
        "threadno":"12",
        "loglevel":"DEBUG",
        "class":"someclassname",
        "nanoseconds":"6419049968",
        "message":null,
        "stackTrace":null
    }
]

我需要在每个json记录{“索引”：{“_index”：“test”，“_type”：“doc”，“_id”：“20200128121343561”}}之前添加这个索引记录，并且_id值是从时间戳派生的。我们还可以使用jolt转换在每个json记录后添加新行吗

Answer 1

处理< code>timestamp字段以创建< code>_id是一种数据转换。根据jolt文档，您必须编写定制的Java代码。

目前，所有的Stock转换只影响数据的“结构”。要进行数据操作，您需要编写Java代码。如果您编写Java“数据操作”代码来实现Transform接口，那么您可以将代码插入到转换链中。

看见https://github.com/bazaarvoice/jolt详细信息。