问题标签 [spring-integration-aws]

有一个弹簧启动应用程序，我想在其中将文件放在 S3 目标存储桶的文件夹中。目标桶/目标系统文件夹/file.csv

对于将从 yml 配置文件中检索的每个文件，目标系统文件夹名称将有所不同。

如果文件夹不退出并且文件应该放在文件夹下，则必须通过代码创建目标系统文件夹

据我所知，S3 存储桶中没有文件夹概念，所有文件夹都存储为对象。

已经阅读了一些文件，比如将文件放在文件夹下，必须给出 key-expression，如 targetsystem-folder/file.csv 和 bucket = target-bucket。但这行不通。想使用spring-integration-aws而不直接使用aws-sdk来实现

任何人都可以指导这个问题

我正在使用来自https://github.com/spring-projects/spring-integration-aws的示例配置作为入站通道适配器，但我有一个存储桶，其中包含内部带有 CSV 的子目录。

有没有办法在本地复制桶树结构？我只设法从子目录中复制文件，但它们最终是在我使用 messageSource.setLocalDirectory(LOCAL_FOLDER); 设置的目录的根目录中创建的；

或者有没有办法识别文件来自哪个桶子目录？

如何自定义 aws s3 inbound-channel-adapter 的启动/停止。我想最初设置 auto-startup="false" 并在服务器启动时手动启动。寻找类似于我们有以下文件入站通道适配器解决方案的解决方案。

inboundFileAdapterChannel.send(new GenericMessage("@'s3FilesChannelId.adapter'.start()"));

配置：

如果我对 s3 入站适配器通道尝试相同的方法。我收到以下错误

应用程序无法启动

描述：

一个组件需要一个名为“s3FilesChannelId.adapter”的 bean，但找不到该 bean。

行动：

考虑在您的配置中定义一个名为“s3FilesChannelId.adapter”的 bean。

我的方案是在文件被修改时仅将一个文件从 AWS S3 存储桶传输到 EC2 实例一次。我使用以下配置并在服务器启动时手动启动适配器。

问题是服务器启动时重复执行 5 或 6 次。看起来正在执行不同的线程。我能够在日志中看到不同的任务执行器，不知道它是轮询器问题还是适配器问题。

我正在使用服务激活器根据 S3 位置中的文件更改执行一些其他操作。

注意：此问题仅在启动时发生一次。进一步的文件修改工作正常。

配置：

正如你所建议的，我尝试了以下方法。

添加了用于检查上次修改时间的逻辑

仍然没有希望。日志是这样的.......

我可以在 s3 入站适配器中有本地目录表达式吗？我的本地目录路径是一个表达式。如何在本地目录属性中分配表达式变量？

有一个弹簧启动应用程序，我正在尝试使用单个 S3 出站适配器将文件放入多个 S3 存储桶中。

想知道是否可以使用 spring-integration-aws 本身使用单个出站适配器将文件放置在多个存储桶中（不使用 aws -sdk）

任何建议都会有所帮助。

S3：出站适配器：

我有InboundChannelAdapter配置了S3StreamingMessageSource。我强迫Poller使用只有 1 个线程的taskExecutor 。但我看到同一个文件被同一个线程以 3-4 秒的间隔拾取 3 次。即使轮询间隔是 10 秒。我指定了由模式过滤器和接受过滤器组成的复合过滤器。但没有结果，文件总是被拾取 3 次。

我看到该应用程序来到@Transformer 3 次。非常感谢任何帮助。

成功传输到目标目录后，源文件不会从 s3 存储桶中删除一次。步骤 1. 使用入站流通道适配器将源文件从 S3 流式传输到本地目录。（工作正常）第 2 步：想要删除源文件一旦成功传输（不工作）配置代码如下

问候，

尝试使用 spring-integration-file 使用单个出站网关将文件放在多个目录中。我知道这样的通道适配器不可能一次发送到多个目录。

为了实现这一点，在 file:outbound-gateway 前面有一个循环，以在每次迭代时修改消息头目标目录，并一次又一次地将它们全部发送到同一个通道。

但是得到如下所述的异常。

任何建议如何循环它或更新标头并再次执行适配器

文件：出站网关：

尝试使用 spring-integration-file 使用单个出站适配器将文件放置在多个目录中。

为了实现这一点，在 file:outbound-gateway 前面有一个循环，以在每次迭代时修改消息头目标目录，并一次又一次地将它们全部发送到同一通道，直到目标计数减少到 0。

能够循环回标头丰富器通道。但是由于我们再次为相同的标头名称丰富标头值。标题名称 TARGET_DIR 的值未更新。也不例外。

想知道一些解决方案是否可以为相同的标头名称一次又一次地更新标头值，或者是否可以在运行时提供动态标头名称。

尝试在循环返回时使用 header:filter 删除 TARGET_DIR 标头。但没有成功。