kinesis agent to lambda, как получить исходный файл и сервер

Question

У меня есть агент кинезирования, который передает много файлов журналов в потоки кинезий, и у меня есть функция Lambda, которая анализирует информацию. На лямбда в дополнение к строке мне нужно знать имя исходного файла, имя машины можно?

Answer 1

Вы можете добавить его в данные, которые вы отправляете в 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;