问题标签 [spring-integration-aws]

我们如何使用 spring-cloud-stream-binder-kinesis 建立两个 AWS kinesis 连接？

第一次连接：Spring 应用程序和 AWS 运动流在同一个 AWS 账户中。

第二个连接：位于不同 AWS 账户中的其他 AWS 运动流。

是否可以从 Spring 应用程序到不同 AWS 账户中的两个不同运动流有两个不同的连接？如果是，我们如何实现它？

Have a spring integration application where files are routed from a folder to S3 buckets using s3-outbound-channel-adapter. If the file processed successfully, then file will be moved to corresponding target-bucket. if any error , file move to error bucket via error channel.

Have to generate a daily statistics report in a text file containing below details.

Total no of files processed: Total success : Total Error:

Would like to know how to get no of files processed successfully/error. Is there any way to achieve this requirement.

Any suggestion or example would be helpful.

Gone through the DefaultMessageChannelMetrics and Micrometer Integration in documentation. Not sure it will help my requirement.

Have separate gateway and adapter to process success and error files.

Success :

Error :

有一个 spring 集成应用程序，其中使用 s3-outbound-channel-adapter 将文件从文件夹路由到 S3 存储桶。我需要知道今天日期（当前日期）存储在 S3 存储桶下的文件/对象的数量以及仅具有格式（csv/txt）的文件。

想知道如何在不直接使用 aws-sdk 的情况下使用 spring-integration-aws 获得它？

观察到 spring-integration-aws 在 S3session 中有一个方法。

我们是否需要在 S3ObjectSummary 上使用比较器，或者是否有任何其他方法可以实现这一点。任何建议都是有帮助的。

我正在研究一个用例，我应该轮询 S3 -> 读取内容流 -> 进行一些处理并将其上传到另一个存储桶，而不是在我的服务器中写入文件。

我知道我可以在 Spring aws 集成中使用 S3StreamingMessageSource 来实现它，但我面临的问题是我不知道如何处理通过轮询接收到的消息流

有人可以帮我处理流的代码吗？

我正在开发一个后端服务，该服务使用 spring aws 集成定期轮询 S3 存储桶并处理来自 S3 的轮询对象。下面是它的实现

我在对象上传时从 S3 获取消息，并且我能够使用作为消息有效负载的一部分接收的输入流来处理它。但是我在这里面临的问题是，在收到几条消息后，我得到了“等待池连接超时”异常

我知道这个问题与没有像这里所说的那样关闭打开的 S3Object 有关https://github.com/aws/aws-sdk-java/issues/1405所以我已经实现关闭作为一部分接收的 S3Object 的输入流消息有效载荷。但这并不能解决问题，我不断收到异常。有人可以帮我解决这个问题吗？

我在我的应用程序中使用弹簧集成通道技术。我只想将一些文件放入具有完全访问权限的 aws s3 存储桶中。我的配置是 XML 格式的。

需要通过在 s3 outbound gateway 中使用 expression-acl-object 属性来实现。

请帮助配置它。

我已经通过 Java 使用直接通道成功地为 AWS SQS 配置了入站通道适配器。该项目使用 JDBC 和 RabbitMQ 与 SQS 的组合作为 3 个独立队列的入站流。我需要持久消息，所以我试图弄清楚如何利用 RabbitMQ。我对如何引用 AMQP 通道感到困惑。如何从 setOutPutChannel 引用 AMQP 消息通道？我的目标是仅在消息成功发布到 RabbitMQ 持久队列时才将消息从 SQS 中删除。

我想在 s3-outbound-gateway 中使用 object-acl-expression ，如下面的配置所述，但是由于 else 部分中的 null 值，它会抛出“非法状态异常”。我不想在 else 部分中设置任何其他访问控制。您能否就此提出一些解决方案？

预期：object-acl-expression 应该是存储桶中提供的默认值实际：抛出“非法状态异常”

我们正在使用 spring-integration-aws-2.0.0 连接到 kinesis 以收听流。停止应用程序时，总是出现以下异常。

尽管它可能尚未造成任何数据丢失。有人遇到这个错误吗？

我们有三个使用 Spring cloud AWS kinesis binder 连接到 Kinesis 流的容器作为消费者。我们使用消费者组在三个容器之间进行负载平衡。要求是集装箱分担负载，并且能够均匀地分配负载。

1. 所有容器都使用来自配置服务器的相同应用程序配置

目前我们有如下配置。

所有容器都在使用相同的消息，但在不同的时间（相差 5 到 10 分钟）

根据文档，

单个消费者组内的静态分片分布 可以在单个消费者组内的所有实例之间均匀分布分片。这是通过配置完成的：

由于我们使用相同的配置服务器，请您帮助如何确保实现负载平衡。