如何在AWS Lambda Nodejs函数中执行HTTP DELETE请求

问题描述:

我正在尝试为直接向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 ...

在此先感谢。

这似乎是一个简单的任务,所以我猜不需要框架。

Node.js中的几行代码可以完成任务。 有两个包,可以帮助你:

的API文档:https://www.elastic.co/guide/en/elasticsearch/client/javascript-api/current/api-reference.html