我有一个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;