amazon-sqs 相关问题

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

通过事件源映射进行 SQS LAMBDA 集成

我们假设以下场景: 我通过事件源映射集成了 Lambda 和 SQS。通过以下设置: 可见性超时 -> 60 秒 批量大小 -> 10 我收到了一个均匀的...

回答 1 投票 0

SQS FIFO队列,并触发lambda

我有一个 FIFO SQS, 和从该 SQS 触发的 lambda, lambda 触发器上的批量大小设置为 1, lambda 保留并发设置为 1。 并且 SQS 可见性超时设置为 2 分钟作为最大上午...

回答 1 投票 0

lambda 函数是否可以从唯一名称列表创建 SQS 队列,并为每个队列分配自己的 SendMessage 权限?

我有一个 lambda 函数,可以创建一堆消息。每条消息在其有效负载中都包含一个“类型”参数。我希望我的 lambda 函数将相同类型的消息发送给它自己的......

回答 1 投票 0

s3bucketnotifications 不适用于 localstack 和 docker

我的情况是这样的: 有一个 xml 通过预签名的 URL 上传到 Amazon S3。 文件上传到 S3 后,我们希望 SQS 队列通过 S3 事件通知了解情况。 一旦...

回答 1 投票 0

限制从 AWS DLQ 重新驱动

我想将失败的消息从DLQ重新驱动到源队列3次。我知道 DLQ 支持重新驱动到 SQS,但是有什么方法可以将重新驱动限制在某些特定时间吗?我可以选择一种

回答 1 投票 0

AWS:在 SAM template.yml 文件中获取 SQS url

如何将 SQS url 设置到 lambda 环境变量中? 例如,我们可以获取 DynamoDB 流的 URN: !GetAtt SuperTable.StreamArn 。 我想为 SQS uri 做类似的事情..

回答 1 投票 0

SQSPolicy 在堆栈创建期间失败

我似乎无法弄清楚是什么导致了这个失败。我参考了一篇文章。谁能告诉我可能导致此错误的原因是什么? 允许SNS2SQS策略: 类型:AWS::SQS::QueuePolicy 正确的...

回答 3 投票 0

无法执行 HTTP 请求:获取操作花费的时间超过配置的最大时间

我正在 AWS 中运行一个批处理作业,它使用来自 SQS 队列的消息并使用 akka 将它们写入 Kafka 主题。我创建了一个具有以下参数的 Sqs 异步客户端: 私人静态

回答 1 投票 0

允许跨区域访问AWS SQS队列

我有一个 AWS SQS 队列,其权限策略如下所示: { "版本": "2012-10-17", “Id”:“arn:aws:sqs:us-east-1:123123123:default_staging/

回答 1 投票 0

如何根据每种消息类型限制SQS队列接收者的最大并发数?

我的 lambda 函数返回一堆我想要发送到外部服务的请求。此外部服务的 api 具有以下速率限制: 参数: 类型:枚举 内容:列出...

回答 1 投票 0

使用boto3在SQS中创建fifo队列

任何人都可以帮我使用 boto3 在 sqs 中创建 fifo 队列吗?尝试过这个,但这不起作用 sqs.create_queue(QueueName='test', Attributes={'FifoQueue':'true'})

回答 2 投票 0

有没有办法为RDS的任何模式中的每个插入更新和删除操作触发AWS Lambda或SQS?

我正在弄清楚是否有任何方法可以为RDS的任何模式中的每个插入更新和删除操作触发AWS Lambda或SQS。 DynamoDb 提供 DDB 流,但不知道...

回答 1 投票 0

保留 SNS 主题订阅的策略

我正在使用 terraform 创建一个主题,将 SQS 队列订阅到该主题,然后将 lambda 订阅到该队列。每个资源的地形都保存在具有不同地形的单独存储库中...

回答 1 投票 0

如果处理时出现错误,更新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

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