spring-integration-aws相关内容
我正在使用批处理模式从 kinesis 流中提取记录.我们正在使用 spring aws kinesis binder. 大多数时候我们无法从流中提取消息.只有某些时候我们能够从流中提取消息. 我的配置如下所示 我的配置 弹簧:云:溪流:运动:粘合剂:锁:租期:30读取容量:1写入容量:1检查点:读取容量:1写入容量:1绑定:InStreamGroupOne:消费者:liste
..
我正在使用批处理模式从 kinesis 流中提取记录.我们正在使用 spring aws kinesis binder. 大多数时候我们无法从流中提取消息.只有有时我们能够从流中提取消息. 我的配置如下 我的配置 弹簧:云:溪流:运动:粘合剂:锁:租期:30读取容量:1写入容量:1检查点:读取容量:1写入容量:1绑定:内流组一:消费者:侦听器模式:批处理idleBetweenP
..
我正在关注文档:Spring Batch Integration 结合 集成 AWS 用于汇集 AWS S3. 但是在某些情况下，每个文件的批处理执行不起作用. AWS S3 池工作正常，所以当我放置一个新文件或当我启动应用程序并且存储桶中有文件时，应用程序与本地目录同步: @Bean公共 S3SessionFactory s3SessionFactory(AmazonS3 pAm
..
在 spring-boot-integration 应用程序中，编写了一个自定义储物柜以在锁定之前重命名原始文件(fileToLock.getAbsolutePath() + ".lock")和预期锁定文件，以便任何其他实例将无法处理同一个文件. 当文件重命名时，它对原始文件和附加文件的内容进行了处理，使用filename.lock创建了内容，原始文件也存在，大小为0 kb，没有内容.
..
我正在以批处理模式消费消息.我想每 250 毫秒从流中提取 8 条消息. 弹簧:云:流:运动:绑定:输入:消费者:侦听器模式:批处理idleBetweenPolls: 250记录限制:8绑定:输入:组:我的组目的地:流内容类型:应用程序/json 我已将大约 100 条消息推送到流中，然后我启动了消费者. 根据配置，我应该每 250 毫秒提取一次消息.但是轮询器不会每 250 毫秒拉取一
..
我需要根据消息内容从S3下载文件.换句话说，要下载的文件以前是未知的，我必须在运行时搜索并找到它. S3MessageHandler ，但是它不支持列出我要查找所需文件所需的文件. 我可以直接使用AWS API实现自己的消息处理程序，只是想知道我是否丢失了某些东西，因为这似乎不是一个不寻常的要求.毕竟，并非每个应用程序都坐在那里，并不断轮询S3中是否有新文件. 解决方案 对于遇到此问
..
我正在开发一个后端服务，该服务使用spring aws集成定期轮询S3存储桶，并处理来自S3的被轮询对象.下面是它的实现 @Configuration @EnableIntegration @IntegrationComponentScan @EnableAsync public class S3PollerConfiguration { //private static fina
..
在spring boot应用程序中使用aws s3出站适配器，尝试将文件上传到s3存储桶中.想要在上传文件之前检查存储桶是否可用.如果存储桶不可用，则需要引发错误. 对此建议.
..
我正在使用批处理模式从kinesis流中提取记录。 在大多数情况下，我们无法从流中提取消息。 我的配置如下所示 我的配置 spring： 云： 流： 运动： 活页夹： 锁： 租约时间：30 读容量：1 write容量：1 检查点：$ b $ b read容量：1 writeCapacity：1 绑定： InStreamGroupOne： 使用者： 侦
..
