amazon-sqs 相关问题

Amazon Simple Queue Service(Amazon SQS)提供可靠,高度可扩展的托管队列,用于在计算机之间传输消息。

AWS 死信队列消息上的原因属性用于过滤要重新发布到主队列的消息?

是否有某个配置设置可以让 lambda 或 SQS 在消息发送到 DLQ 时添加原因属性? 消息可能因错误或通过......而最终进入死信队列。

回答 2 投票 0

DynamoDB 的大规模更新

我从提供商 API 一次接收多个 json 项目更新,并且不控制可以接收多少,因为有时可以有 1 个项目,有时可以有 100k 个项目。 这些物品是...

回答 1 投票 0

Kafka 还是 SNS 还是其他? [已关闭]

抱歉,如果这是一个新手问题。但我试图了解我应该使用什么。据我了解卡夫卡是: Apache Kafka 是一个分布式发布订阅消息系统。 还有SNS...

回答 3 投票 0

带有 SQS 代理和死信队列的 Celery

我正在尝试弄清楚如何配置 celery,以便在消息按照配置传递 max_retries 后将其移动到死信队列。 目前正在删除(确认)超出的消息

回答 3 投票 0

使用 @aws-sdk/client-sqs npm 包从 EKS 集群 pod 推送到 AWS SQS 时出错

我在 AWS EKS 集群中使用 @aws/client-sqs npm 包将消息推送到标准 SQS 队列并收到以下错误: CredentialsProviderError:169.254.170.23 不是有效的容器我...

回答 1 投票 0

当我的用例限制我按创建顺序处理消息且只能处理一次消息时,SQS FIFO 队列是否可以有多个使用者?

我有一个将从 SQS 队列中使用的服务,并且该服务的多个实例将在 EC2 或 Kubernetes Pod 上并行运行,以避免单点故障,现在我的队列是...

回答 1 投票 0

如何使用 Serverless 框架将 sns 的资源策略添加到 sqs

我在为我的 sqs 队列分配正确的策略时遇到问题,以便任何 sns 主题在该队列订阅时都可以向它发送消息。我尝试在服务中使用 UpdatePolicy 和 Metadata...

回答 1 投票 0

签名不匹配 - 相同的实现在不同的环境中工作

我正在使用 aws-java-sdk-sts',版本:'1.12.166' 尝试连接到 sqs 队列并从中读取消息并使用 Apache camel camel-aws-sqs:3.0.0 路由它们当我部署解决方案时,我...

回答 1 投票 0

AWS Lambda 未向 AWS SQS DLQ 发送错误消息

我正在尝试通过 terraform 创建一个由 Kinesis 触发的 lambda,并且她在失败时的目的地将是 AWS SQS。 我创建了 lambda 并配置了源和目标 当我发送...

回答 4 投票 0

禁用 ECS 应用程序不从 aws sqs 读取消息

我们通过引入 aws sqs(简单队列服务)在应用程序中引入了异步处理。我们正在使用蓝/绿部署模型,当我们进行新部署时,我们会部署...

回答 1 投票 0

通过 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'

回答 1 投票 0

AWS Lambda 函数未立即从 SQS 触发

我有一个超时为 3 分钟的 AWS Lambda 函数和一个可见性超时为 3 分钟的 SQS 队列。也许我不明白这里的一些东西,但为什么我的消息只会触发 lam...

回答 1 投票 0

AWS-SDK 问题 w/deleteMessageBatch,告诉我 MissingParameter 但我不是

我收到以下消息 UnhandledPromiseRejectionWarning:MissingParameter:请求必须包含参数DeleteMessageBatchRequestEntry.1.Id。 我想我正在遵循文档...

回答 2 投票 0

Lambda 和 SQS 触发器在 15 次迭代后停止

我有一个 aws lambda 函数。它将使用 SQS 触发。 lambda 时间为 15 分钟,SQS 队列可见时间为 16 分钟。当 lambda 即将超时时,我会继续...

回答 1 投票 0

SQS“飞行中”状态的消息:未正确删除

我需要一些帮助来了解我在这里缺少的内容。 我使用的是 SQS FIFO 队列,其可见性超时设置为 2 分钟,并带有 lambda 触发器。现在我正在运行一个超级简单的代码,它就是

回答 1 投票 0

从 EC2 到 SQS 的连接有时会丢失

平均每月一次,我在 AWS EC2 计算机上运行的 Java 应用程序会失去与 AWS SQS 的连接: 尝试与服务交互时收到 UnknownHostException。参见...

回答 1 投票 0

API网关自定义授权方内部服务器错误

我有以下 Cloudformation 模板,该模板使用传递到 SQS 队列的自定义 Lambda 授权方来部署 HTTP API 网关。我用另一个 lambda t 处理队列中的消息...

回答 1 投票 0

由于 SQS FIFO 队列中有大量积压,我们引入了一个新的消息组。没有看到任何来自新群组发送的消息

我们有一个 SQS FIFO 队列,有大量积压的消息需要通过。我们引入了一些发送到此队列的新消息组,以帮助在我们的

回答 1 投票 0

将消息发送到SQS队列时遇到类型不匹配错误

面临 SQS 队列实现的错误。我正在关注以下文档:https://docs.aws.amazon.com/sdk-for-javascript/v3/developer-guide/javascript_sqs_code_examples.html,但我面临...

回答 1 投票 0

通过CloudFormation添加SNS过滤策略

我正在尝试通过 CloudFormation 为 DynamoDB 更新添加 SNS 过滤器,但似乎后一个过滤器不支持 null,而我需要通过可空字段添加过滤器。 我的目标是获取更新...

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.