U W¨+dR&ã@sPddlmZGdd„deƒZGdd„deƒZGdd„deƒZGdd „d eƒZd S) é)Úsixc@s"eZdZdZddd„Zdd„ZdS) ÚBatcha  Used to construct a BatchGet request. :ivar table: The Table object from which the item is retrieved. :ivar keys: A list of scalar or tuple values. Each element in the list represents one Item to retrieve. If the schema for the table has both a HashKey and a RangeKey, each element in the list should be a tuple consisting of (hash_key, range_key). If the schema for the table contains only a HashKey, each element in the list should be a scalar value of the appropriate type for the table schema. NOTE: The maximum number of items that can be retrieved for a single operation is 100. Also, the number of items retrieved is constrained by a 1 MB size limit. :ivar attributes_to_get: A list of attribute names. If supplied, only the specified attribute names will be returned. Otherwise, all attributes will be returned. :ivar consistent_read: Specify whether or not to use a consistent read. Defaults to False. NFcCs||_||_||_||_dS©N)ÚtableÚkeysÚattributes_to_getÚconsistent_read©Úselfrrrr©r ú7/tmp/pip-unpacked-wheel-dlxw5sjy/boto/dynamodb/batch.pyÚ__init__3szBatch.__init__cCs„i}g}|jD]@}t|tƒr&|\}}n|}d}|jj |jj||¡}| |¡q||d<|jrh|j|d<|j rxd|d<nd|d<|S)úO Convert the Batch object into the format required for Layer1. NÚKeysÚAttributesToGetTZConsistentReadF) rÚ isinstanceÚtuplerÚlayer2Úbuild_key_from_valuesÚschemaÚappendrr)r Ú batch_dictZkey_listÚkeyÚhash_keyÚ range_keyÚkr r r Úto_dict:s&   ÿ   z Batch.to_dict)NF©Ú__name__Ú __module__Ú __qualname__Ú__doc__r rr r r r rs ÿ rc@s"eZdZdZddd„Zdd„ZdS)Ú BatchWritea Used to construct a BatchWrite request. Each BatchWrite object represents a collection of PutItem and DeleteItem requests for a single Table. :ivar table: The Table object from which the item is retrieved. :ivar puts: A list of :class:`boto.dynamodb.item.Item` objects that you want to write to DynamoDB. :ivar deletes: A list of scalar or tuple values. Each element in the list represents one Item to delete. If the schema for the table has both a HashKey and a RangeKey, each element in the list should be a tuple consisting of (hash_key, range_key). If the schema for the table contains only a HashKey, each element in the list should be a scalar value of the appropriate type for the table schema. NcCs||_|p g|_|pg|_dSr)rÚputsÚdeletes©r rr#r$r r r r gs zBatchWrite.__init__cCs”g}|jD](}d|jj |¡i}d|i}| |¡q |jD]L}t|tƒrR|\}}n|}d}|jj |jj ||¡}d|i}| d|i¡q:|jj |fS)rZItemZ PutRequestNZKeyZ DeleteRequest) r#rrZ dynamize_itemrr$rrrrÚname)r Zop_listÚitemÚdrrrrr r r rls"     ÿzBatchWrite.to_dict)NNrr r r r r"Ss r"c@s:eZdZdZdd„Zddd„Zdd „Zd d „Zd d „ZdS)Ú BatchListzs A subclass of a list object that contains a collection of :class:`boto.dynamodb.batch.Batch` objects. cCst |¡d|_||_dSr)Úlistr Ú unprocessedr©r rr r r r ˆs zBatchList.__init__NFcCs| t||||ƒ¡dS)aO Add a Batch to this BatchList. :type table: :class:`boto.dynamodb.table.Table` :param table: The Table object in which the items are contained. :type keys: list :param keys: A list of scalar or tuple values. Each element in the list represents one Item to retrieve. If the schema for the table has both a HashKey and a RangeKey, each element in the list should be a tuple consisting of (hash_key, range_key). If the schema for the table contains only a HashKey, each element in the list should be a scalar value of the appropriate type for the table schema. NOTE: The maximum number of items that can be retrieved for a single operation is 100. Also, the number of items retrieved is constrained by a 1 MB size limit. :type attributes_to_get: list :param attributes_to_get: A list of attribute names. If supplied, only the specified attribute names will be returned. Otherwise, all attributes will be returned. N)rrr r r r Ú add_batchszBatchList.add_batchc Cs¢|dd…=|jsdSt |j¡D]x\}}|d}|j |¡}g}|D].}|d}d}d|krd|d}| ||f¡qDd} d|krˆ|d} |j||| dq | ¡S)a Resubmit the batch to get the next result set. The request object is rebuild from scratch meaning that all batch added between ``submit`` and ``resubmit`` will be lost. Note: This method is experimental and subject to changes in future releases NrZHashKeyElementZRangeKeyElementr)r)r+rÚ iteritemsrZ get_tablerr-Úsubmit) r Ú table_nameZ table_reqZ table_keysrrrÚhÚrrr r r Úresubmit§s$  zBatchList.resubmitcCs"|j |¡}d|kr|d|_|S)NZUnprocessedKeys)rZbatch_get_itemr+)r Úresr r r r/Ès  zBatchList.submitcCs.i}|D] }| ¡}|dr|||jj<q|S)zM Convert a BatchList object into format required for Layer1. r)rrr&)r r(ÚbatchÚbr r r rÎs zBatchList.to_dict)NF) rrr r!r r-r3r/rr r r r r)‚sÿ !r)c@s2eZdZdZdd„Zd dd„Zdd„Zd d „ZdS) ÚBatchWriteListzx A subclass of a list object that contains a collection of :class:`boto.dynamodb.batch.BatchWrite` objects. cCst |¡||_dSr)r*r rr,r r r r às zBatchWriteList.__init__NcCs| t|||ƒ¡dS)aW Add a BatchWrite to this BatchWriteList. :type table: :class:`boto.dynamodb.table.Table` :param table: The Table object in which the items are contained. :type puts: list of :class:`boto.dynamodb.item.Item` objects :param puts: A list of items that you want to write to DynamoDB. :type deletes: A list :param deletes: A list of scalar or tuple values. Each element in the list represents one Item to delete. If the schema for the table has both a HashKey and a RangeKey, each element in the list should be a tuple consisting of (hash_key, range_key). If the schema for the table contains only a HashKey, each element in the list should be a scalar value of the appropriate type for the table schema. N)rr"r%r r r r-äszBatchWriteList.add_batchcCs |j |¡Sr)rZbatch_write_item)r r r r r/úszBatchWriteList.submitcCs&i}|D]}| ¡\}}|||<q|S)zR Convert a BatchWriteList object into format required for Layer1. )r)r r(r5r0rr r r rýs   zBatchWriteList.to_dict)NN)rrr r!r r-r/rr r r r r7Ús  r7N)Z boto.compatrÚobjectrr"r*r)r7r r r r Ús 9/X