0
레코드를 직접 Elasticsearch 클러스터로 보내는 Firehose 스트림에 대해 AWS Lambda 변환 함수를 만들려고합니다.AWS Lambda Nodejs 함수에서 HTTP DELETE 요청을 실행하는 방법
현재 Firehose 스트림 레코드에 ES 문서 ID를 지정하는 방법이 없으므로 모든 레코드 (심지어 중복 레코드)가 삽입됩니다. 그러나 Firehose는 Lambda에서 호스팅되는 변환 함수를 지원합니다.
내 솔루션은 변형 중에 모든 레코드에 대해 Elasticsearch에 대한 DELETE 요청을 실행하는 람다 변환 함수를 작성한 다음 모든 레코드를 수정하지 않고 반환하는 것입니다. "delete-insert"동작을 얻습니다 (짧은 기간 동안 레코드가 사라지는 것을 확인했습니다).
그러나 Nodejs에 대해서는 거의 알지 못합니다. 이것은 매우 간단한 것이지만 어떻게해야 하는지를 알 수는 없습니다.
람다가 사용할 수있는 노드 패키지가 있습니까? (가급적이면 AWS Elasticsearch API를 사용하지만 간단한 HTTP 패키지를 사용하는 것이 좋습니다.)
다른 모듈을 패키지화해야합니까?
Apex와 같은 것이 나를 도와 줄 수 있습니까? 내가 선호하는 언어는 Go 다. 그러나 지금까지 나는 Cloudwatch에 무엇이든지 실행하거나 기록 할 수있는 꼭지점 함수를 얻을 수 없었다 ...
미리 감사드립니다.