amazon-sqs 相关问题

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

如果处理时出现错误,更新SQS消息

嗨,我有两个 lambda,例如:L1 和 L2。 L1 创建 SQS 消息并将其发送到我的 SQS 队列。 例子: queue.send_message(MessageBody='boto3', MessageAttributes={ '作者': { '字符串值': '

回答 1 投票 0

连接到 FIFO Topic 的 FIFO 队列不会接收后续消息

我正在使用 AWS SQS 和 SNS fifo 变体来创建一种管理整个系统事件的简单方法。作为序言,我的系统真的很小而且没那么复杂,但我决定它......

回答 1 投票 0

AWS SQS 从 Lambda 重新驱动时出错 - boto3 AttributeError:SQS 客户端对象没有属性“start_message_move_task”

我正在尝试从 AWS Lambda 执行启动 DLQ 重新驱动的方法。根据文档,boto3 版本必须为 1.34.44 或更高版本。 lambda 有 1.34.9 作为 boto3 版本和 Python 版本...

回答 1 投票 0

AWS SQS 错误:SignatureDoesNotMatch HTTP 错误:403

我正在制作面部跟踪思想视频 AWS Rekognition (StartFaceSearch)。它将返回作业 ID。我已经设置了 SQS SNS 的所有部分。我的问题是我无法收到消息...

回答 2 投票 0

将消息从SNS批量投递到SQS

我正在将消息发送到 SNS,然后将消息重新分发到 SQS 标准队列。每个队列都有一个单独的 SNS 订阅,并具有自己的过滤策略。消息量很大...

回答 1 投票 0

Fifo-SQS lambda 触发故障处理

我们的系统使用 Fifo SQS 队列来驱动 lambda。以下是我们的 SAM 模板: 事件解析器触发队列: 类型:AWS::SQS::队列 特性: 消息保留期:1209600 # 14 D...

回答 1 投票 0

CloudTrail 可以在事件历史记录中记录 SQS ReveiceMessage 和 SendMessage 事件吗?

我有 CloudTrail 记录我的 SQS 队列的事件,但我看到的唯一与 SQS 相关的事件是 CreateQueue 和 DeleteQueue。我正在尝试让 CloudTrail 将 ReceiveMessage 和 SendMessage SQS 事件记录为

回答 2 投票 0

根据自定义 Cloudwatch 指标的多个条件缩放 AWS EKS 中的副本

我对 EKS 相当陌生。我想根据 SQS 队列中的消息数量进行自动缩放。我读过有关 kubernetes 中的 HPA 的内容(https://kubernetes.io/docs/tasks/run-application/horizontal-pod-auto...

回答 1 投票 0

AWS FIFO SQS:当消息陷入 DLQ 时,SQS 如何维护组中的排序?

我计划使用 AWS FIFO SQS 来记录数据存储中每个项目的当前状态。我将使用每个项目的唯一标识符作为 messageGroupId 以确保严格排序

回答 1 投票 0

在哪里可以更改触发 AWS Lambda 函数的 SQS 队列的批量大小?

我可以发誓,有一种简单的方法可以更改配置为 Lambda 触发器的 SQS 队列的批量大小,但截至 2020 年 7 月,我再也找不到这种情况发生的地方。这可能...

回答 5 投票 0

localstack aws sdk sqs 中的反序列化错误

我正在运行我的expressjs应用程序,并尝试使用aws sdk v3将消息(字符串化对象)推送到队列(本地堆栈)中。 awslocal sqs create-queue --queue-name my-queue “@aws-sdk/clie...

回答 1 投票 0

尽管可见性超时,但为什么会多次收到 SQS 消息?

我有一条 SQS 消息,其“接收计数”为 16。但是,SQS 队列的可见性超时为 2 小时,并且该消息仅在几个小时前“发送”。不应该吗

回答 1 投票 0

Celery + SQS - pycurl 错误

今天我一直在尝试使用 AWS SQS 作为代理来设置 Celery,但是在执行以下命令时: 测试.py 从芹菜进口芹菜 access_key_id = '********************'

回答 6 投票 0

尝试从 ECS 写入 SQS 时出现区域未提供错误

我有一个带有 python 脚本的容器,它每次都会从 RDS 数据库中连续读取数据。每次读取都可以将一些数据发送到 SQS 队列。 导入boto3 队列=boto3.resource('sqs')

回答 1 投票 0

Mongoose 游标eachAsync 会造成内存泄漏

我想使用 Mongoosecursor.eachAsync 迭代 1000 个文档,批量大小为 10。有时它会造成内存泄漏。每次数据迭代都将发送到 AWS SQS 队列以进行进一步处理。 ...

回答 1 投票 0

在 SQS 消息上生成自己的 AWS 跟踪标头不会阻止 Lambda 上的递归循环

我正在设计一个系统解决方案,其中 SQS 队列触发 Lambda,队列接收大量用于逻辑分组(例如 execId)的消息。 lambda 以 ba 的方式从队列中读取消息...

回答 1 投票 0

无法使用Java和TestContainers获取AWS SQS队列的属性

下面的代码重现了我在一些测试中看到的问题。我们 启动一个测试容器 创建 SQS 客户端 使用该客户端创建队列 尝试查找队列 ARN 队列

回答 1 投票 0

SQS 不删除消息并运行无限循环

我是 AWS SQS 的新手。我正在尝试实现一个简单的服务器到节点 SQS 服务,其中多个节点向服务器发送一些信息(关于自身的一些标识),这是服务器需要的......

回答 2 投票 0

如何将相同的 Amazon S3 事件定向到多个不同的 SQS 队列?

我正在使用 AWS Lambda 函数(使用 Python),该函数处理出现在同一 Amazon S3 存储桶和文件夹中的新文件。 当新文件出现在 s3:/folder1/folderA,B,C 中时,发生事件 s3:

回答 3 投票 0

如何按顺序处理事件,但 1 名员工只有 1 个活动进程?

我正在研究一个用例,其中我们有多个来自上游的事件,并且我们可能会有 1 名员工的多个事件。但我们要确保只有 1 个...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.