Kinesis Firehose 可以进行过滤吗?

mar*_*rea 5 amazon-s3 amazon-web-services amazon-kinesis-firehose

因此,我们有 100 种不同类型的消息进入 Kinesis 流。我们只想保存 4 种类型。我知道 Kinesis 可以转换消息,但它也可以过滤吗?这是怎么做到的?

Jav*_*rez 7

过滤只是一种转换,您决定不输出任何内容。"Dropped"您可以通过按照文档发送带有值的结果来表明这一点。

您可以在这篇文章中找到一个转换的示例,其逻辑包括几件事:让记录直接通过而不进行任何转换(状态"OK"),转换并输出记录(再次,状态"OK"),删除或过滤记录(状态)"Dropped"),并使用状态传达错误"ProcessingFailed"