File manager - Edit - /usr/lib/rads/venv/lib/python3.13/site-packages/boto3/dynamodb/__pycache__/table.cpython-313.pyc
Back
� � �i� � �^ � S SK r \ R " \5 rS r " S S5 r " S S5 rg)� Nc �0 � U R S[ 5 g )Nr )�insert� TableResource)� base_classes�kwargss �G/usr/lib/rads/venv/lib/python3.13/site-packages/boto3/dynamodb/table.py�register_table_methodsr s � �����=�)� c �2 ^ � \ rS rSrU 4S jrSS jrSrU =r$ )r � c �& >� [ TU ] " U0 UD6 g �N)�super�__init__)�self�argsr � __class__s �r r �TableResource.__init__ s �� � ���$�)�&�)r c �T � [ U R U R R US9$ )a� Create a batch writer object. This method creates a context manager for writing objects to Amazon DynamoDB in batch. The batch writer will automatically handle buffering and sending items in batches. In addition, the batch writer will also automatically handle any unprocessed items and resend them as needed. All you need to do is call ``put_item`` for any items you want to add, and ``delete_item`` for any items you want to delete. Example usage:: with table.batch_writer() as batch: for _ in range(1000000): batch.put_item(Item={'HashKey': '...', 'Otherstuff': '...'}) # You can also delete_items in a batch. batch.delete_item(Key={'HashKey': 'SomeHashKey'}) :type overwrite_by_pkeys: list(string) :param overwrite_by_pkeys: De-duplicate request items in buffer if match new request item on specified primary keys. i.e ``["partition_key1", "sort_key2", "sort_key3"]`` )�overwrite_by_pkeys)� BatchWriter�name�meta�client)r r s r � batch_writer�TableResource.batch_writer s' � �6 � �I�I�t�y�y�'�'�<N� � r � r )�__name__� __module__� __qualname__�__firstlineno__r r �__static_attributes__� __classcell__)r s @r r r s �� �*� � r r c �Z � \ rS rSrSr SS jrS rS rS rS r S r S r S r S r S rSrg)r �? zAAutomatically handle batch writes to DynamoDB for a single table.Nc �B � Xl X l / U l X0l X@l g)a� :type table_name: str :param table_name: The name of the table. The class handles batch writes to a single table. :type client: ``botocore.client.Client`` :param client: A botocore client. Note this client **must** have the dynamodb customizations applied to it for transforming AttributeValues into the wire protocol. What this means in practice is that you need to use a client that comes from a DynamoDB resource if you're going to instantiate this class directly, i.e ``boto3.resource('dynamodb').Table('foo').meta.client``. :type flush_amount: int :param flush_amount: The number of items to keep in a local buffer before sending a batch_write_item request to DynamoDB. :type overwrite_by_pkeys: list(string) :param overwrite_by_pkeys: De-duplicate request items in buffer if match new request item on specified primary keys. i.e ``["partition_key1", "sort_key2", "sort_key3"]`` N)� _table_name�_client� _items_buffer� _flush_amount�_overwrite_by_pkeys)r � table_namer � flush_amountr s r r �BatchWriter.__init__B s# � �< &�� � � ��� )��#5� r c �. � U R SSU005 g )N� PutRequest�Item��_add_request_and_process)r r1 s r �put_item�BatchWriter.put_itemf s � � �%�%�|�f�d�^�&D�Er c �. � U R SSU005 g )N� DeleteRequest�Keyr2 )r r8 s r � delete_item�BatchWriter.delete_itemi s � � �%�%���� �&E�Fr c � � U R ( a U R U5 U R R U5 U R 5 g r )r+ � _remove_dup_pkeys_request_if_anyr) �append�_flush_if_needed)r �requests r r3 �$BatchWriter._add_request_and_processl s9 � � � #� #� � 1� 1�'� :� ���!�!�'�*� � � � r c �� � U R U5 nU R HK nU R U5 U:X d M U R R U5 [ R SU5 MM g )Nz4With overwrite_by_pkeys enabled, skipping request:%s)�_extract_pkey_valuesr) �remove�logger�debug)r r? �pkey_values_new�items r r< �,BatchWriter._remove_dup_pkeys_request_if_anyr s[ � � �3�3�G�<���&�&�D��(�(��.�/�A��"�"�)�)�$�/�� � �J��� 'r c � � UR S5 ( a& U R Vs/ s H nUS S U PM sn$ UR S5 ( a& U R Vs/ s H nUS S U PM sn$ g s snf s snf )Nr0 r1 r7 r8 )�getr+ )r r? �keys r rB � BatchWriter._extract_pkey_values| s� � � �;�;�|� $� $� �3�3��3�C� � �%�f�-�c�2�3�� � �[�[� � )� )� �3�3��3�C� ��(��/��4�3�� � ���� s �A:�!A?c �l � [ U R 5 U R :� a U R 5 g g r )�lenr) r* �_flush�r s r r> � BatchWriter._flush_if_needed� s) � � �t�!�!� "�d�&8�&8� 8� �K�K�M� 9r c � � U R S U R nU R U R S U l U R R U R U0S9nUS nU( d 0 nUR U R / 5 nU R R U5 [ R S[ U5 [ U R 5 5 g )N)� RequestItems�UnprocessedItemsz$Batch write sent %s, unprocessed: %s) r) r* r( �batch_write_itemr' rJ �extendrD rE rN )r � items_to_send�response�unprocessed_items� item_lists r rO �BatchWriter._flush� s� � � �*�*�+?�T�-?�-?�@� � !� /� /��0B�0B�0D� E����<�<�0�0� �*�*�M�:� 1� �� %�%7� 8�� � "� �%�)�)�$�*:�*:�B�?� � ���!�!�)�,�� � � 2� � � � ��"�"� #� r c � � U $ r r rP s r � __enter__�BatchWriter.__enter__� s � �� r c �n � U R ( a$ U R 5 U R ( a M# g g r )r) rO )r �exc_type� exc_value�tbs r �__exit__�BatchWriter.__exit__� s$ � � � � � �K�K�M� � � � r )r( r* r) r+ r' )� N)r r r r! �__doc__r r4 r9 r3 r< rB r> rO r] rc r" r r r r r ? sA � �K� GK�"6�HF�G� � � �� �&�r r )�logging� getLoggerr rD r r r r r r �<module>ri s6 �� � � � �8� $��*�! � ! �Hh� hr
| ver. 1.4 |
Github
|
.
| PHP 8.3.31 | Generation time: 0 |
proxy
|
phpinfo
|
Settings