所以我们有 100 种不同类型的消息进入我们的 Kinesis 流。我们只想保存 4 种类型。我知道 Kinesis 可以转换消息,但它也可以过滤吗?这是怎么做到的?
最佳答案
过滤只是一种转换,您可以在其中决定不输出任何内容。您可以根据 the documentation 发送带有值 "Dropped"
的结果来表明这一点.
您可以在 this post 找到转换的一个例子,逻辑包括几件事:让记录直接通过而不进行任何转换(status “OK”
),转换并输出记录(再次,status “OK”
),删除或过滤记录(状态 “Dropped”
),并使用状态 “ProcessingFailed”
关于amazon-web-services - Kinesis Firehose 可以进行过滤吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55696143/