B è?F[R&ã@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 ú2lib/python3.7/site-packages/boto/dynamodb/batch.pyÚ__init__3szBatch.__init__cCsˆi}g}xJ|jD]@}t|tƒr(|\}}n|}d}|jj |jj||¡}| |¡qW||d<|jrl|j|d<|j r|d|d<nd|d<|S)zO 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|_dS)N)rÚputsÚdeletes)rrrr r r r r gs zBatchWrite.__init__cCsœg}x2|jD](}d|jj |¡i}d|i}| |¡q WxV|jD]L}t|tƒrX|\}}n|}d}|jj |jj ||¡}d|i}| d|i¡q@W|jj |fS)zO Convert the Batch object into the format required for Layer1. ZItemZ PutRequestNZKeyZ DeleteRequest) rrrZ dynamize_itemrr rrrrÚname)rZop_listÚitemÚdrrrrr r r rls    zBatchWrite.to_dict)NN)rrrrr rr r r r rSs rc@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|_||_dS)N)Úlistr Ú unprocessedr)rrr 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)rr)rrrrrr r r Ú add_batchszBatchList.add_batchc Csª|dd…=|jsdSxŒt |j¡D]|\}}|d}|j |¡}g}x6|D].}|d}d}d|krh|d}| ||f¡qHWd} d|krŽ|d} |j||| dq"W| ¡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 Nr ZHashKeyElementZRangeKeyElementr )r)r&rZ 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&)rZresr r r r(Ès  zBatchList.submitcCs2i}x(|D] }| ¡}|dr |||jj<q W|S)zM Convert a BatchList object into format required for Layer1. r )rrr!)rr#ÚbatchÚbr r r rÎs  zBatchList.to_dict)NF) rrrrr r'r,r(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 |¡||_dS)N)r%r r)rrr 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)rrrr r r r r'äszBatchWriteList.add_batchcCs |j |¡S)N)rZbatch_write_item)rr r r r(úszBatchWriteList.submitcCs*i}x |D]}| ¡\}}|||<q W|S)zR Convert a BatchWriteList object into format required for Layer1. )r)rr#r-r)rr r r rýs    zBatchWriteList.to_dict)NN)rrrrr r'r(rr r r r r/Ús  r/N)Z boto.compatrÚobjectrrr%r$r/r r r r Ús 9/X