amazon-sqs 相关问题

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

使用 RabbitMQ,我怎样才能像 AWS SQS SetMessageVisibility 或 Azure 更新锁一样获得滚动消息过期?

我已经使用 AWS SQS 队列构建了一个解决方案,并定期调用 SetMessageVisibility 以保持消息在消费者中隐藏(即仍在处理)。队列中的这些消息可以带

回答 0 投票 0

带缓冲区和超时的 Go writer

我想使用 Go 从 SQS 向 AWS 发送请求。有使用 v2 SDK 中的 sqs.SendMessageInput 在单事件模式下执行此操作的示例,但我想改为批量发送。我...

回答 2 投票 0

SQS 异步消费者,连接问题

在我的应用程序中,我有异步 SQS 消费者,这是官方文档中的示例: 类 MyListener 实现 MessageListener { @覆盖 public void onMessage(消息消息){ ...

回答 0 投票 0

如何连接 lambda --> RDS postgres DB

我创建了我的节点应用程序的图像,它将更新数据库中的值。图像在 lambda 中。在 cloud9 上,该功能可以正常工作,但是当我使用 SQS 触发它时

回答 0 投票 0

SQS ReceiveMessage 和 SendMessage 似乎不适用于 Lambda

情况 我使用由 SQS 触发的 Lambda,并为我的 100 个队列设置了以下设置: 可见性超时:330 秒 ReceiveMessageWaitTimeSeconds:20 秒 以及事件源的设置

回答 0 投票 0

如何使用 springboot 在 SQS 监听器中更新 AWS STS 令牌

我正在使用 Springboot 创建一个 AWS SQS 监听器。我获得了联合用户标识、密码和角色。我必须使用此 id/pwd/role 调用客户 rest api,作为回报,我得到临时令牌 wh...

回答 0 投票 0

NestJS AWS SQS:找不到元数据:<QueueName>

我正在尝试在我的项目中配置@nestjs-sqs,但我越来越 警告 [SqsService] 找不到元数据: 我的模块是 模块({ 进口:[ ConfigModule.forRoot( {} ),

回答 0 投票 0

使用 webhooks 将 Github 与 Amazon SQS 集成

Github 已弃用集成和服务,建议改用 webhook 或 GitHub Apps。 我在这里怀疑 AWS SQS 需要经过身份验证的请求(https://docs.aws.amazon.com/

回答 2 投票 0

Amazon Linux 2 worker 重启失败

我正在连接到 SQS 的 Amazon Linux 2 工作实例上运行 Node.js 应用程序。 问题 一切运行良好,只是出于技术原因我需要定期重启服务器。做

回答 3 投票 0

Errno 13:权限被拒绝:“celerybeat-schedule”,Celery 在 AWS ECS 和 SQS 上运行

我有一个单独的 Celery Beat 和 Work 服务在 ECS 中运行。该工作人员与 SQS 的连接似乎正常。另一方面,The Beat 却给我带来了麻烦。我使用这些说明作为技术...

回答 1 投票 0

对多个事件源使用 RequestStreamHandler 并在批处理失败时拆分

我有一个用例(场景 1),我有一个 lambda,它侦听来自 DynamoDB 变化的运动流,如果在处理我返回的那批运动流中的任何记录时出现错误...

回答 0 投票 0

是否有相当于 AWS SQS 的 GCP?

我很好奇了解 GCP 的 PubSub 的实现。虽然 Pubsub 似乎指向遵循 Publish-Subscribe 设计模式,但它似乎更接近 AWS 的 SQS(队列)而不是 AWS SNS(那个......

回答 2 投票 0

SQS FIFO 队列,每条消息都有自己唯一的消息组 ID,当队列超过 10k 项时,对 0 进行长轮询

我有一个 FIFO 队列设置,其中发送的每条消息都带有保证的唯一消息组 ID。 DeduplicationScope = perMessageGroup FifoThroughputLimit = perMessageGroupId 我一直...

回答 0 投票 0

当应用程序关闭/进入睡眠状态时,如何使用 kpl 将记录作为批处理发送到运动流?

关于申请: 我有一个部署到 AWS Fargate 服务的 spring 应用程序。此应用程序使用来自 SQS 队列的数据。然后,应用一些逻辑并将这些数据发送到 Kinesis Stream。

回答 0 投票 0

AWS lambda 发送批量消息到 SQSClient 超时

在我的 nodejs lambda 函数中,aws SQSClient 将批处理请求发送到 dlq 队列 为什么我的发送请求总是因超时而失败? const sqs = new SQSClient({ region: process.env.AWS_REGION ?? 'eu-

回答 0 投票 0

如何在 AWS SQS 队列中的两条消息之间添加延迟?

伙计们。我正在开发像 TikTok、twitch 这样的直播应用程序,我们在这个项目中使用 AWS 服务。但我现在正在努力解决一个问题。我在直播期间收到用户的礼物......

回答 0 投票 0

需要使用 JMETER 或 LoadRunner(基于角色的身份验证)在 AWS SQS 中推送消息

我需要使用 JMeter 或 LoadRunner 在 AWS SQS 中推送消息。 我已经通过 AWS 查询 API 这个链接创建了一个查询 API,但它需要 AWS 访问密钥 ID,它是

回答 0 投票 0

AWS SQS JMS SDK MessageListener onMessage() 没有为每次调用分配不同的线程

我有一个要求,我必须编写一个 sqs 消费者,它从 AWS SQS 异步消费消息。我的假设是 JMS 是多线程的,并且对于 MessageListener 的每次调用

回答 0 投票 0

在 AWS 中配置 AWS SQS 死信队列以获取特定的错误消息

在 AWS SQS 中是否有任何方法可以仅将失败的消息与特定错误消息路由到 DLQ(死信队列)? 默认情况下,所有未处理的消息都发送到 DLQ。有什么办法吗

回答 0 投票 0

EventBridge 不会将事件放入 SQS 队列

我有一个事件总线,其规则将事件转发到 lambda 函数并且它工作正常。 我创建了一个 SQS 队列来接收相同的事件,但我遇到了问题。 活动规则为

回答 0 投票 0

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