如何使用boto3获取给定SQS队列的死信队列？
要使用boto3获取给定SQS队列的死信队列，可以按照以下步骤进行操作：
- 导入boto3库：在Python代码中导入boto3库，以便使用AWS SDK进行操作。
import boto3- 创建SQS客户端：使用boto3库创建SQS客户端对象，用于与SQS服务进行交互。
sqs_client = boto3.client('sqs')- 获取队列的URL：使用
get_queue_url方法获取给定队列的URL，需要提供队列的名称。
queue_name = 'your_queue_name'
response = sqs_client.get_queue_url(QueueName=queue_name)
queue_url = response['QueueUrl']- 获取队列属性：使用
get_queue_attributes方法获取队列的属性，需要提供队列的URL和属性名称。
attribute_name = 'RedrivePolicy'
response = sqs_client.get_queue_attributes(QueueUrl=queue_url, AttributeNames=[attribute_name])
redrive_policy = response['Attributes'][attribute_name]- 解析死信队列信息：解析获取到的RedrivePolicy属性，提取死信队列的URL。
import json
redrive_policy = json.loads(redrive_policy)
dead_letter_queue_url = redrive_policy['deadLetterTargetArn'].split(':')[-1]- 获取死信队列的属性：使用
get_queue_attributes方法获取死信队列的属性，需要提供死信队列的URL和属性名称。
attribute_name = 'QueueArn'
response = sqs_client.get_queue_attributes(QueueUrl=dead_letter_queue_url, AttributeNames=[attribute_name])
dead_letter_queue_arn = response['Attributes'][attribute_name]通过以上步骤，你可以使用boto3库获取给定SQS队列的死信队列的URL和属性信息。
请注意，以上代码示例中的your_queue_name需要替换为实际的队列名称。此外，还可以根据具体需求使用其他boto3提供的方法和属性来进一步操作和管理SQS队列和死信队列。
关于腾讯云相关产品和产品介绍链接地址，由于要求不能提及具体品牌商，建议参考腾讯云官方文档或咨询腾讯云官方支持获取相关信息。
相关·内容
我希望创建一个连接到死信队列的SQS队列。我希望将接收到但不能正确处理来自SQS队列的消息放到死信队列中。此外，我想设置这个做云形成。我看过了。但是我仍然对设置这个程序的过程有疑问。我看到了下面的代码片段，这些代码片段显示了如何做到这一点：
AWSTemplateFormatVersion: "2010-09-09"
Resources:
MySourceQueue:
Type: AWS::SQS::Queue
Properties:
RedrivePolicy:
deadLetterTargetArn:
浏览 1提问于2019-03-04得票数 4
对于SQS源队列及其DLQ如何处理消息处理，我有一个疑问。
我知道SQS不像JMS那样实现trasaction，而是使用带有超时的锁，以便其他订阅者可以在此超时过期后从队列中提取。
尽管如此，我如何实现下面的行为(使用更多的SQS配置而不是客户端实现)？
订阅者侦听SQS中的消息；
尝试处理信息；
如果失败了，它就会重试3次，例如；
如果重试尝试失败，我必须将消息发送到DLQ并从源队列中删除它。
浏览 1提问于2017-12-01得票数 0
回答已采纳
2回答
AWS SNS消息生存期
、、、
我有一个用例，我需要Amazon发送通知，直到我的应用程序(让我们称之为APP)成功地接收到通知为止，但是文档显示消息的最长寿命可以是1小时。
假设应用程序崩溃了，不可能在1小时内实时运行。我还是需要以某种方式接收这些信息。
它有多种实现方法：
来自SQS的APP投票。我不喜欢这个选项，因为它产生太多的网络流量之间的应用程序和AWS。
SNS同时向APP和SQS发送通知。如果应用程序能够接收到消息，它将立即将其从SQS中删除。如果应用程序无法接收消息(崩溃)，它可以在启动时从SQS加载消息并清理队列。
AWS代码作为消息传递服务。如果Lambda代码失败，它可以将消息推送到SQS死
浏览 22提问于2017-01-13得票数 6
我使用一个CloudFormation模板为SQS创建一个堆栈。我有一个SQS队列集，它依赖于另一个SQS队列，用作DLQ。当我创建堆栈时，我会得到以下错误：
Value {"deadLetterTargetArn":"arn:aws:sqs:eu-west-1:xxxxxxxxx:services-abc-dlq","maxReceiveCount":"10"} for parameter RedrivePolicy is invalid. Reason: Dead letter target does not exist.
如
浏览 1提问于2015-09-10得票数 6
回答已采纳
我正在使用SQS来保存http请求。如何使消息保持活动状态(在队列中)，以便在请求失败时重新处理，而不被另一个进程捕获？
浏览 0提问于2020-07-24得票数 0
我有一个lambda函数，它的触发器是SQS。当lambda执行时，它会抛出一个错误或不抛出错误。它将把作业放回队列中，并创建一个循环，您肯定知道AWS账单:)
我是否应该在lambda函数中返回一些内容，让SQS知道我得到了消息(完成了任务)？我该怎么写这条信息呢？据我所知，我们在SQS中没有ack和nack。
如果任何作业失败，SQS配置中是否有任何选项只能重试N次？
浏览 3提问于2021-11-20得票数 2
回答已采纳
1回答
我有SQS触发AWS，它需要做一些处理和上传到其他地方。我有一个死信与它有关的三次尝试。如果上传失败超过3次，那么它将被移动到死后队列。当我在SQS队列中接收消息时，我将获得消息属性，如下所示：
{ApproximateReceiveCount=3, SentTimestamp=123, SenderId=xyz-123, ApproximateFirstReceiveTimestamp=123}
现在上传API是固定的，当我尝试重新驱动AWS死信队列时，我将再次从1开始获取消息属性ApproximateReceiveCount，它必须从4开始
我有设置，就像当我们重新驱动器，然后它将回到原来
浏览 9提问于2022-10-31得票数 -1
1回答
当AWS死信队列中有项目时，需要通知业务。我们正在使用SQS。然而，我们不希望项目从死信队列中出来，当我们聆听它们时。如何才能做到这一点？
浏览 6提问于2022-01-07得票数 0
回答已采纳
我尝试过使用npm包，比如sqs-queue-parallel & sqs-consumer来消费节点中SQS的消息。
但是最近我有了一种机制，当一个特定的消息在处理过程中发生错误时，它应该被移到死信队列中
但到目前为止，它一直在按最大接收计数次数重试消息
对于其他一些npm包，是否有可能在发生错误时将其直接移到死信队列？
浏览 1提问于2016-04-29得票数 5
1回答
我有一个带有策略的队列：
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": "sns.amazonaws.com"
},
"Action": "sqs:SendMessage",
"Resource":
浏览 11提问于2022-06-06得票数 0
回答已采纳
目标
我想证明的概念。这是一个在sqs队列中放置消息和令牌的step函数，队列连接到一些任意的工作，当完成该工作时，您将step函数返回令牌，以便它知道要继续。
问题
我开始测试所有这些东西，在step函数中手动启动一个执行，在几次失败之后，我找到了应该起作用的东西。send_task_success被称为An error occurred (TaskTimedOut) when calling the SendTaskSuccess operation: Task Timed Out: 'Provided task does not exist anymore'，但我得到的只
浏览 8提问于2022-03-19得票数 0
1回答
目前，我们有一个订阅了标准SNS主题的sqs，该主题触发lambda将基于这些事件的一些数据发布到下游X。
我们带来了另一个用法，我们想要听这个退出的SNS，并发布基于这些事件的另一组数据到下游Y。将来，我们可能会有另一个用例，在这个用例中，我们希望侦听这个退出的SNS，并根据这些事件向下游Z发布另一组数据。
我想知道我们是否可以在这些新的用例中重新使用现有的SQS和lambda。我只是好奇，如果发布失败，我们如何处理失败场景。X之外的一个进程的失败将导致消息从需要重新驱动的地方返回到DLQ，所以这个消息的所有使用者进程在lambda中都会再次处理这个重驱动的消息？
另一种方法可以是为每个这样
浏览 18提问于2022-07-08得票数 0
我可以通过创建如下的Terraform数据源来获取SQS队列的URL。
data "aws_sqs_queue" "my-sqs-queue-name" {
name = "my-sqs-queue-name"
}
然后将其称为，
QUEUE_URL = data.aws_sqs_queue.my-sqs-queue-name.url
如何获取使用上述队列自动创建的死信队列的URL？
我想要像下面这样的东西。这有可能吗？
DEAD_LETTER_QUEUE_URL = data.aws_sqs_queue.my-sqs-queue-name.
浏览 1提问于2020-03-26得票数 1
如果消息发送到SQS，我正在尝试触发警报。但是，我看到CloudWatch指标表明有一条消息，但没有触发警报。
警报当前也处于INSUFFICIENT_DATA状态。为了测试，我通过boto3客户端发送了一条消息。
下面是我的SQS和CloudWatch报警的CloudFormation模板
QueueMessageAlarm:
Type: AWS::CloudWatch::Alarm
Condition: AlarmsEnabled
Properties:
AlarmDescription: "Alarm if queue message is greater than 0
浏览 70提问于2018-12-14得票数 0
回答已采纳
1回答
我有根据队列名称前缀过滤SQS队列的代码。但是，现在我想根据标签而不是“队列名称前缀”来过滤队列。有没有办法在boto3中做到这一点？ 下面是根据名称前缀过滤sqs队列的代码。此代码返回我的帐户中以名称"Queue“开头的所有SQS队列 import boto3
sqs = boto3.client('sqs')
response = sqs.list_queues(QueueNamePrefix = 'Queue')
queue_array = response["QueueUrls"]
print(queue_array)
浏览 12提问于2021-05-03得票数 1
我已经将lambda集成设置为SQS，它具有固定的保留并发性，以将请求传递到后端服务。我需要使用DLQ来跟踪和存储错误。
使用SQS的重驱动策略与lambda函数的DeadLetterConfig在行为上有什么不同？
当队列中有大量消息但具有有限的lambda并发性时，我对这种行为特别感兴趣。
浏览 0提问于2020-07-28得票数 1
回答已采纳
我配置了SQS + Lambda，一切都很好。我正在做一些模拟和发送信息，造成错误。当我这样做的时候，消息永远在运行，而lambda一直在执行。如何才能避免这种情况发生呢？
浏览 0提问于2018-09-27得票数 0
回答已采纳
2回答
我试图使用无服务器框架创建AWS SQS死信队列
这样做的目的是让SQS触发Lambda函数，
并将另一个SQS作为DeadLetterQueue，即。接收消息，以防Lambda失败或超时。
我做了下面的工作来创建一个测试项目-
mkdir dlq
cd dlq/
serverless create --template aws-nodejs
以下是我的serverless.yaml -
service: dlq
provider:
name: aws
runtime: nodejs12.x
region: ap-southeast-1
role: arn:aws:iam::
浏览 6提问于2020-07-16得票数 4
回答已采纳
1回答
Amazon消息消失
、、、
我有一个Amazon队列和一个死信队列。
我的python程序从SQS队列中获取一条消息，然后，如果它引发异常，它将将消息发送到死信队列。
现在，我有了一个程序，可以检查死信队列，如果这些消息仍然可以被处理。如果是，它将被发送回主SQS队列。你看，我在这里期望的是在我的测试中有一个无限的循环，但是很明显，消息在2次尝试后消失了。为什么是这样？
当我在消息中添加一个额外的字段(这是随机值)时，它以某种方式实现了我所期望的(来回发送的无限循环)。在SQS中是否有一种机制可以阻止我在消息相同时所做的事情？
def handle_retrieved_messages(self):
if not
浏览 0提问于2019-05-23得票数 0
很抱歉，我在文档中找不到这个时刻：
当sqs决定将消息从队列移动到死队列时，它是保留原始id还是为消息分配一个新的id？有没有保证它总是复制原始id，或者它可以复制，也可以不复制？
浏览 0提问于2017-10-31得票数 4
1回答
在使用boto3列出sqs队列时，是否可以将权限限制在函数可以拉出的队列数量上？
我目前正在使用boto3根据前缀提取队列列表：
sqs = boto3.client('sqs')
response = sqs.list_queues(
QueueNamePrefix = 'some-prefix'
)
我只能使这项工作符合以下政策：
{
"Action": "sqs:ListQueues",
"Effect": "Allow",
"Resource": &#
浏览 1提问于2021-08-04得票数 1
回答已采纳
1回答
我有一个由SNS主题触发的Lambda函数。如果Lambda达到了最大并发执行的极限，并且无法进一步扩展，那么发布到SNS主题的消息会发生什么呢？例如，假设我的SNS主题每秒接收1000条消息，但是Lambda只能扩展到每秒处理600条消息。根据我对SNS的了解，它是一个pub/sub机制，不可能有任何积压(与SQS、Kinesis等不同)。那么，每秒额外的400条消息会发生什么呢？
另外，我如何监控我的Lambda是否能够以SNS接收消息的速度进行处理？
浏览 0提问于2018-03-28得票数 2
我有一个基本的SQS队列，它用重驱策略触发Lambda，在5次重试后将失败的消息发送到DLQ。
除了当我查看DLQ中的消息时，我没有看到来自Lambda的任何ErrorCode、ErrorMessage属性。有人把这个搞定了吗？
浏览 0提问于2019-04-03得票数 2
回答已采纳
我计划使用AWS FIFO SQS来记录我的数据存储中每个项目的当前状态。我将使用每个项目的唯一标识符作为messageGroupId，以确保对每个项的消息进行严格排序。
SQS是否确保如果属于特定组的消息在DLQ中，那么在DLQ消息被删除或重新驱动回主队列之前，来自该组的消息对使用者是不可见的吗？
例如，可以按顺序接收以下三条消息：
(groupIdA, M1)
(groupIdA, M2)
(groupIdA, M3)
我的计票器成功地使用了M1，但未能处理M2。它会尝试，直到maxReceive计数耗尽，消息被SQS推送到DLQ。现在，我仍然有另一条消息M3在等待被消耗。我希望确保M3只
浏览 4提问于2022-06-04得票数 0
回答已采纳
使用Elastic Beanstalk，我从管理控制台创建了worker 1.1层(运行Ruby 1.9.3的64位Amazon Linux 2014.03 v1.0.3 )。当涉及到配置工作进程详细信息时，我选择了“自动生成队列”。当我这样做时，生成了两个SQS队列(worker和dead letter)，但是我的worker实例的"Worker queue URL“被设置为dead letter队列url。我想应该是工作队列吧？如果我尝试将其更改为worker配置中的worker队列，两个队列都将被删除(worker和死信)。谁能告诉我这是否是正常行为？
浏览 0提问于2014-06-12得票数 5
1回答
我有以下基于这个的核心模块
module "sqs" {
source = "github.com/terraform-aws-modules/terraform-aws-sqs?ref=0d48cbdb6bf924a278d3f7fa326a2a1c864447e2"
name = "${var.site_env}-sqs-${var.service_name}"
}
我想创建两个队列: xyz和xyz_dead。xyz将其死信消息发送给xyz_dead。
module "xyz_queue" {
source
浏览 1提问于2018-09-16得票数 1
1回答
我正在尝试使用boto3创建一对SQS队列。第一个是第二个的死信队列。
def create_queues(qname):
# create a fifo queue with a deadletter queue
dl_queue = sqs.create_queue(
QueueName=f'{qname}-dead-letter.fifo',
Attributes={'FifoQueue': "true"}
)
dl_arn = dl_queue.attributes[
浏览 8提问于2022-03-22得票数 0
1回答
根据事件的不同，我们有一个从30秒到5分不等的过程。我们的基本架构如下(python3.9，从boto3到send_message到sqs)：
lambda函数A查找数据库并决定事件
事件被推入标准的SQS队列(VisibilityTimeout: 600)
lambda函数B是由SQS队列从(2)点触发的--由于我们希望同时处理一条消息，触发器的BatchSize设置为1，函数的ReservedConcurentExecutions也设置为1，函数超时为600。
配置了VPC和NAT网关。
我们注意到，后续消息总是每隔10分钟处理一次，尽管函数调用是提前完成的。我们打算更
浏览 5提问于2022-03-26得票数 1
回答已采纳
工作原理:使用AWS-SQS SDK for .Net，我能够在消息可见性计时器窗口中接收一批消息并删除单个消息。我也不能做任何事情，并有效地重新排队消息，如果它被重新排队配置的次数，它就会变得死气沉沉。
不起作用的是:我正在尝试使用Lambda做同样的事情。我已经创建了一个触发器，这意味着SQS会触发lambda，向其发送一批消息。当这种情况发生时，这些消息似乎会自动从队列中删除。我无法控制删除单个消息或将其重新排队。
在lambda中抛出异常似乎会使批处理中的所有消息都保留在队列中。有没有一种更优雅的方法来做这件事，还有一种方法是针对单个消息而不是整个批次？
浏览 1提问于2019-03-12得票数 1
2回答
如何使用AWS实现死信队列
、、、、
我试图为失败的lambda事件实现一个死信队列。我创建了一个SQS队列和两个lambda。一个lambda只抛出一个错误，另一个侦听SQS队列，并在队列收到消息并将事件记录到Cloudwatch时触发。
在AWS管理控制台中，我可以看到.function lambda (抛出错误的那个)配置了一个死信队列。
我能够看到.dispatcher函数(监听SQS的函数)配置正确，如果我向SQS队列发送消息，我还可以看到Cloudwatch日志显示它正按预期被触发。
尽管所有的配置似乎都是正确的，但我无法让.function在事件失败时将事件发送到SQS，以便触发.dispatcher lambda。
浏览 16提问于2022-08-20得票数 -1
回答已采纳
2回答
我有一个烧瓶应用程序，每当碰到端点时，它都需要与SQS服务交互。我在本地模拟SQS服务，使用码头映像sukumarporeddy/sqs:fp，它的基本映像是，配置中还添加了两个队列。
我需要从另一个应用程序访问该服务，该应用程序以app_service的形式运行。这两个服务是使用docker-compose.yml文件运行的，我在这里提到了两个服务。
app_service
sqs_service
在构建应用程序映像时，我将环境变量设置为将sqs_service作为QUEUE_ENDPOINT=http://sqs_service:9324访问。但是当我尝试访问应用程序sqs_service
浏览 4提问于2019-10-09得票数 1
回答已采纳
1回答
我已经创建了一个SQS队列，现在我想从我的lambada函数读取数据。我已经将触发器从SQS配置到这个lambada函数。 当我将消息放入SQS队列时，当我单击Flight.But函数中的测试时，它会显示1条消息。 错误 {
"errorMessage": "module initialization error"
} 我正在使用下面的boto3 import boto3
sqs = boto3.client('sqs')
queue_url = 'https://sqs.us-east-1.amazo
浏览 22提问于2019-03-06得票数 0
回答已采纳
在我看来，这似乎是一个简单的用例，但结果比我预想的要困难得多。
问题
我有一个AWS充当一个作业队列，它会触发一个工人AWS。但是，由于worker lambda共享不可伸缩的资源，因此必须将并发运行lambda的数量限制在(例如)不超过5个同时运行的lambda。
根据的说法，很简单
保留并发也限制了函数的最大并发性，并应用于整个函数。
但是，SQS似乎完全忽略了将Reserved concurrency-property设置为5，在我的示例中，队列Messages in Flight-property显示的并行执行接近20-30次，具体取决于队列中的消息数量。
问题
我最接近的解决
浏览 0提问于2020-04-08得票数 6
1回答
我正在处理一个需求，您需要将表单提交到RDS数据库中。表单不应大于20 be。表单提交可能会出现尖峰，我们可能需要支持300,000个并发用户。
有几个选择我可以想到
1)客户端-> Api网关-> lambda -> S3 (触发器) -> lambda ->RDS
2) Client -> Api网关-> lambda -> SQS (触发器) -> lambda ->RDS
在第二种方法中，lambda (粗体)也将存储在S3 (未显示)中，以持久存储表单，以防我需要返回并重新处理它们。
我们需要考虑的是
1)写入吞吐量(将
浏览 1提问于2020-01-23得票数 0
1回答
我有一个由SQS触发的lambda，但是我希望在较低的环境中禁用事件触发器。
如果还有发布到该SQS的其他部分，那么消息会发生什么情况？在SQS上没有DLQ。消息会在MessageRetentionPeriod启动后消失吗？
浏览 6提问于2021-11-30得票数 0
回答已采纳
4回答
我们有客户使用的web应用程序，他们可以选择创建报告。报告包含电子邮件和预定时间(Ex:每天上午9点)。
当计划的时间与当前时间匹配时，web应用程序会做一些工作，并将结果发送到电子邮件。
我有一个需求，我需要在swf之上实现可伸缩的cron体系结构。
我需要的体系结构如下所示：
用户创建报告(已完成)
Webapp将报表保存到db，并通过SQS(简单查询服务)将报表数据和计时器发送到cron微服务。(已完成)
Cron微服务读取传入的SQS消息，并在经过定时器时发回SQS消息。(需要这个)
Webapp读取SQS消息，触发数据分析器和Emailer函数发送分析数据。(已完成)
浏览 0提问于2018-11-05得票数 3
回答已采纳
我有一个lambda函数，我想为此创建一个SQS死信队列。我首先在terraform中创建SQS：
resource "aws_sqs_queue" "my_lambda_dlq" {
name = "my_lambda_dlq"
delay_seconds = 90
max_message_size = 2048
message_retention_seconds = 86400
receive_wait_time_seconds = 1
浏览 8提问于2020-11-30得票数 0
回答已采纳
4回答
我正在使用python中的boto3客户端。我正在将消息推送到sqs，但接收它们的顺序错误。我可以看到他们的发送时间是正确的。
队列是这样创建的：
boto_session = boto3.Session(region_name=..,aws_access_key_id=.., aws_secret_access_key=...)
sqs_client = boto_session.resource('sqs', endpoint_url=endpoint_url)
sqs_client.create_q
浏览 6提问于2016-10-31得票数 6
1回答
这是我的设计：
一个码头化的环境，它为RoR后端和ReactJS前端提供了独立的坞容器。我希望将事件发布到AWS队列，并希望根据SQS中的消息对MongoDB执行操作。SQS已经被设置用于跟踪两个不同的桶上的事件，比如bin和bin。E是什么？
事件的流动：
在发布到SQS的bin -> Message1上有一个上载事件。
接收方从SQS读取message1并决定执行action1 -> message2发布到SQS。
action1完成-> message3发布到SQS
接收方读取message3，并决定更新Mongo以反映正在执行的此操作。
我的问
浏览 4提问于2015-09-18得票数 0
假定在读取SQS数据的过程中会出现问题，并利用SQS的数据再次进行处理。
在这种情况下，是否有任何函数保存SQS的数据？
作为假设的例子：
使用+ fargate处理过程中发生错误
保存SQS的数据
操作人员确认了疏散数据和异常内容。据判断，重传是可能的。
使用保存的数据再次执行处理
浏览 1提问于2019-02-20得票数 0
回答已采纳
1回答
我一直在开发一个小型Spring应用程序，它接收来自Amazon的消息。然而，我预见到处理这些消息可能会失败，所以我认为添加一个死信队列是个好主意。
但是有一个问题:当处理失败时(我通过对某些消息抛出异常来强制处理)，以后不会重新尝试，也不会将它移到死信队列中。我很难找到这个问题，因为它似乎没有太多的信息。
然而，如果我看一下，他们似乎能够做到这一点，但是没有使用Spring注释。有什么办法可以让下面的代码在不编写太多JMS代码的情况下工作事务性的呢？
这是我正在使用的当前配置。
@Configuration
public class AWSConfiguration {
@Valu
浏览 3提问于2016-12-14得票数 6
回答已采纳
1回答
我已经设置了一个SQS，DeadLetterQue (DLQ)和lambda。我有一些关于SQS接收到的主体格式的问题。经过一些尝试，我可以看到一些消息在DLQ中结束。
我读过很多文件，但实际上我还是想不出一些基本的东西。
我的任务相当简单。我将使用Axios向外部API发送一些有效负载。那个API可能会给我一个错误，或者在那个时候不可用。这段代码非常简单，但最后它将包括Axios实现：
exports.handler = async (event, context) => {
event.Records.forEach(record => {
const {
浏览 1提问于2019-02-07得票数 0
回答已采纳
2回答
我有一个SQS队列，使用来拥有以下策略文档。用于从桶中接收S3事件：
{
"Version": "2008-10-17",
"Id": "example-ID",
"Statement": [
{
"Sid": "example-statement-ID",
"Effect": "Allow",
"Principal": {
"AWS": "
浏览 6提问于2017-06-16得票数 7
回答已采纳
1回答
我试图从AWS中建立一个SQS队列，我的目标是
接收来自sns主题的通知，该主题基本上来自亚马逊市场。
当新消息传入时，我需要通知我的应用程序，随着消息一起接收到新消息，或者至少通知有一条新消息。
有办法做到这一点吗？从文档中我可以看到，我们可以使用sdk接收消息，我使用的是Node、Express、。我应该继续用一个时间间隔来检查sqs吗？我相信应该有更好的方法。
浏览 0提问于2018-08-27得票数 3
我想在每次向我的DLQ添加消息时触发AWS cloudwatch警报。我正在使用云信息来部署我的sqs/dlq资源，但我不知道如何配置这种类型的警报。
浏览 22提问于2019-10-30得票数 4
2回答
我正在尝试从FIFO sqs队列中获取消息。以下是示例代码：
import boto3
sqs_client = boto3.resource(
'sqs',
#aws_access_key_id=AWS_ACCESS_KEY,
#aws_secret_access_key=AWS_SECRET_ACCESS_KEY,
region_name='us-east-2'
)
queue_name = 'test_queue.fifo'
response = sqs_client.create_queue(
浏览 2提问于2017-09-06得票数 0
我有lambda触发器，它从SQS队列读取消息。在某些情况下，消息可能还没有准备好进行处理，所以我想将消息放回队列中1分钟，然后再试一次。目前，我正在创建该客户记录的另一个副本，并在队列中发布这个新副本。与创建新记录相比，我是否有理由/方法将原始记录保留在队列中？
def postToQueue(customer):
if 'attemptCount' in customer.keys():
attemptCount = int(customer["attemptCount"]) + 1
else:
attemp
浏览 1提问于2018-12-16得票数 1
2回答
我正在考虑使用SNS-SQS服务来向运行相同服务的计算机提供更新。由于计划不是让机器相互通信，因此我计划为每台机器创建一个SQS (SQS将在启动时创建)。
然而，我不确定在这种情况下如何使用死信队列(DLQ)。每个SQS是否应该有自己的DLQ，或者我是否可以有一个通用的DLQ，以便在区域内的所有SQS之间共享？我对前一种方法的担忧是会创建太多的队列(2台机器)，而对后一种方法的担忧是队列中可能存在同一消息的多个副本。
使用多个SQS队列时，最佳实践和推荐方法是什么？
浏览 0提问于2018-03-07得票数 0
1回答
我正在尝试使用AWS的SNS和SQS实现扇出架构。将有一个FIFO主题，订阅了几个FIFO队列，每个队列都有自己的过滤策略，如本文所示
在上面的文章中，他有一个我想要避免的全捕获队列。假设我有一个主题T和两个队列Q1和Q2订阅它。Q1接受“狗”，Q2接受“猫”。
我的问题是：
如果有人用马发布消息，会发生什么？
我如何处理没有被任何队列接收的消息？SNS DLQ最终会收到马消息还是会被丢弃？
谢谢
浏览 4提问于2022-04-06得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
