|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/site-packages/boto3/resources/__pycache__/ |
U
Q��g�X � @ s� d dl Z d dlmZ ddlmZ ddlmZ ddlmZm Z ddl
m Z m Z dd l
mZ dd
lmZ dd lmZmZ e �e�ZG d d
� d
�ZdS )� N)�partial� )� docstring)�ResourceLoadException� )�
ServiceAction� WaiterAction)� ResourceMeta�ServiceResource)�CollectionFactory)�
ResourceModel)�ResourceHandler�build_identifiersc @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd&d#d$�Zd%S )'�ResourceFactoryaW
A factory to create new :py:class:`~boto3.resources.base.ServiceResource`
classes from a :py:class:`~boto3.resources.model.ResourceModel`. There are
two types of lookups that can be done: one on the service itself (e.g. an
SQS resource) and another on models contained within the service (e.g. an
SQS Queue resource).
c C s t � | _|| _d S �N)r �_collection_factory�_emitter)�selfZemitter� r �D/opt/cppython/lib/python3.8/site-packages/boto3/resources/factory.py�__init__% s zResourceFactory.__init__c
C s" t �d|j|� t|||j�}d}|jr6|j�|j�}|�|� t |j|d�}d|i}| j
||||d� | j ||||d� | j |||||d� | j
|||d� | j||||d� | j||||d� |}|j|kr�d }|jd
| }tg} | jdk �r| jjd |� �|| |d � tt|�t| �|�S )
a{
Loads a resource from a model, creating a new
:py:class:`~boto3.resources.base.ServiceResource` subclass
with the correct properties and methods, named based on the service
and resource name, e.g. EC2.Instance.
:type resource_name: string
:param resource_name: Name of the resource to look up. For services,
this should match the ``service_name``.
:type single_resource_json_definition: dict
:param single_resource_json_definition:
The loaded json of a single service resource or resource
definition.
:type service_context: :py:class:`~boto3.utils.ServiceContext`
:param service_context: Context about the AWS service
:rtype: Subclass of :py:class:`~boto3.resources.base.ServiceResource`
:return: The service or resource class.
z
Loading %s:%sN)�resource_model�meta)�attrsr �
resource_namer )r r r �service_context)r r r r r )r r r r
�.zcreating-resource-class.)Zclass_attributes� base_classesr )�logger�debug� service_namer �resource_json_definitions�shape�
service_model� shape_forZload_rename_mapr �_load_identifiers�
_load_actions�_load_attributes�_load_collections�_load_has_relations�
_load_waitersr
r �emit�type�str�tuple)
r r � single_resource_json_definitionr r r" r r �cls_namer r r r �load_from_definition) s� ���
� ���� ���
�z$ResourceFactory.load_from_definitionc C s0 |j D ]$}|j �|j� | �||�||j< qdS )z�
Populate required identifiers. These are arguments without which
the resource cannot be used. Identifiers become arguments for
operations on the resource.
N)� identifiers�append�name�_create_identifier)r r r r r �
identifierr r r r% � s
�z!ResourceFactory._load_identifiersc C sP |j r*| j|j ||dd�|d< |d |d< |jD ]}| j|||d�||j< q0dS )z�
Actions on the resource become methods, with the ``load`` method
being a special case which sets internal data for attributes, and
``reload`` is an alias for ``load``.
T)� action_modelr r �is_load�load�reload)r7 r r N)r9 �_create_action�actionsr4 )r r r r r �actionr r r r& � s �
�z ResourceFactory._load_actionsc
C s� |j s
dS |j�|j �}dd� |jD �}|�|�}|�� D ]H\} \}
} | |krf| j||| | |d�} n| j||
| | |d�} | || < q:dS )a
Load resource attributes based on the resource shape. The shape
name is referenced in the resource JSON, but the shape itself
is defined in the Botocore service JSON, hence the need for
access to the ``service_model``.
Nc S s i | ]}|j r|j |�qS r )� member_name��.0�ir r r �
<dictcomp>� s � z4ResourceFactory._load_attributes.<locals>.<dictcomp>)r r6 � member_modelr )r r4 � snake_casedrC r )r" r# r$ r2 Zget_attributes�items�_create_identifier_alias�_create_autoload_property)
r r r r r r r" r2 �
attributesr4 � orig_name�member�propr r r r' � s. �
��z ResourceFactory._load_attributesc C s( |j D ] }| j|j||d�||j< qdS )a
Load resource collections from the model. Each collection becomes
a :py:class:`~boto3.resources.collection.CollectionManager` instance
on the resource instance, which allows you to iterate and filter
through the collection's items.
)r �collection_modelr N)� collections�_create_collectionr4 )r r r r rL r r r r( � s
�z!ResourceFactory._load_collectionsc C sV |j D ]}| j|||d�||j< q|jD ]}| j|||d�||j< q(| �||j� dS )a�
Load related resources, which are defined via a ``has``
relationship but conceptually come in two forms:
1. A reference, which is a related resource instance and can be
``None``, such as an EC2 instance's ``vpc``.
2. A subresource, which is a resource constructor that will always
return a resource instance which shares identifiers/data with
this resource, such as ``s3.Bucket('name').Object('key')``.
)�reference_modelr r )�subresource_modelr r N)Z
references�_create_referencer4 � subresources�_create_class_partial�&_create_available_subresources_command)r r r r r � reference� subresourcer r r r) � s
�
� �z#ResourceFactory._load_has_relationsc s. dd� |D �� t � �� � fdd�}||d< d S )Nc S s g | ]
}|j �qS r �r4 )r@ rV r r r �
<listcomp> s zJResourceFactory._create_available_subresources_command.<locals>.<listcomp>c s � S )z�
Returns a list of all the available sub-resources for this
Resource.
:returns: A list containing the name of each sub-resource for this
resource
:rtype: list of str
r )� factory_self�Z
_subresourcesr r �get_available_subresources s zZResourceFactory._create_available_subresources_command.<locals>.get_available_subresourcesr[ )�sorted)r r rR r[ r rZ r rT s z6ResourceFactory._create_available_subresources_commandc C s& |j D ]}| j|||d�||j< qdS )z�
Load resource waiters from the model. Each waiter allows you to
wait until a resource reaches a specific state by polling the state
of the resource.
)�resource_waiter_modelr r N)�waiters�_create_waiterr4 )r r r r r �waiterr r r r* - s
�z ResourceFactory._load_waitersc s2 � fdd�}t � j�|_tj|� dd�|_t|�S )zI
Creates a read-only property for identifier attributes.
c s t | d� j d �S �N�_��getattrr4 �r �r6 r r �get_identifierA s z:ResourceFactory._create_identifier.<locals>.get_identifierF)r Zidentifier_model�include_signature)r- r4 �__name__r ZIdentifierDocstring�__doc__�property)rY r6 r rg r rf r r5 < s �z"ResourceFactory._create_identifierc s> � fdd�}t � j�|_tj|j|� j| j|dd�|_t|�S )zJ
Creates a read-only property that aliases an identifier.
c s t | d� j d �S ra rc re rf r r rg Z s z@ResourceFactory._create_identifier_alias.<locals>.get_identifierF�r r � attr_name�
event_emitterZ
attr_modelrh ) r- r> ri r �AttributeDocstringr r rj rk )rY r r6 rC r rg r rf r rF S s � z(ResourceFactory._create_identifier_aliasc s: � fdd�}t |�|_tj|j||| j|dd�|_t|�S )z�
Creates a new property on the resource to lazy-load its value
via the resource's ``load`` method (if it exists).
c s@ | j jd kr2t| d�r | �� nt| jj� d���| j j�� �S )Nr9 z has no load method)r �data�hasattrr9 r � __class__ri �getre rW r r �property_loaderz s
�zBResourceFactory._create_autoload_property.<locals>.property_loaderFrl )r- ri r ro r r rj rk )rY r r4 rD rC r rt r rW r rG i s
� z)ResourceFactory._create_autoload_propertyc sH t ||jd�� � fdd�}t|j�|_tj|| j|j||jdd�|_ |S )zx
Creates a new wait method for each resource where both a waiter and
resource model is defined.
)Zwaiter_resource_namec s � | f|�|� d S r r )r �args�kwargs�r` r r � do_waiter� s z1ResourceFactory._create_waiter.<locals>.do_waiterF)r rn r# r] �service_waiter_modelrh )
r r4 r- ri r ZResourceWaiterDocstringr r# ry rj )rY r] r r rx r rw r r_ � s � �z ResourceFactory._create_waiterc sL �j j|���jd�� � ���fdd�}t�j�|_tj�dd�|_t |�S )zS
Creates a new property on the resource to lazy-load a collection.
)r rL r rn c s � �| ��d�S )N)rL �parent�factoryr r re ��clsrL rY r r r �get_collection� s �z:ResourceFactory._create_collection.<locals>.get_collectionF)rL rh )
r r1 r r- r4 ri r ZCollectionDocstringrj rk )rY r rL r r~ r r| r rN � s � �z"ResourceFactory._create_collectionc s^ t |jj| |j|d�� tdd� |jjD ���� �fdd�}t|j�|_tj |dd�|_
t |�S )zR
Creates a new property on the resource to lazy-load a reference.
)� search_pathr{ r r c s s | ]}|j d kV qdS )rp N)�sourcer? r r r � <genexpr>� s z4ResourceFactory._create_reference.<locals>.<genexpr>c s2 �r"| j jd kr"t| d�r"| �� � | i | j j�S �Nr9 )r rp rq r9 re ��handlerZ
needs_datar r �
get_reference� s z8ResourceFactory._create_reference.<locals>.get_referenceF)rO rh ) r
�resource�path�anyr2 r- r4 ri r ZReferenceDocstringrj rk )rY rO r r r� r r� r rQ � s �
� �z!ResourceFactory._create_referencec s> �j j�� ���fdd�}t��|_tj|��jdd�|_|S )z�
Creates a new method which acts as a functools.partial, passing
along the instance's low-level `client` to the new resource
class' constructor.
c sn g }�j ��i �}� j�|�d�}�jj}|d k rPt|| �D ]\}}|�|� q<t|f|�d| jj i�||�S )N)r r/ r �client)
r! rs r1 r� r2 r r3 r r r� ) r ru rv Zpositional_argsZjson_defZ resource_clsr2 r6 �value�rY r4 r rP r r �create_resource� s* � ��� �z>ResourceFactory._create_class_partial.<locals>.create_resourceF)r Zsub_resource_modelr# rh )r� r, r- ri r ZSubResourceDocstringr# rj )rY rP r r r� r r� r rS � s
�z%ResourceFactory._create_class_partialFc sv t || |d�� |r<� fdd�}tj|j|| j||jdd�}n$� fdd�}tj|| j||jdd�}t|j�|_||_ |S )zc
Creates a new method which makes a request to the underlying
AWS service.
)r{ r c s � | f|�|�}|| j _d S r )r rp �r ru rv �response�r= r r � do_action4 s z1ResourceFactory._create_action.<locals>.do_actionF)� action_namer rn Z
load_modelr# rh c s& � | f|�|�}t | d�r"d | j_|S r� )rq r rp r� r� r r r� D s
)r rn r7 r# rh )
r r ZLoadReloadDocstringr4 r r# ZActionDocstringr- ri rj )rY r7 r r r8 r� Zlazy_docstringr r� r r; s4 � � � z ResourceFactory._create_actionN)F)ri �
__module__� __qualname__rj r r1 r% r& r' r( r) rT r* r5 rF rG r_ rN rQ rS r; r r r r r s& w &$()3 �r )�logging� functoolsr �docsr �
exceptionsr r= r r �baser r
Z
collectionr �modelr r� r
r � getLoggerri r r r r r r �<module> s