问题标签 [spring-integration-aws]

根据 Spring 发行说明，spring-integration-aws.1.1.0.M1不包括 DynamoDB MetaDataStore 实现。仍然有ConcurrentMetadataStore一个类是基于键值的存储，并且基于实现，我想它映射具有最新序列号读取的流。但它不使用任何数据存储来检索检查点。

我正在使用弹簧集成进行运动消耗，并且需要实施检查点。我想知道是否需要通过连接到 DynamoDB 并始终更新检查点来手动执行此操作，或者是否有另一种使用 Spring 框架的方法？

PS：我不能使用 Spring Cloud KinesisBinderConfiguration，因为我从可配置的流列表中动态使用事件。

谢谢

我对检查点存储有以下配置：

当消费者启动时，它通过创建以下键来查找检查点值

这意味着我应该在消费者启动之前创建密钥，这需要从 kinesis 获取所有分片。

如果没有密钥，为什么没有通用的方法来创建密钥？为什么检查点存储不使用 putIfAbsent 以便可以动态生成密钥？

谢谢

我有使用 AWS Kinesis 和 DynamoDB 的 Spring Boot 应用程序。当我运行应用程序时，我可以看到 AWSCredentialsProviderChain 提供了 EnvironmentVariableCredentialsProvider 以从环境变量中读取AWS_ACCESS_KEY_ID和AWS_ACCESS_KEY 。

但是当我运行集成测试时，EnvironmentVariableCredentialsProvider不在 AWSCredentialsProvider(s) 中。这是我的基本测试类配置：

@SpringBootTest 将 @SpringBootApplication 作为主要配置类，我假设两者都应该具有相同的配置上下文。

我感谢您的帮助。

谢谢

我对 KinesisMessageDrivenChannelAdapter 进行了以下配置，当我dynamoDbMetaDataStore作为检查点删除时，可以正确接收消息，但是当我添加回来时，记录总是空的。我调试了代码，KinesisMessageDrivenChannelAdapter.processTask()第 776 行（版本 2.0.0.M2）返回空记录。

更新：

谢谢

我正在尝试使用以下代码运行这个简单的 kinesis 消息使用者。这是应用程序中唯一的类

我正面临这个错误，因为我已经更新到最新的 kinesis binder 快照版本

应用 yml

构建.gradle

我收到了 bean 初始化异常，并且在创建 bean 时似乎存在问题DynamoDbMetadataStore。

此错误在更新到最新的 kinesis binder 快照版本后开始。

你能检查一下是否有问题。

我是春天的新手。我有一个使用 spring-integration-file (spring boot- FTP,SFTP,NFS) 创建的 spring 项目，它将文件从源路径转换为目标路径。

必须编写junit测试用例来测试项目。如果有人共享一些文档/链接以使用 @RunWith(SpringRunner.class) 为 spring-integration-file 项目编写 junit 测试用例，这将很有帮助

提前致谢

有时，当我们突然停止应用程序时，会发生解锁失败的异常。然后同一组将永远不会收到消息。其他组正在收到消息。

我正在使用 aws kinesis binder 快照版本。

这是应用程序停止时的错误。

然后我们启动应用程序，这是我们得到的错误。

在使用存储桶表达式进行处理之前，如果存储桶在 S3 存储中可用，如何检查 s3-outbound-gateway。如果存储桶不可用，则应将其重定向到错误通道。

在 Spring Boot 应用程序中使用 aws s3 出站适配器，尝试在 s3 存储桶中上传文件。想在上传文件之前检查存储桶是否可用。如果桶不可用需要抛出错误。

对此提出建议。

我的 spring-boot-integration 应用程序可以在多个服务器（节点）上运行，但它们都应该读取一个公共目录。现在，我编写了一个自定义储物柜，它可以锁定文件，以便任何其他实例都无法处理相同的文件。所有 spring 配置都在 xml 中完成。

应用程序获取锁但无法读取锁定文件的内容。

正如表单中所建议的，我们只能通过 ByteBuffer 访问锁定的文件内容。

因此尝试使用 file-to-bytes-transformer 将文件转换为字节，并作为输入传递给出站网关。但是实例没有开始。

有什么建议吗？