aws s3 Spring 集成文件修改监视器

Question

我正在寻找 AWS s3 Spring 集成文件修改监视器示例。

要求：每当从 AWS S3 存储桶中修改文件时，必须将最新更改从 s3 传输到 EC2 实例。

我们有文件入站适配器的监视事件，但我正在寻找类似的适配器或用于 s3 操作的逻辑。

我们现在拥有的：

<int-file:inbound-channel-adapter id="modifiedFiles" directory="${input.directory}" use-watch-service="true" filter="acceptAllFilter" watch-events="MODIFY"/>

XML 配置：

<bean id="acceptOnceFilter"
    class="org.springframework.integration.file.filters.AcceptOnceFileListFilter" />

<integration:channel id="s3FilesChannel" />
<int-aws:s3-inbound-channel-adapter id="s3FilesChannelId" channel="s3FilesChannel"
             session-factory="s3SessionFactory"
             auto-create-local-directory="false"
             delete-remote-files="false"
             preserve-timestamp="true"
             local-directory="file:${localFilePath}"
             local-filter="acceptOnceFilter"
             remote-directory-expression="${bucket_name}"
             auto-startup="false"
             filename-regex="${regx_expresion}" 
             remote-file-separator="/" >
    <integration:poller fixed-delay="1000"/>
</int-aws:s3-inbound-channel-adapter>

<integration:channel id="s3FilesChannel">
    <integration:queue/>
</integration:channel>

Answer 1

AWS S3 没有这样的监视器。这是基于 HTTP 的远程协议，与基于 WatchService 的普通文件系统监视器不同。你不要拿苹果和苹果比较。

您需要使用标准的<int-aws:s3-inbound-channel-adapter>。默认情况下使用S3PersistentAcceptOnceFileListFilter，它会对远程文件的修改做出反应。好吧，基本上它会轮询远程文件并检查其lastmodified。

在Reference Manual查看更多信息：

另外，如果您将过滤器配置为使用FtpPersistentAcceptOnceFileListFilter，并且远程文件时间戳发生更改（导致它被重新获取）

同样的规则也适用于 AWS S3 通道适配器。