16得票3回答
AWS S3:文件接收后通过S3通知触发多个目标

我希望在AWS S3存储桶中设置以下事件/通知配置: 收到文件(s3:ObjectCreated:*)后将触发两个目标: SQS:将文件排队进行详细的后处理并保留一段时间 Lambda:进行一些快速的即时度量处理 当我尝试通过AWS控制台设置配置时,出现以下错误消息:Configura...

22得票2回答
Spring Cloud @SqsListener 消息转换异常:无法将 [java.lang.String] 转换为 GenericMessage。

当我尝试消费SQS消息时,出现以下异常: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [com.example....

8得票1回答
我能否确定Amazon SQS消息是否正在传递中?

在 Amazon SQS 中,是否有一种通过 API 判断消息是否仍处于传输状态的方法?或者说,我需要记录接收消息时的时间戳,将其减去当前时间,并检查该值是否小于可见性超时时间吗?

7得票2回答
如何强制AmazonSQSBufferedAsyncClient刷新消息?

我正在使用AWS SDK for Java,并使用缓冲异步sqs客户端批处理请求,以降低成本。 当我的应用程序关闭时,我希望确保没有消息在缓冲区等待,但是我看不到客户端上的.flush()方法。 AmazonSQSBufferedAsyncClient.shutdown()被调用时是否会刷...

8得票3回答
如何防止AWS SQS在Lambda函数触发器未能处理消息时删除该消息?

我部署了一个 AWS Lambda 函数,当 SQS 队列收到消息时会触发该函数。该函数向 Rest API 发送请求,如果响应不是“Ok”,则需要重新处理 SQS 消息。 这就是为什么我需要重新发送消息到队列中,但我更喜欢通过编程方式删除 SQS 消息,尽管我找不到如何配置 SQS 的方法...

13得票5回答
Amazon SQS的最佳实践 - 轮询队列

我正在为我们的电子商务网站设计一项发送电子邮件的服务(订单确认、提醒等)。计划是创建一个“SendEmail”方法,生成代表要发送的电子邮件的XML片段,并将其放入Amazon SQS队列中。我的Web应用程序和其他应用程序将使用此方法进行电子邮件的“发送”。 接下来,我需要一种检查队列并实...

9得票5回答
我该如何在Celery中指定SQS队列名称

我需要将redis代理替换为SQS代理,当我在谷歌上搜索时,我看到了很多页面,告诉我如何使用celery和SQS。据我所知,它会创建自己的SQS队列,但我只有一个任务,想要使用已经创建的SQS队列。

138得票4回答
SQS与RabbitMQ的比较

我需要创建一个用于处理的队列。 队列本身是相对低流量的。 每小时可能会有大约1000个写入操作。 每个任务的执行可能需要大约一分钟时间,并且几乎在项添加到队列时立即处理。 是否有任何原因,使我希望使用RabbitMQ而不是像Amazon SQS这样的现成解决方案? 为什么应用程序需要自己的队...

7得票2回答
如何编写用于S3事件的加密SQS策略声明?

我有一个SQS队列,它曾经有以下策略文档,用于接收来自存储桶的S3事件: { "Version": "2008-10-17", "Id": "example-ID", "Statement": [ { "Sid": "example-statement-ID"...

8得票3回答
如何在消息发布到 SQS 后延迟一段时间触发 Lambda?

我有一个Lambda配置,当消息发布到SQS队列时会触发它。以下是SAM模板以进行部署。 MyQueue: Type: AWS::SQS::Queue Properties: VisibilityTimeout: 180 DelaySeco...