AWS SQS boto3 send_message 返回“dict”对象没有属性“send_message”

问题描述 投票:0回答:2
  • 我是Python新手,我仍在学习它。
  • 我正在编写一个Python代码来向AWS SQS发送消息
  • 以下是我写的代码

    from boto3.session import Session
      session = Session(aws_access_key_id='**', aws_secret_access_key='**',
      region_name='us-west-2') 
      clientz = session.client('sqs') 
      queue = clientz.get_queue_url(QueueName='queue_name') 
      print queue responses = queue.send_message(MessageBody='Test')
      print(response.get('MessageId'))

    • 运行此代码时,它会返回

    {u'QueueUrl':'https://us-west-2.queue.amazonaws.com/@@/queue_name','ResponseMetadata':{'HTTPStatusCode':200,'RequestId':'@@ '}}

    回溯(最近一次调用最后一次): 文件“publisher_dropbox.py”,第 77 行,位于 响应=queue.send_message(MessageBody='测试')

    AttributeError:“dict”对象没有属性“send_message”

  • 我不确定“dict”对象是什么,因为我没有在任何地方指定它。

python amazon-sqs
2个回答
5
投票

我认为你混淆了 boto3 客户端 send_mesasge Boto3 客户端 send_message 与 boto3.resource.sqs 功能。

首先,对于boto3.client.sqs.send_message,您需要指定QueueUrl。其次,出现错误消息是因为您编写了错误的打印语句。

# print() function think anything follow by the "queue" are some dictionary attributes  
print queue responses = queue.send_message(MessageBody='Test')

此外,我不需要使用 boto3.session ,除非我需要显式定义备用配置文件或访问权限,而不是在 aws 凭证文件内进行设置。

import boto3 
sqs = boto3.client('sqs') 
queue = sqs.get_queue_url(QueueName='queue_name')
# get_queue_url will return a dict e.g.
# {'QueueUrl':'......'}
# You cannot mix dict and string in print. Use the handy string formatter
# will fix the problem   
print "Queue info : {}".format(queue)

responses = sqs.send_message(QueueUrl= queue['QueueUrl'], MessageBody='Test')
# send_message() response will return dictionary  
print "Message send response : {} ".format(response) 

0
投票
responses = sqs.send_message(QueueUrl= queue['QueueUrl'], MessageBody='Test')

这条回复线对我有用。出色的。谢谢

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