Kinesis Firehose 可以进行过滤吗？
Can Kinesis Firehose do filtering?
所以我们有 100 种不同类型的消息进入我们的 Kinesis 流。我们只想保存 4 种类型。我知道 Kinesis 可以 transform 消息，但它也可以 filter 吗？这是怎么做到的？
过滤只是一种你决定不输出任何东西的转换。您通过根据 the documentation.
发送带有值 "Dropped" 的结果来表明这一点
你可以在this post找到一个转换的例子，逻辑包括几件事：让记录直接通过而不进行任何转换（状态"OK"），转换并输出记录（再次, status "OK"), drop-or filtering- a record (status "Dropped"), and communicating an error using the status "ProcessingFailed"
所以我们有 100 种不同类型的消息进入我们的 Kinesis 流。我们只想保存 4 种类型。我知道 Kinesis 可以 transform 消息，但它也可以 filter 吗？这是怎么做到的？
过滤只是一种你决定不输出任何东西的转换。您通过根据 the documentation.
发送带有值"Dropped" 的结果来表明这一点
你可以在this post找到一个转换的例子，逻辑包括几件事：让记录直接通过而不进行任何转换（状态"OK"），转换并输出记录（再次, status "OK"), drop-or filtering- a record (status "Dropped"), and communicating an error using the status "ProcessingFailed"