带有putrecord的lambda函数的AWS firehose delievery流

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了带有putrecord的lambda函数的AWS firehose delievery流相关的知识,希望对你有一定的参考价值。

我正在使用Kinesis firehose交付流。我使用PutRecord API将记录放入交付流中。一个观察结果putRecord将Record作为参数,内部采用byteBuffer。

我能够成功地将记录放入firehose传输流中。现在我在nodejs中实现了lambda函数来对kinesis firehose流中的记录进行转换。

在我的lambda函数中,我在lambda函数中得到字节流而不是字符串。知道为什么会这样吗?我尝试将字节流转换为字符串,但没有运气

答案

从AWS doc我开始知道数据被发布到lambda函数是BASE64编码我们需要解码数据。

谢谢

以上是关于带有putrecord的lambda函数的AWS firehose delievery流的主要内容,如果未能解决你的问题,请参考以下文章

Node.js中的代码AWS Lambda Package不会调用putRecord()来将数据添加到AWS Kinesis Firehose Stream中

带有 Lambda 函数的 AWS EBS 与 EFS

我的带有 lambda 函数的 AWS API Gateway REST API 返回 Null,如何解决这个问题?

在异步 AWS Lambda 函数中使用带有 node-fetch 模块的 node.js 时遇到问题

向 AWS Lambda 发送带有正文的请求

使用带有 Node.js 的 AWS Lambda 函数从 S3 存储桶中提取 zip 文件并上传到另一个存储桶