/usr/lib/python2.6/site-packages/boto/sqs
Edit: /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyc (3898B)
Ñò
Å-õSc @ sR d d k Z d d k Z d d k l Z d d k l Z d e f d „ ƒ YZ d S( iÿÿÿÿN( t
RawMessage( t SQSDecodeErrort
BigMessagec B sM e Z d Z d d d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( s±
The BigMessage class provides large payloads (up to 5GB)
by storing the payload itself in S3 and then placing a reference
to the S3 object in the actual SQS message payload.
To create a BigMessage, you should create a BigMessage object
and pass in a file-like object as the ``body`` param and also
pass in the an S3 URL specifying the bucket in which to store
the message body::
import boto.sqs
from boto.sqs.bigmessage import BigMessage
sqs = boto.sqs.connect_to_region('us-west-2')
queue = sqs.get_queue('myqueue')
fp = open('/path/to/bigmessage/data')
msg = BigMessage(queue, fp, 's3://mybucket')
queue.write(msg)
Passing in a fully-qualified S3 URL (e.g. s3://mybucket/foo)
is interpreted to mean that the body of the message is already
stored in S3 and the that S3 URL is then used directly with no
content uploaded by BigMessage.
c C s& | | _ t t | ƒ i | | ƒ d S( N( t s3_urlt superR t __init__( t selft queuet bodyR ( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyR 8 s c C s˜ d } } | o} | i d ƒ oT | d i d d ƒ } | d } t | ƒ d j o | d o | d } qq qŠ qŽ d } t | | ƒ ‚ n | | f S( Ns s3://i t /i i s( s3_url parameter should start with s3://( t Nonet
startswitht splitt lenR ( R R t bucket_namet key_namet
s3_componentst msg( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyt _get_bucket_key< s
c C s‹ | i | i ƒ \ } } | o | o | i St i ƒ } t i ƒ } | i | ƒ } | i | ƒ } | i | ƒ d | | f | _ | i S( s
:type value: file-like object
:param value: A file-like object containing the content
of the message. The actual content will be stored
in S3 and a link to the S3 object will be stored in
the message body.
s
s3://%s/%s( R R t uuidt uuid4t botot
connect_s3t
get_buckett new_keyt set_contents_from_file( R t valueR R t s3_connt s3_buckett key( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyt encodeN s
c C so | i | ƒ \ } } | o6 | o/ t i ƒ } | i | ƒ } | i | ƒ } | Sd | } t | | ƒ ‚ d S( Ns Unable to decode S3 URL: %s( R R R R t get_keyR ( R R R R R R R R ( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyt _get_s3_objecta s
c C s" | | _ | i | ƒ } | i ƒ S( N( R R t get_contents_as_string( R R R ( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyt decodel s c C sA | i o | i | i ƒ } | i ƒ n t t | ƒ i ƒ d S( N( R R t deleteR R ( R R ( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyR# q s
N(
t __name__t
__module__t __doc__R
R R R R R" R# ( ( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyR s ( R R t boto.sqs.messageR t boto.exceptionR R ( ( ( s7 /usr/lib/python2.6/site-packages/boto/sqs/bigmessage.pyt
s