2017-10-10 86 views
0

我正在嘗試爲直接向Elasticsearch集羣發送記錄的Firehose流創建AWS Lambda轉換函數。如何在AWS Lambda Nodejs函數中執行HTTP DELETE請求

目前,沒有辦法在Firehose流記錄中指定ES文檔ID,因此插入所有記錄,甚至是重複的記錄。但是,Firehose確實支持Lambda中託管的轉換函數,它給了我一個想法:

我的解決方案是創建一個Lambda轉換函數,該函數在轉換過程中爲每個記錄對Elasticsearch執行DELETE請求,然後返回未修改的所有記錄實現「刪除 - 插入」行爲(我記得短時間內消失的紀錄)。

但是,我對Nodejs知之甚少,即使這是一件很簡單的事情,我無法弄清楚如何去做。

是否有可供Lambda使用的節點包? (最好是AWS Elasticsearch API,但是一個簡單的HTTP軟件包可以)。

我需要打包一些其他模塊才能完成這項工作嗎?

Apex能幫助我嗎?我的首選語言是Go,但到目前爲止,我一直無法獲得頂點函數來執行或記錄任何內容到Cloudwatch ...

在此先感謝。

回答