使用NiFi GetSQS处理器时如何按消息内容过滤接收消息

• 首先明确原生SQS的能力边界：不支持基于消息体内部的特定字符串实现服务端过滤，你既不能通过修改队列URL属性实现该需求，也无法在ReceiveMessage（即你提到的GetSQS请求）中增加额外参数让服务端帮你做内容匹配。
• 如果你使用的是普通原生SQS队列，目前只能先全量拉取消息到本地，再做内容过滤：匹配到目标字符串的消息正常处理后删除，不符合要求的消息可以等待可见性超时自动回到队列，也可以直接删除，可根据你的业务逻辑选择。
• 如果你可以调整上游消息发送逻辑，也可以采用优化方案避免本地过滤大量无效消息：
  发送消息时提前把需要过滤的特征提取为自定义消息属性，搭配SNS主题实现服务端过滤：先把所有消息发到SNS主题，给主题绑定多个SQS队列作为订阅者，每个订阅配置对应的消息属性过滤规则，只有符合规则的消息才会被推送至对应SQS队列，后续你直接消费目标队列的消息即可，不需要再做本地过滤。

内容的提问来源于stack exchange，提问作者Vijay Kumar