amazon-web-services - NiFi PutSNS 处理器没有附加文件？

Question

NiFi 很新，所以如果我在这里完全遗漏了一些东西，请提前道歉。

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

NiFi 架构

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

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

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

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

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

错误信息

标签： amazon-web-servicesapache-nifiamazon-sns

Answer 1

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

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