File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/boto_s3_bucket.cpython-310.pyc
Back
o ;j( � @ sP d Z ddlZddlZddlZddlZddlmZ e�e �Z zddl Z ddl Z ddl mZ e�d��ej� dZW n eyC dZY nw dd � Zd d � ZdBd d �Z dCdd�Z dDdd�Z dEdd�ZdBdd�Z dEdd�ZdBdd�Z dFdd�Z dGd d �Z dCd d �Z dBd d!�Z dBd"d#�Z dFd$d%�Z! dFd&d'�Z"dBd(d)�Z#dBd*d+�Z$ dBd,d-�Z%dBd.d/�Z&dBd0d1�Z' dEd2d3�Z( dHd4d5�Z)dBd6d7�Z* dBd8d9�Z+dBd:d;�Z,dBd<d=�Z-dBd>d?�Z.dBd@dA�Z/dS )Ia6 Connection module for Amazon S3 Buckets .. versionadded:: 2016.3.0 :depends: - boto - boto3 The dependencies listed above can be installed via package or pip. :configuration: This module accepts explicit Lambda credentials but can also utilize IAM roles assigned to the instance through Instance Profiles. Dynamic credentials are then automatically obtained from AWS API and no further configuration is necessary. More Information available at: .. code-block:: text http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/iam-roles-for-amazon-ec2.html If IAM roles are not used you need to specify them either in a pillar or in the minion's config file: .. code-block:: yaml s3.keyid: GKTADJGHEIQSXMKKRBJ08H s3.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs A region may also be specified in the configuration: .. code-block:: yaml s3.region: us-east-1 If a region is not specified, the default is us-east-1. It's also possible to specify key, keyid and region via a profile, either as a passed in dict, or as a string to pull from pillars or minion config: .. code-block:: yaml myprofile: keyid: GKTADJGHEIQSXMKKRBJ08H key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs region: us-east-1 � N)�SaltInvocationError)� ClientError�boto3TFc C s t jjjdd�S )zg Only load if boto libraries exist and if boto libraries are greater than a given version. z1.2.1)Z boto3_ver)�salt�utilsZversionsZcheck_boto_reqs� r r �O/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/boto_s3_bucket.py� __virtual__Q s r c C s t r td td� d S d S )Nzboto3.assign_funcsZs3)�HAS_BOTO� __utils__�__name__)�optsr r r �__init__\ s �r c C s� zt ||||d�}|j| d�}ddiW S tyE } z&|j�di ��d�dkr1ddiW Y d }~S td |�}d |iW Y d }~S d }~ww ) a Given a bucket name, check to see if the given bucket exists. Returns True if the given bucket exists and returns False if the given bucket does not exist. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.exists mybucket ��region�key�keyid�profile��Bucket�existsT�Error�CodeZ404FN�boto3.get_error�error)� _get_connZ head_bucketr �response�getr ) r r r r r �conn�buckets�e�errr r r r a s ��r c C s� zWt || | | d�} i } dD ]}t� | dur tt� | �| |< q |r(d|i| d< | jdd| i| ��}| �d�j| d� |rNt�d |d � d | |d d �W S t�d � ddiW S t yr } zdt d |�d�W Y d}~S d}~ww )aU Given a valid config, create an S3 Bucket. Returns {created: true} if the bucket was created and returns {created: False} if the bucket was not created. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.create my_bucket \ GrantFullControl='emailaddress=example@example.com' \ GrantRead='uri="http://acs.amazonaws.com/groups/global/AllUsers"' \ GrantReadACP='emailaddress="exampl@example.com",id="2345678909876432"' \ LocationConstraint=us-west-1 r ��ACL�GrantFullControl� GrantRead� GrantReadACP� GrantWrite� GrantWriteACPN�LocationConstraintZCreateBucketConfigurationr Z bucket_existsr z.The newly created bucket name is located at %s�LocationT)�created�namer* zBucket was not createdr+ Fr )r+ r r ) r �locals�strZ create_bucketZ get_waiter�wait�log�info�warningr r )r r# r) r$ r% r& r' r( r r r r r �kwargs�arg�locationr r r r �create{ s. ��� ��r6 c C sx z t ||||d�}|rt| ||||||d� |j| d� ddiW S ty; } zdtd | �d�W Y d } ~ S d } ~ ww ) a! Given a bucket name, delete it, optionally emptying it first. Returns {deleted: true} if the bucket was deleted and returns {deleted: false} if the bucket was not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete mybucket r ��MFA� RequestPayerr r r r r �deletedTFr �r: r N)r �emptyZ delete_bucketr r ) r r8 r9 ZForcer r r r r r r r r �delete� s$ � ��r= c C s< t |t�r tjj�|�}t |t�std��d|vr td��g }|d } tdt | �d�D ]g} | | | d � } | dd�} z;d| i} |rH| � d|i�nd |rS| � d |i�nd | � d | i� t ||||d �}|j di | ��}||� d g �7 }W q+ ty� } zdtd |�d�W Y d }~ S d }~ww |r�d|d�S ddiS )a& Delete objects in a given S3 bucket. Returns {deleted: true} if all objects were deleted and {deleted: false, failed: [key, ...]} otherwise CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_objects mybucket '{Objects: [Key: myobject]}' zMalformed Delete request.�Objectsr i� T)r> ZQuietr r8 Nr9 �Deleter ZErrorsFr r; �r: �failedr: r )� isinstancer. r r �json�loads�dictr �range�len�updater �delete_objectsr r r )r r? r8 r9 r r r r rA Zobjs�i�chunkZsubset�argsr �retr r r r rI � s8 ��"�� rI c C s� z�t ||||d�}i }|j|j|j|j|j|j|j|j|j |j |j d� }|� � D ]6\}}z|| d�} W n t yR } z| j�di ��d�dv rMW Y d} ~ q(� d} ~ ww d| v rZ| d= | ||< q(i } z|j| d�} | �d �D ] } | �d �| | �d �< qmW n t y� } z| j�di ��d�d ks�� W Y d} ~ nd} ~ ww | r�| |d < d|iW S t y� } z*td | �} | j�di ��d�dkr�ddiW Y d} ~ S dtd | �iW Y d} ~ S d} ~ ww )z� Given a bucket name describe its properties. Returns a dictionary of interesting properties. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.describe mybucket r ) r# ZCORS�LifecycleConfigurationr* ZLogging�NotificationConfiguration�PolicyZ ReplicationZRequestPaymentZ VersioningZWebsiter r r )Z NoSuchLifecycleConfigurationZNoSuchCORSConfigurationZNoSuchBucketPolicyZNoSuchWebsiteConfigurationZ%ReplicationConfigurationNotFoundError� NoSuchTagSetN�ResponseMetadata�TagSet�Value�KeyrQ �TaggingZbucketr Z NoSuchBucketr )r Zget_bucket_aclZget_bucket_corsZ"get_bucket_lifecycle_configurationZget_bucket_locationZget_bucket_loggingZ%get_bucket_notification_configurationZget_bucket_policyZget_bucket_replicationZget_bucket_request_paymentZget_bucket_versioningZget_bucket_website�itemsr r r Zget_bucket_taggingr )r r r r r r �resultZ conn_dict�query�datar �tagsZtagdefr! r r r �describe sb � �� � ��� ��r\ c C s� t | ||||d�}i }dd� |�dg �D �|d< |d dd� |�dg �D �7 < |d rHt| |||||||d�} | �d g �} | rHd | | d �S d d iS )a Delete all objects in a given S3 bucket. Returns {deleted: true} if all objects were deleted and {deleted: false, failed: [key, ...]} otherwise CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.empty mybucket r c S � g | ] }|d |d d��qS �rU � VersionId)rU r_ r ��.0�vr r r � <listcomp>r � ��zempty.<locals>.<listcomp>�Versionsr> c S r] r^ r r` r r r rc v rd � DeleteMarkersr7 rA Fr@ r: T)�list_object_versionsr rI ) r r8 r9 r r r r �stuffr? rM rA r r r r< ] s2 � � �� r< c C sz z"t | |||d�}|�� }t|�d��st�d� d|v r |d= |W S ty< } zdtd |�iW Y d}~S d}~ww )z� List all buckets owned by the authenticated sender of the request. Returns list of buckets CLI Example: .. code-block:: yaml Owner: {...} Buckets: - {...} - {...} r ZBucketszNo buckets foundrR r r N)r Z list_buckets�boolr r0 r2 r r )r r r r r r r r r r �list� s ��rj c C s zkg }g } d| i} |r| � d|i�nd |r | � d|i�nd |r(| � d|i�nd t||||d�} d} | rf| jdi | ��} | �dd �} | d v rT| d | d < | d | d< || �dg �7 }| | �dg �7 } | s6|| d�W S ty� } zdtd |�iW Y d}~S d}~ww )z� List objects in a given S3 bucket. Returns a list of objects. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.list_object_versions mybucket r � DelimiterN� EncodingType�Prefixr T� IsTruncatedF��True�trueTZ NextKeyMarkerZ KeyMarkerZNextVersionIdMarkerZVersionIdMarkerre rf )re rf r r r )rH r rg r r r )r rk rl rm r r r r re rf rL r rn rM r r r r rg � s4 ��� � ��rg c C s zfg } | |d�} |r| � d|i�nd |r | � d|i�nd |r'| � d|i�nd |r2| � d|i�nd t|||| d�} d} | rb| jdi | ��}|�d d �} | d v rX|d | d < | |�dg �7 } | s@d| iW S ty� } zdtd |�iW Y d}~S d}~ww )z� List objects in a given S3 bucket. Returns a list of objects. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.list_objects mybucket )r � FetchOwnerrk Nrl rm � StartAfterr Trn Fro ZNextContinuationTokenZContinuationToken�Contentsr r r )rH r Zlist_objects_v2r r r )r rk rl rm rr rs r r r r rt rL r rn rM r r r r � list_objects� s2 ���� � ��ru c C s� zCt || | | d�} i } |dur t|t�rtjj�|�}|| d< dD ]}t� | dur3tt� | �| |< q!| jd d| i| �� d| d�W S t y^ } zdt d |�d �W Y d}~S d}~ww ) a) Given a valid config, update the ACL for a bucket. Returns {updated: true} if the ACL was updated and returns {updated: False} if the ACL was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_acl my_bucket 'public' \ GrantFullControl='emailaddress=example@example.com' \ GrantRead='uri="http://acs.amazonaws.com/groups/global/AllUsers"' \ GrantReadACP='emailaddress="exampl@example.com",id="2345678909876432"' r N�AccessControlPolicyr" r T��updatedr, Fr �rx r r ) r rB r. r r rC rD r- Zput_bucket_aclr r )r r# rv r$ r% r& r' r( r r r r r r3 r4 r r r r �put_acl s" � ��rz c C � z't ||||d�}|durt|t�rtjj�|�}|j| d|id� d| d�W S tyB } zdt d |�d �W Y d}~S d}~ww ) a� Given a valid config, update the CORS rules for a bucket. Returns {updated: true} if CORS was updated and returns {updated: False} if CORS was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_cors my_bucket '[{\ "AllowedHeaders":[],\ "AllowedMethods":["GET"],\ "AllowedOrigins":["*"],\ "ExposeHeaders":[],\ "MaxAgeSeconds":123,\ }]' r N� CORSRules)r ZCORSConfigurationTrw Fr ry ) r rB r. r r rC rD Zput_bucket_corsr r )r r| r r r r r r r r r �put_cors7 s ��r} c C r{ ) ao Given a valid config, update the Lifecycle rules for a bucket. Returns {updated: true} if Lifecycle was updated and returns {updated: False} if Lifecycle was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_lifecycle_configuration my_bucket '[{\ "Expiration": {...},\ "ID": "idstring",\ "Prefix": "prefixstring",\ "Status": "enabled",\ "Transitions": [{...},],\ "NoncurrentVersionTransitions": [{...},],\ "NoncurrentVersionExpiration": {...},\ }]' r N�Rules)r rN Trw Fr ry ) r rB r. r r rC rD Z"put_bucket_lifecycle_configurationr r )r r~ r r r r r r r r r �put_lifecycle_configurationV s � ��r c C s� zGt ||||d�}i } |||d�} | �� D ] \}} | dur!| | |< q| r)d| i} ni } |dur;t|t�r;tjj�|�}|j| | d� d| d�W S t yb } zdt d | �d �W Y d} ~ S d} ~ ww ) aI Given a valid config, update the logging parameters for a bucket. Returns {updated: true} if parameters were updated and returns {updated: False} if parameters were not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_logging my_bucket log_bucket '[{...}]' prefix r )� TargetBucket� TargetGrants� TargetPrefixNZLoggingEnabled)r ZBucketLoggingStatusTrw Fr ry ) r rW rB r. r r rC rD Zput_bucket_loggingr r )r r� r� r� r r r r r Zlogstate�targets�valZ logstatusr r r r � put_logging{ s, �� ��r� c C s� zRt ||||d�}|du rg }n t|t�r tjj�|�}|du r#g }n t|t�r/tjj�|�}|du r6g }n t|t�rBtjj�|�}|j| |||d�d� d| d�W S tym } zdt d | �d �W Y d} ~ S d} ~ ww ) a� Given a valid config, update the notification parameters for a bucket. Returns {updated: true} if parameters were updated and returns {updated: False} if parameters were not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_notification_configuration my_bucket [{...}] \ [{...}] \ [{...}] r N)�TopicConfigurations�QueueConfigurations� LambdaFunctionConfigurations)r rO Trw Fr ry ) r rB r. r r rC rD Z%put_bucket_notification_configurationr r ) r r� r� r� r r r r r r r r r � put_notification_configuration� s8 ��� ��r� c C s� z(t ||||d�}|du rd}n t|t�s tjj�|�}|j| |d� d| d�W S tyC } zdt d |�d �W Y d}~S d}~ww ) a Given a valid config, update the policy for a bucket. Returns {updated: true} if policy was updated and returns {updated: False} if policy was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_policy my_bucket {...} r Nz{})r rP Trw Fr ry ) r rB r. r r rC �dumpsZput_bucket_policyr r )r rP r r r r r r r r r � put_policy� s ��r� c C sR | � d�r| S td ||||d�}|rd|v r|d }|d u r!d}d|� d| � �S )Nz arn:aws:iam:zboto_iam.get_account_idr r z us-east-1z arn:aws:iam::z:role/)� startswithZ__salt__)r, r r r r Z account_idr r r � _get_role_arn� s � r� c C s� z4t ||||d�}t|||||d�}|du rg }n t|t�r%tjj�|�}|j| ||d�d� d| d�W S t yO } zdt d |�d �W Y d}~S d}~ww ) ab Given a valid config, update the replication configuration for a bucket. Returns {updated: true} if replication configuration was updated and returns {updated: False} if replication configuration was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_replication my_bucket my_role [...] r )r, r r r r N)�Roler~ )r ZReplicationConfigurationTrw Fr ry ) r r� rB r. r r rC rD Zput_bucket_replicationr r ) r r� r~ r r r r r r r r r �put_replication s" � � ��r� c C sf zt ||||d�}|j| d|id� d| d�W S ty2 } zdtd |�d�W Y d }~S d }~ww ) an Given a valid config, update the request payment configuration for a bucket. Returns {updated: true} if request payment configuration was updated and returns {updated: False} if request payment configuration was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_request_payment my_bucket Requester r �Payer)r ZRequestPaymentConfigurationTrw Fr ry N)r Zput_bucket_request_paymentr r )r r� r r r r r r r r r �put_request_payment. s � ��r� c K s� z6t ||||d�}g }|�� D ]\}} t|��d�rq|�t|�t| �d�� q|j| d|id� d| d�W S tyQ } zdtd | �d �W Y d } ~ S d } ~ ww ) a! Given a valid config, update the tags for a bucket. Returns {updated: true} if tags were updated and returns {updated: False} if tags were not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_tagging my_bucket my_role [...] r �__)rU rT rS )r rV Trw Fr ry N)r rW r. r� �appendZput_bucket_taggingr r ) r r r r r r3 r Ztagslist�krb r r r r � put_taggingG s ��r� c C s� z/t ||||d�}d|i} |dur|| d< i } |dur || d< |jd | | d�| �� d| d�W S tyJ } zd td | �d �W Y d} ~ S d} ~ ww ) aX Given a valid config, update the versioning configuration for a bucket. Returns {updated: true} if versioning configuration was updated and returns {updated: False} if versioning configuration was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_versioning my_bucket Enabled r �StatusN� MFADeleter8 )r �VersioningConfigurationTrw Fr ry r )r Zput_bucket_versioningr r ) r r� r� r8 r r r r r r� r3 r r r r �put_versioningc s$ �� ��r� c C s� z8t ||||d�} i } dD ] }t� | } | dur+t| t�r'tjj�| �| |< q | | |< q | j| | d� d| d�W S t yS } zdt d | �d �W Y d} ~ S d} ~ ww ) al Given a valid config, update the website configuration for a bucket. Returns {updated: true} if website configuration was updated and returns {updated: False} if website configuration was not updated. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.put_website my_bucket IndexDocument='{"Suffix":"index.html"}' r )� ErrorDocument� IndexDocument�RedirectAllRequestsTo� RoutingRulesN)r �WebsiteConfigurationTrw Fr ry ) r r- rB r. r r rC rD Zput_bucket_websiter r ) r r� r� r� r� r r r r r r� r� r r r r � put_website� s$ �� ��r� c C �` zt ||||d�}|j| d� d| d�W S ty/ } zdtd |�d�W Y d}~S d}~ww ) a Delete the CORS configuration for the given bucket Returns {deleted: true} if CORS was deleted and returns {deleted: False} if CORS was not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_cors my_bucket r r T�r: r, Fr r; N)r Zdelete_bucket_corsr r �r r r r r r r r r r � delete_cors� � ��r� c C r� ) a2 Delete the lifecycle configuration for the given bucket Returns {deleted: true} if Lifecycle was deleted and returns {deleted: False} if Lifecycle was not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_lifecycle_configuration my_bucket r r Tr� Fr r; N)r Zdelete_bucket_lifecycler r r� r r r � delete_lifecycle_configuration� s ��r� c C r� ) a Delete the policy from the given bucket Returns {deleted: true} if policy was deleted and returns {deleted: False} if policy was not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_policy my_bucket r r Tr� Fr r; N)r Zdelete_bucket_policyr r r� r r r � delete_policy� r� r� c C r� ) aB Delete the replication config from the given bucket Returns {deleted: true} if replication configuration was deleted and returns {deleted: False} if replication configuration was not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_replication my_bucket r r Tr� Fr r; N)r Zdelete_bucket_replicationr r r� r r r �delete_replication r� r� c C r� ) a Delete the tags from the given bucket Returns {deleted: true} if tags were deleted and returns {deleted: False} if tags were not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_tagging my_bucket r r Tr� Fr r; N)r Zdelete_bucket_taggingr r r� r r r �delete_tagging r� r� c C r� ) a9 Remove the website configuration from the given bucket Returns {deleted: true} if website configuration was deleted and returns {deleted: False} if website configuration was not deleted. CLI Example: .. code-block:: bash salt myminion boto_s3_bucket.delete_website my_bucket r r Tr� Fr r; N)r Zdelete_bucket_websiter r r� r r r �delete_website0 r� r� )NNNN) NNNNNNNNNNN)NNFNNNN)NNNNNN)NNNNNNN) NNNFNNNNN)NNNNNNNN)0�__doc__�loggingZsalt.utils.compatr Zsalt.utils.jsonZsalt.utils.versionsZsalt.exceptionsr � getLoggerr r0 Zbotor Zbotocore.exceptionsr �setLevel�CRITICALr � ImportErrorr r r r6 r= rI r\ r< rj rg ru rz r} r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> s 6 � �B �- � 5D � . �/ �/ � 6 �' �1 � 9 � " �* � 0 �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings