0

如何从 kinesis 转换数据？

我需要从非 json 格式事件中提取“logBody”作为 json 格式。在“logBody”模式将动态更改。所以，我只想保存为文件。

这是我要转换的事件：

["log_LogName",
  {"streamKey":"KinesisDataStream","txNo":0,"partitionKey":"123456789949","streamName":"bucketlog","qid":-1858829953885061086},
  {"tag1":null,"repair":false,"publishTime":"1619417687000","code":"act","slot":1612340400000,"tag2":null,
        "logBody":
            {"log1":"aaaaa, 0",
            "log2":"type1",
            "log3":"none",
            "log4":1,
            "log5":999,
            "log6":"000000000000001",
            "log7":"none",
            "log8":-1,
            "log9":"add",
            "log10":1612340607134
            },
         "split":18,
         "appId":"1",
         "logId":"176ddc71-65f9-11eb-bf73-29aec924521a",
         "marketOrderId":null,
         "maxSplit":56,
         "playerId":"000000000000001"
    }
]

我想提取为这种格式

{
"log1":"aaaaa, 0",
"log2":"type1",
"log3":"none",
"log4":1,
"log5":999,
"log6":"000000000000001",
"log7":"none",
"log8":-1,
"log9":"add",
"log10":1612340607134
}
4

0 回答 0