有没有一种方法可以指定文件扩展名,将文件保存到Kinesis Firehose的S3中?

10

我正在设置Kinesis Firehose流,文件以分隔符形式在S3上创建,一切正常。但是我想知道是否有一种方法可以指定此文件的扩展名,因为消费者需要它为CSV或TXT格式。有没有办法实现这个需求?

谢谢。

2个回答

3
您可以创建一个S3触发器,将其发送到Lambda并从那里进行重命名。

1

我无法为firehose生成的文件获得扩展名,但最终我使用了数据管道来完成这个任务,通过使用ShellCommandActivity组件可以在Amazon S3上运行shell命令并将结果文件写入S3或其他任何位置。


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接