问题标签 [spring-cloud-aws]

我有一个 Spring Boot 应用程序，我想使用spring-cloud-starter-aws-messaging. 我已经看过有关如何使用 AWS SECRET ACCCESS KEY 进行操作的教程，但我想改用 IAM 角色。你知道如何做的任何例子或教程吗？

干杯

我正在使用spring-boot-1.5.10和 spring-cloud 并使用spring-cloud-starter-aws-messaging。我能够发送和接收消息，但无法获取 SNS 消息属性。任何帮助都会非常显着。请在下面找到代码，

pom.xml

控制器.java

收到的输出消息：

我想获取我在 SNS 生产者中设置的消费者中的消息属性，例如 name、traceId。我浏览了很多，但找不到任何解决方案。任何帮助都会非常显着。

我们有一个用例，其中我们的一些侦听器需要具有不同的消息执行器线程数。或者更确切地说，一些队列侦听器需要比其他队列侦听器更少的并发消息处理。

在研究代码后，QueueMessageHandler 会查找所有 SQSListener 注释的方法，并将它们都配置为相同的属性。这包括每个批处理配置的最大消息，我们希望每个侦听器有所不同。

我们是否需要自定义QueueMessageHandler，还是有更合适的方法来做到这一点？

我正在使用spring-cloud-aws-autoconfigure:2.1.0.RELEASE连接到 AWS。但是，当应用程序在 AWS 以外的环境中运行时，我不希望进行自动配置。

我尝试按照此处和此处的建议使用 java 配置类以及spring.autoconfigure.excludes我的 yml 文件中的属性关闭自动配置，如下所示：

但这些解决方案似乎都不起作用。自动配置仍然发生，因此应用程序无法启动。

我有一个完善的 Spring Boot 服务器应用程序。我正在阅读一篇文章来配置 Spring 以将指标发送到 AWS Cloudwatch。

当我包含启动包spring-cloud-starter-aws时，我遇到了运行时异常。谁能告诉我为什么我会遇到这个异常以及我可以做些什么来解决这个问题？

以下是两种摘要形式的例外：

和长形式：

我使用 IntelliJ，查看了“外部库”列表，并找到了这个异常抱怨的类。IntelliJ 对代码进行反编译，我可以看到它是一个包含公共 AbstractRegistrar 内部类的公共类。似乎Spring应该找到这个类。

对此的任何帮助将不胜感激。

我创建了一个SQS使用@SqsListener. 它工作正常，但我不断收到大量类似的消息：

org.springframework.core.task.TaskRejectedException: Executor [java.util.concurrent.ThreadPoolExecutor@372b568[Running, pool size = 3, active threads = 3, queued tasks = 0, completed tasks = 0]] 不接受任务： org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer$SignalExecutingRunnable@4c30c2f9 at org.springframework.scheduling.concurrent.ThreadPoolTask​​Executor.execute(ThreadPoolTask​​Executor.java:317) ~[spring-context-5.1.4.RELEASE.jar: 5.1.4.RELEASE] 在 org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer$AsynchronousMessageListener.run(SimpleMessageListenerContainer.java:286) ~[spring-cloud-aws-messaging-2.1.0.RELEASE.jar:2.1 .0.RELEASE] 在 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_171] 在 java.util.concurrent。FutureTask.run(FutureTask.java:266) [na:1.8.0_171] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_171] at java.util.concurrent.ThreadPoolExecutor$ Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_171] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_171] 原因：java.util.concurrent.RejectedExecutionException：任务 org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer$SignalExecutingRunnable@4c30c2f9 从 java.util.concurrent.ThreadPoolExecutor@372b568 被拒绝 [正在运行，池大小 = 3，活动线程 = 3，排队任务 = 0，已完成任务 = 0] 在 java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) ~[na:1.8.0_171] 在 java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) [na:1.8.0_171] at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379) [na:1.8.0_171] at org.springframework.scheduling.concurrent.ThreadPoolTask​​Executor.execute(ThreadPoolTask​​Executor. java:314) ~[spring-context-5.1.4.RELEASE.jar:5.1.4.RELEASE] ...省略了6个常用框架

我的配置bean：

我的消费者如下：

是否可以通过重新配置来删除它们@Bean？问题的根本原因是什么以及如何与之抗争？

我试图通过自然搜索找到解决方案并遇到以下答案。它对我不起作用，因为我没有JMS. 我无法调试，因为我什至不知道要调试什么。

我正在开发一个 Spring Boot 应用程序，我在其中集成了 Amazon S3 服务。
此类是我访问 S3 存储桶的存储库：

按照建议使用Spring Boot Autoconfiguration。
所以在我的pom.xml，除其他外，我已经

此外，我做了application.properties这样的事情：

问题：

如果我编译我的项目，然后我只需运行 JAR java -jar target/myproject.jar，一切正常，我正确地得到了我要求的图像，一切都很好。

相反，如果我在尝试获取图像（存在于存储桶中）时使用IDE 默认运行项目，则会出现以下异常： mvn spring-boot:run

所以我认为它抛出了一个异常，因为它就像它进入 jar来寻找匹配的东西，s3://mybucket/test.jpeg但我不明白为什么，以及为什么它只运行项目mvn spring-boot:run而不运行 jar。

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

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

目前我们有如下配置。

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

根据文档，

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

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

我试图为 Aws kinesis 流消费者实现负载平衡

根据我正在尝试实施的文档

我有3 个容器，如果需要，我想在不重新启动现有容器的情况下启动新容器（最多 6 个） 。

1. instanceIndex 从 0 或 1 开始。
2. 如果我将 instanceCount 设为 6，但只启动了三个实例，那么在我启动新实例之前，是否会消耗所有消息。
3. 在文档中，有一个名为 spring.cloud.stream.bindings..consumer.concurrency 的属性，你能帮助它的重要性。
4. 由于某些原因，如果任何一个实例出现故障，是否有任何消息未被消费。

你能帮助我们吗

我正在使用 1 条碎片推送 100 条消息。

我正在循环推送消息以进行测试

我正在使用如下消息

消息消费无序。

我是不是错过了什么。