kinesis 에이전트 람다, 기원 파일 및 서버를 얻는 방법

Question

나는 kinesis 스트림에 많은 로그 파일 정보를 스트리밍하는 Kinesis 에이전트가 있으며 정보를 구문 분석하는 람다 함수가 있습니다. 람다에 문자열 이외에도 소스 파일 이름을 알 필요가있는 컴퓨터 이름이 가능합니까?

Answer 1

Kinesis으로 보내는 데이터에 추가 할 수 있습니다.

Lambda

가 base64 문자열로 Kinesis 기록을 얻을, 당신은이 문자열이 양식의 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;