def _dequeue_json_message(self):
sqs = boto.connect_sqs(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET)
queue = sqs.create_queue(RESPONSE_QUEUE)
msg = queue.read()
if msg is not None:
data = simplejson.loads(msg.get_body())
bucket = data.get('bucket', None)
key = data.get("key", None)
queue.delete_message(msg)
if bucket is not None and key is not None:
return data
评论列表
文章目录