带有 lambda 函数和 putrecord 的 AWS firehose 交付流答案

【问题标题】：AWS firehose delievery stream with lambda function with putrecord带有 lambda 函数和 putrecord 的 AWS firehose 交付流
【发布时间】：2018-10-29 16:40:55
【问题描述】：

我正在使用 Kinesis firehose 传输流。我正在使用 PutRecord API 将记录放入传输流中。一个观察 putRecord 将 Record 作为参数，在内部它采用 byteBuffer。

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

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

【问题讨论】：

标签： amazon-web-services aws-lambda amazon-kinesis-firehose

【解决方案1】：

从 AWS 文档中我了解到，发布到 lambda 函数的数据是 BASE64 编码的，我们需要对数据进行解码。

谢谢

【讨论】：