Amazon Simple Queue Service(Amazon SQS)提供可靠,高度可扩展的托管队列,用于在计算机之间传输消息。
根据自定义 Cloudwatch 指标的多个条件缩放 AWS EKS 中的副本
我对 EKS 相当陌生。我想根据 SQS 队列中的消息数量进行自动缩放。我读过有关 kubernetes 中的 HPA 的内容(https://kubernetes.io/docs/tasks/run-application/horizontal-pod-auto...
AWS FIFO SQS:当消息陷入 DLQ 时,SQS 如何维护组中的排序?
我计划使用 AWS FIFO SQS 来记录数据存储中每个项目的当前状态。我将使用每个项目的唯一标识符作为 messageGroupId 以确保严格排序
在哪里可以更改触发 AWS Lambda 函数的 SQS 队列的批量大小?
我可以发誓,有一种简单的方法可以更改配置为 Lambda 触发器的 SQS 队列的批量大小,但截至 2020 年 7 月,我再也找不到这种情况发生的地方。这可能...
localstack aws sdk sqs 中的反序列化错误
我正在运行我的expressjs应用程序,并尝试使用aws sdk v3将消息(字符串化对象)推送到队列(本地堆栈)中。 awslocal sqs create-queue --queue-name my-queue “@aws-sdk/clie...
我有一条 SQS 消息,其“接收计数”为 16。但是,SQS 队列的可见性超时为 2 小时,并且该消息仅在几个小时前“发送”。不应该吗
今天我一直在尝试使用 AWS SQS 作为代理来设置 Celery,但是在执行以下命令时: 测试.py 从芹菜进口芹菜 access_key_id = '********************'
我有一个带有 python 脚本的容器,它每次都会从 RDS 数据库中连续读取数据。每次读取都可以将一些数据发送到 SQS 队列。 导入boto3 队列=boto3.resource('sqs')
我想使用 Mongoosecursor.eachAsync 迭代 1000 个文档,批量大小为 10。有时它会造成内存泄漏。每次数据迭代都将发送到 AWS SQS 队列以进行进一步处理。 ...
在 SQS 消息上生成自己的 AWS 跟踪标头不会阻止 Lambda 上的递归循环
我正在设计一个系统解决方案,其中 SQS 队列触发 Lambda,队列接收大量用于逻辑分组(例如 execId)的消息。 lambda 以 ba 的方式从队列中读取消息...
无法使用Java和TestContainers获取AWS SQS队列的属性
下面的代码重现了我在一些测试中看到的问题。我们 启动一个测试容器 创建 SQS 客户端 使用该客户端创建队列 尝试查找队列 ARN 队列
我是 AWS SQS 的新手。我正在尝试实现一个简单的服务器到节点 SQS 服务,其中多个节点向服务器发送一些信息(关于自身的一些标识),这是服务器需要的......
如何将相同的 Amazon S3 事件定向到多个不同的 SQS 队列?
我正在使用 AWS Lambda 函数(使用 Python),该函数处理出现在同一 Amazon S3 存储桶和文件夹中的新文件。 当新文件出现在 s3:/folder1/folderA,B,C 中时,发生事件 s3:
我正在研究一个用例,其中我们有多个来自上游的事件,并且我们可能会有 1 名员工的多个事件。但我们要确保只有 1 个...
这是我的简单代码: @成分 @Slf4j @RequiredArgsConstructor 公共类 SQSEventsService { 私有静态最终字符串MESSENGER_QUEUE =“messengerQueue”; 私人...
当消息移动到DLQ时,是否可以获取源队列中发生的错误?如果是,我怎样才能得到错误?标题中有一些信息吗? 我有一项服务列出...
使用 localstack SQS 作为无服务器离线 lambda 的事件源
在无服务器离线状态下有一个node.js lambda,我想使用localstack SQS作为事件源来调用它。 我从这里获取了 localstack 版本: https://github.com/localstack/localstack 和
我想自动将对象从第一个 s3 存储桶移动到第二个存储桶。创建文件或将文件上传到第一个存储桶时,应将其移动到第二个存储桶。应该有...
AWS 死信队列消息上的原因属性用于过滤要重新发布到主队列的消息?
是否有某个配置设置可以让 lambda 或 SQS 在消息发送到 DLQ 时添加原因属性? 消息可能因错误或通过......而最终进入死信队列。
我从提供商 API 一次接收多个 json 项目更新,并且不控制可以接收多少,因为有时可以有 1 个项目,有时可以有 100k 个项目。 这些物品是...
抱歉,如果这是一个新手问题。但我试图了解我应该使用什么。据我了解卡夫卡是: Apache Kafka 是一个分布式发布订阅消息系统。 还有SNS...