我正在尝试将来自 Kinesis 流的消息作为批处理

我在用

应用程序.yml

代码

根据文档，当 listenerMode 为批处理时，预计将列表作为有效负载

我已发送消息为 {"ab":"aa"}

我收到消息错误为

我们目前正在将我们当前的架构迁移到基于 Spring-AWS 的微服务中。我的任务之一是研究我们的微服务如何相互通信。我的目标是建立一个 RESTful HTTP 端点和 SQS 生产者和消费者的混合系统。

例如，我有以下代码：

从理论上讲，该方法应该能够处理以下问题：

1. 通过 HTTP接收请求对象
2. 不断轮询request_queue以获取包含Request对象的消息

作为 HTTP 端点，该方法不返回错误。但是，作为 SQS 监听器，它会遇到以下异常：

我尝试使用@Payload 注释请求参数，但无济于事。目前我还通过 Java 设置了 AWS 配置，如下所示：

消费者AWSSQSConfig.java

你们有什么感想？

我最近一直在研究 Spring-Cloud-Function 和 Spring-Cloud-AWS 以及 Spring 模块提供的所有功能，但是，我不太清楚的一件事是这两者是否正确地结合在一起。

我可以看到 Spring Cloud 功能和 S3 一起使用，但不支持 AWS 的无服务器数据库 DynamoDB。

将 Spring Cloud Function (AWS Lambda) 与 RDS 一起使用是好还是坏？DynamoDB 是一个非阻塞 DBS 是否更适合 Lambda 及其计费结构？

如何使用注释配置 Spring Cloud AWS XML 配置？

我对更改默认任务执行器特别感兴趣。

环境

• Spring Boot：1.5.13.RELEASE
• 云：Edgware.SR3
• 云 AWS：1.2.2.RELEASE
• 爪哇 8
• OSX 10.13.4

问题

我正在尝试为 SQS 编写集成测试。

我有一个运行 SQS 的本地运行localstack docker容器TCP/4576

在我的测试代码中，我定义了一个 SQS 客户端，其端点设置为本地 4576，并且可以成功连接并创建队列、发送消息和删除队列。我还可以使用 SQS 客户端接收消息并提取我发送的消息。

我的问题是，如果我删除手动接收消息的代码以允许另一个组件获取消息，似乎什么都没有发生。我有一个注释如下的弹簧组件：

听众

测试

在测试日志中，我看到：

oscamlistener.QueueMessageHandler ：在 MyListener 类上找到 1 个消息处理程序方法：{public void MyListener.receive(MyMsg)=org.springframework.cloud.aws.messaging.listener.QueueMessageHandler$MappingInformation@1cd4082a} 2018-05-31 22:50： 39.582 信息 16329 ---

oscamlistener.QueueMessageHandler ：将“org.springframework.cloud.aws.messaging.listener.QueueMessageHandler$MappingInformation@1cd4082a”映射到公共 void MyListener.receive(MyMsg)

其次是：

正在运行：真

活动：真

isRunningOnQueue:false

得到消息：1

这表明，在发送消息之间的 30 秒暂停中，容器没有接收到它，当我手动轮询消息时，它在队列中，我可以使用它。

我的问题是，为什么不调用侦听器，为什么isRunningOnQueue:false行表明它不是为该队列自动启动的？

请注意，我还尝试设置我自己的SimpleMessageListenerContainerbean，将 autostart 显式设置为 true（无论如何都是默认值）并且观察到行为没有变化。我认为应该配置一个应该org.springframework.cloud.aws.messaging.config.annotation.SqsConfiguration#simpleMessageListenerContainer为我轮询消息@EnableSqs的自动启动。SimpleMessageListenerContainer

我也设置了

在我的测试属性中，可以看到 HTTP 调用创建队列、发送消息和删除等，但没有接收 HTTP 调用（除了我在测试结束时的手动调用）。

我最近将我的 SpringCloud 项目从 Brixton 升级到了 Finchley，一切正常。我正在研究 Finchley.SR2 并且没有任何问题，但是每当我将项目升级到 Finchley.RELEASE （这是我所做的唯一更改）时，项目都无法启动。

原因是项目找不到AmazonS3ClientBean：

这些是我之前的相关配置和类：

构建.gradle

S3Config.java（创建 AmazonS3/AmazonS3Client Bean 的类）

StorageService（找不到Bean的类）

这是我升级到 Finchley.Release 时对build.gradle文件所做的唯一更改：

I've tried looking for any missing library and tweaking all the configurations I can find, but none seem to take any effect.

我目前正在处理一个项目，在该项目中我们的应用程序需要连接到 Amazon RDS 实例。到目前为止，我一直在使用以下文档进行设置： https ://cloud.spring.io/spring-cloud-aws/spring-cloud-aws.html#_sdk_credentials_configuration 。

根据文档，第 7.3 节，我应该这样设置我的 application.properties 文件：

但是，当我运行应用程序时，我收到以下错误：

我不确定为什么当上面的设置看起来很好时它告诉我密码为空。

任何的意见都将会有帮助。让我知道我是否需要提供其他任何东西。

谢谢。

我们正在尝试接收来自 AWS SNS 服务的通知，我们决定使用 Spring Cloud SNS 库来处理来自 AWS SNS 的请求。 这是 Spring Cloud SNS 库的示例。

一切正常，但我们不知道如何或在哪里验证亚马逊 AWS 文档所说的消息。这里有一个示例，但是使用 Spring Cloud SNS 添加此验证是我们迷路的地方。

例如，我想在消息到达方法之前添加此验证代码：confirmUnsubscribeMessage、receiveNotification 和 confirmSubscriptionMessage。

提前致谢。

我使用 Spring cloud AWS 在 openStack 中连接到我的 Amazon S3，默认情况下，端点是 s3.amasonaws.com 我想更改端点，因为我的存储桶 S3 我们在私有云中而不是在公共亚马逊云中。

. . . .

....在我的 application.properties

想你的帮助。

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

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

应用 yml

构建.gradle

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

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

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