mar*_*rea 5 amazon-s3 amazon-web-services amazon-kinesis-firehose
因此,我们有 100 种不同类型的消息进入 Kinesis 流。我们只想保存 4 种类型。我知道 Kinesis 可以转换消息,但它也可以过滤吗?这是怎么做到的?
Jav*_*rez 7
过滤只是一种转换,您决定不输出任何内容。"Dropped"您可以通过按照文档发送带有值的结果来表明这一点。
"Dropped"
您可以在这篇文章中找到一个转换的示例,其逻辑包括几件事:让记录直接通过而不进行任何转换(状态"OK"),转换并输出记录(再次,状态"OK"),删除或过滤记录(状态)"Dropped"),并使用状态传达错误"ProcessingFailed"
"OK"
"ProcessingFailed"
归档时间:
6 年,6 月 前
查看次数:
5819 次
最近记录: