def queue_json_message(doc, doc_key):
key_name = doc_key.name.replace(os.path.basename(doc_key.name), "message-%s.json" % str(uuid4()))
key = doc_key.bucket.new_key(key_name)
message_data = simplejson.dumps({'bucket': doc_key.bucket.name, 'key': doc_key.name, 'uuid': doc.uuid})
key.set_contents_from_string(message_data)
msg_body = {'bucket': key.bucket.name, 'key': key.name}
queue = boto.connect_sqs(settings.PDF_AWS_KEY, settings.PDF_AWS_SECRET).create_queue(REQUEST_QUEUE)
msg = queue.new_message(body=simplejson.dumps(msg_body))
queue.write(msg)
评论列表
文章目录