kinesis代理到lambda，如何获取原始文件和服务器

Posted 2021-04-19

我有一个kinesis代理，它将很多日志文件信息传递给kinesis流，我有一个Lambda函数来解析信息。在Lambda上除了字符串我还需要知道源文件名，机器名是否可行？

答案

您可以将其添加到发送到Kinesis的数据中。

Lambda获取Kinesis记录为base64字符串，您可以编码为此字符串这种形式的JSON：

{
  "machine": [machine],
  "data": [original data]
}

然后，在处理Lambda上的记录时：（nodejs）：

let record_object = JSON.parse(new Buffer(event.Records[0].kinesis.data, 'base64').toString('utf8'));

let machine = record_object.machine;
let data = record_object.data;