通过boto3订阅SNS主题时，我的SQS队列中没有收到任何消息。在

这是我使用的代码或API凭据的问题吗？与此帐户关联的IAM策略具有AWS PowerUser特权，这意味着它可以不受限制地访问SNS主题和SQS队列。在

当我通过AWS控制台(createtopic，createqueue，subscribe queue to topic)创建等效结构并使用boto3、awscli或AWS控制台发送消息时，消息会正确传递。在

我不认为这是代码的问题，因为SubscriptionArn返回正确？在

我在美国东部1号和亚太东南1号地区都试过了，结果是一样的。在

样本代码：#!/usr/bin/env python3

import boto3

import json

def get_sqs_msgs_from_sns():

sqs_client = boto3.client('sqs', region_name='us-east-1')

sqs_obj = boto3.resource('sqs', region_name='us-east-1')

sns_client = boto3.client('sns', region_name='us-east-1')

sqs_queue_name = 'queue1'

topic_name = 'topic1'

# Create/Get Queue

sqs_client.create_queue(QueueName=sqs_queue_name)

sqs_queue = sqs_obj.get_queue_by_name(QueueName=sqs_queue_name)

queue_url = sqs_client.get_queue_url(QueueName=sqs_queue_name)['QueueUrl']

sqs_queue_attrs = sqs_client.get_queue_attributes(QueueUrl=queue_url,

AttributeNames=['All'])['Attributes']

sqs_queue_arn = sqs_queue_attrs['QueueArn']

if ':sqs.' in sqs_queue_arn:

sqs_queue_arn = sqs_queue_arn.replace(':sqs.', ':')

# Create SNS Topic

topic_res = sns_client.create_topic(Name=topic_name)

sns_topic_arn = topic_res['TopicArn']

# Subscribe SQS queue to SNS

sns_client.subscribe(

TopicArn=sns_topic_arn,

Protocol='sqs',

Endpoint=sqs_queue_arn

)

# Publish SNS Messages

test_msg = {'default': {"x":"foo","y":"bar"}}

test_msg_body = json.dumps(test_msg)

sns_client.publish(

TopicArn=sns_topic_arn,

Message=json.dumps({'default': test_msg_body}),

MessageStructure='json')

# Validate Message

sqs_msgs = sqs_queue.receive_messages(

AttributeNames=['All'],

MessageAttributeNames=['All'],

VisibilityTimeout=15,

WaitTimeSeconds=20,

MaxNumberOfMessages=5

)

assert len(sqs_msgs) == 1

assert sqs_msgs[0].body == test_msg_body

print(sqs_msgs[0].body) # This should output dict with keys Message, Type, Timestamp, etc., but only returns the test_msg

if __name__ == "__main__":

get_mock_sqs_msgs_from_sns()

我收到以下输出：

^{pr2}$