将元数据添加到 Kinesis Firehose 推送的 S3 对象

Question

我有 Firehose 流将数据推送到 s3，并使用一个小 lambda 处理格式。 我希望 S3 中的这些对象在创建时具有一些元数据。

我发现您可以在使用 aws cli 时或通过控制台添加它，但我没有找到一种方法来为从 firehose 创建的文件自动添加它。 lambda的格式只包含recordId、data和result。

我错过了什么吗？或者这是我无法使用 Firehose 自定义的东西？

谢谢:)

Answer 1

Firehose 没有提供开箱即用的选项。但您可以在 Firehose 向 S3 发布新对象时触发事件通知。事件通知可以触发将添加元数据的 lambda。