没有附加文件的 NiFi PutSNS 处理器？

Question

对 NiFi 很陌生，所以如果我在这里完全遗漏了什么，请提前道歉。

架构：我正在从 ftp 服务器获取一些文件，上传到 S3，然后归档回服务器。如果上传到 S3 失败，请发布到 SNS 主题。

NiFi architecture

目标：如果发生故障，NiFi 将发布到 SNS 主题以发送电子邮件以支持人们。

问题：该文件似乎包含在发送到 SNS 的有效负载中，导致文件大小错误。

我尝试过的事情：我尝试使用 UpdateAttribute 处理器删除流文件属性以删除文件名，使用 LogMessage 处理器后跟 PutSNS 处理器，除了图中描述的内容.

有没有办法只向 SNS 发布一条短消息？

这是错误的图像，以确保我没有遗漏任何内容：

Error message

Answer 1

PutSNS 处理器将 FlowFile 的内容作为通知发送到 Amazon Simple Notification Service

因此，您必须在发送 SNS 之前使用 ReplaceText 或其他处理器更改流文件的内容。