Amazon Simple Queue Service(Amazon SQS)提供可靠,高度可扩展的托管队列,用于在计算机之间传输消息。
AWS 死信队列消息上的原因属性用于过滤要重新发布到主队列的消息?
是否有某个配置设置可以让 lambda 或 SQS 在消息发送到 DLQ 时添加原因属性? 消息可能因错误或通过......而最终进入死信队列。
我从提供商 API 一次接收多个 json 项目更新,并且不控制可以接收多少,因为有时可以有 1 个项目,有时可以有 100k 个项目。 这些物品是...
抱歉,如果这是一个新手问题。但我试图了解我应该使用什么。据我了解卡夫卡是: Apache Kafka 是一个分布式发布订阅消息系统。 还有SNS...
我正在尝试弄清楚如何配置 celery,以便在消息按照配置传递 max_retries 后将其移动到死信队列。 目前正在删除(确认)超出的消息
使用 @aws-sdk/client-sqs npm 包从 EKS 集群 pod 推送到 AWS SQS 时出错
我在 AWS EKS 集群中使用 @aws/client-sqs npm 包将消息推送到标准 SQS 队列并收到以下错误: CredentialsProviderError:169.254.170.23 不是有效的容器我...
当我的用例限制我按创建顺序处理消息且只能处理一次消息时,SQS FIFO 队列是否可以有多个使用者?
我有一个将从 SQS 队列中使用的服务,并且该服务的多个实例将在 EC2 或 Kubernetes Pod 上并行运行,以避免单点故障,现在我的队列是...
如何使用 Serverless 框架将 sns 的资源策略添加到 sqs
我在为我的 sqs 队列分配正确的策略时遇到问题,以便任何 sns 主题在该队列订阅时都可以向它发送消息。我尝试在服务中使用 UpdatePolicy 和 Metadata...
我正在使用 aws-java-sdk-sts',版本:'1.12.166' 尝试连接到 sqs 队列并从中读取消息并使用 Apache camel camel-aws-sqs:3.0.0 路由它们当我部署解决方案时,我...
AWS Lambda 未向 AWS SQS DLQ 发送错误消息
我正在尝试通过 terraform 创建一个由 Kinesis 触发的 lambda,并且她在失败时的目的地将是 AWS SQS。 我创建了 lambda 并配置了源和目标 当我发送...
我们通过引入 aws sqs(简单队列服务)在应用程序中引入了异步处理。我们正在使用蓝/绿部署模型,当我们进行新部署时,我们会部署...
通过 Django Celery [sqs] 连接到 Amazon SQS 密钥 (SSE-SQS) 加密的 SQS 队列
连接到 SQS 加密队列时,我无法让我的 Celery 运行 这是我的 django 项目的 settings.py SQS_AWS_ACCESS_KEY_ID = 'xxxx' SQS_AWS_SECRET_ACCESS_KEY = 'xxxx'
我有一个超时为 3 分钟的 AWS Lambda 函数和一个可见性超时为 3 分钟的 SQS 队列。也许我不明白这里的一些东西,但为什么我的消息只会触发 lam...
AWS-SDK 问题 w/deleteMessageBatch,告诉我 MissingParameter 但我不是
我收到以下消息 UnhandledPromiseRejectionWarning:MissingParameter:请求必须包含参数DeleteMessageBatchRequestEntry.1.Id。 我想我正在遵循文档...
我有一个 aws lambda 函数。它将使用 SQS 触发。 lambda 时间为 15 分钟,SQS 队列可见时间为 16 分钟。当 lambda 即将超时时,我会继续...
我需要一些帮助来了解我在这里缺少的内容。 我使用的是 SQS FIFO 队列,其可见性超时设置为 2 分钟,并带有 lambda 触发器。现在我正在运行一个超级简单的代码,它就是
平均每月一次,我在 AWS EC2 计算机上运行的 Java 应用程序会失去与 AWS SQS 的连接: 尝试与服务交互时收到 UnknownHostException。参见...
我有以下 Cloudformation 模板,该模板使用传递到 SQS 队列的自定义 Lambda 授权方来部署 HTTP API 网关。我用另一个 lambda t 处理队列中的消息...
由于 SQS FIFO 队列中有大量积压,我们引入了一个新的消息组。没有看到任何来自新群组发送的消息
我们有一个 SQS FIFO 队列,有大量积压的消息需要通过。我们引入了一些发送到此队列的新消息组,以帮助在我们的
面临 SQS 队列实现的错误。我正在关注以下文档:https://docs.aws.amazon.com/sdk-for-javascript/v3/developer-guide/javascript_sqs_code_examples.html,但我面临...
我正在尝试通过 CloudFormation 为 DynamoDB 更新添加 SNS 过滤器,但似乎后一个过滤器不支持 null,而我需要通过可空字段添加过滤器。 我的目标是获取更新...