Amazon Simple Queue Service（Amazon SQS）提供可靠，高度可扩展的托管队列，用于在计算机之间传输消息。
对多个事件源使用 RequestStreamHandler 并在批处理失败时拆分
我有一个用例（场景 1），我有一个 lambda，它侦听来自 DynamoDB 变化的运动流，如果在处理我返回的那批运动流中的任何记录时出现错误...
我很好奇了解 GCP 的 PubSub 的实现。虽然 Pubsub 似乎指向遵循 Publish-Subscribe 设计模式，但它似乎更接近 AWS 的 SQS（队列）而不是 AWS SNS（那个......
SQS FIFO 队列，每条消息都有自己唯一的消息组 ID，当队列超过 10k 项时，对 0 进行长轮询
我有一个 FIFO 队列设置，其中发送的每条消息都带有保证的唯一消息组 ID。 DeduplicationScope = perMessageGroup FifoThroughputLimit = perMessageGroupId 我一直...
当应用程序关闭/进入睡眠状态时，如何使用 kpl 将记录作为批处理发送到运动流？
关于申请： 我有一个部署到 AWS Fargate 服务的 spring 应用程序。此应用程序使用来自 SQS 队列的数据。然后，应用一些逻辑并将这些数据发送到 Kinesis Stream。
AWS lambda 发送批量消息到 SQSClient 超时
在我的 nodejs lambda 函数中，aws SQSClient 将批处理请求发送到 dlq 队列 为什么我的发送请求总是因超时而失败？ const sqs = new SQSClient({ region: process.env.AWS_REGION ?? 'eu-
伙计们。我正在开发像 TikTok、twitch 这样的直播应用程序，我们在这个项目中使用 AWS 服务。但我现在正在努力解决一个问题。我在直播期间收到用户的礼物......
需要使用 JMETER 或 LoadRunner（基于角色的身份验证）在 AWS SQS 中推送消息
我需要使用 JMeter 或 LoadRunner 在 AWS SQS 中推送消息。 我已经通过 AWS 查询 API 这个链接创建了一个查询 API，但它需要 AWS 访问密钥 ID，它是
AWS SQS JMS SDK MessageListener onMessage() 没有为每次调用分配不同的线程
我有一个要求，我必须编写一个 sqs 消费者，它从 AWS SQS 异步消费消息。我的假设是 JMS 是多线程的，并且对于 MessageListener 的每次调用
在 AWS 中配置 AWS SQS 死信队列以获取特定的错误消息
在 AWS SQS 中是否有任何方法可以仅将失败的消息与特定错误消息路由到 DLQ（死信队列）？ 默认情况下，所有未处理的消息都发送到 DLQ。有什么办法吗
我有一个事件总线，其规则将事件转发到 lambda 函数并且它工作正常。 我创建了一个 SQS 队列来接收相同的事件，但我遇到了问题。 活动规则为
带有 SQS 的 Lambda 函数 - 并发函数甚至没有接近极限
我注意到许多其他问题都在谈论 lambda 并发性，但似乎没有一个与我的问题完全相同，所以这是一个新问题： 我有一个使用 python 的当前 lambda 函数
你好 Stack Overflow 社区， 我正在尝试了解 AWS SQS 消息中包含的元数据字段，我想知道是否有人可以帮助我了解“发件人帐户 ID”字段...
如何使用 botocore.stub.Stubber 在不影响 SQS 客户端行为的情况下对 SFN 客户端的响应进行存根
我正在使用存根来存根 stepfunction 的“get_execution_history”方法的响应，但看起来它也在影响 sqs 客户端。我已经使用 moto 库来模拟'sqs'服务......
我有一个 SQS 队列需要订阅一个 SNS 主题。 我正在尝试在创建订阅时启用基于属性的过滤。 我怎样才能有一个过滤策略来订阅消息
我们需要一个 Lambda 来批处理在不一致的时间基础上进入 S3 的文件集。 Lambda 每小时运行一次，需要处理自上次以来进入 S3 的所有文件
在我的 cloudformation 模板中，我的 SQS 队列具有以下内容： 输出队列策略： 类型：AWS::SQS::QueuePolicy 特性： 政策文件： 陈述： - 效果：“Allo...
从 S3 读取 Excel 文件并在 C# 中的 Lambda 函数中处理，其中 SNS 和 SQS 介于两者之间
我正在使用 .NET 6.0 来执行 AWS 的 Lambda 函数。 故事是这样的…… 将包含数据的 Excel 文件上传到 S3 存储桶，在 S3 属性部分为其创建事件通知，创建...
golang 中的 aws lambda 由 sqs 触发并出现类型错误
我正在开发一个由 API 网关和 SQS 触发的 lambda。 包主 进口 （ “语境” “调频” “日志” “github.com/aws/aws-lambda-go/events&
AWS Lambda 无法连接到 AWS SQS（VPC 端点）
我有一个 AWS Lambda 通过安全组连接到 VPC 中的 RDS 实例。将我的 AWS Lambda 放在 VPC 中意味着它无法访问公共互联网，除非我创建一个 VPC 端点。硅...
如何在 EC2 实例中使用 sqs-consumer 读取 SQS 消息？
我有一个 node.js。在使用 sqs-consumer 库从 SQS 读取消息的 EC2 实例中运行的守护进程。 我遇到的问题是消息被写入 SQS 但它们不是 cons...