Spring集成仅根据触发器文件指定的文件名拾取

Question

使用spring集成，我只想从触发器文件指定的文件名中提取文件。

如果.batch01-触发器存在，那么将根据处理结果更新触发器的文件名(. be 01-触发器成功或.be 01-触发器失败)

目前我正在轮询S3桶，但我无法应用上面的用例。

谢谢!

我使用了AWS SDK和spring-integration-aws。

Answer 1

我能看到这样的解决方案：

1. 有一个为*-trigger模式配置的S3InboundFileSynchronizingMessageSource。因此，它将定期轮询S3目录，以确定是否存在类似于您的S3文件。

1. --您将该文件向下发送到某个服务激活器，该激活程序将使用S3Session.list()并只筛选出匹配的文件。或者public InputStream readRaw(String source) {，因为此时您知道需要从S3.

中提取文件名(batch01.tar)。

1. 当前存储在消息头中的触发器文件.

在处理S3Session.rename().文件之后，您可以做出一个.success或.failed决策并执行.tar