File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/boto_elasticsearch_domain.cpython-310.pyc
Back
o ;jT? � @ s4 d Z ddlZddlZddlZddlZddlmZ e�e �Z z$ddl Z ddl Z ddl mZ e�d��ej� e�d��ej� dZW n eyL dZY nw d d � Zd d � Zd d d�Zd dd�Zd dd�Z d dd�Zd dd�Z d!dd�Z d"dd�Z d"dd �Z d"d d �Z dS )#a� Connection module for Amazon Elasticsearch Service .. versionadded:: 2016.11.0 :configuration: This module accepts explicit AWS credentials but can also utilize IAM roles assigned to the instance trough 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 lambda.keyid: GKTADJGHEIQSXMKKRBJ08H lambda.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs A region may also be specified in the configuration: .. code-block:: yaml lambda.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 Create and delete methods return: .. code-block:: yaml created: true or .. code-block:: yaml created: false error: message: error message Request methods (e.g., `describe_function`) return: .. code-block:: yaml domain: - {...} - {...} or .. code-block:: yaml error: message: error message :depends: boto3 � N)�SaltInvocationError)� ClientError�boto�boto3TFc C s t jjjddd�S )zg Only load if boto libraries exist and if boto libraries are greater than a given version. z2.8.0z1.4.0)Zboto_verZ boto3_ver)�salt�utilsZversionsZcheck_boto_reqs� r r �Z/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/boto_elasticsearch_domain.py� __virtual__i s r c C s t r td td� d S d S )Nzboto3.assign_funcs�es)�HAS_BOTO� __utils__�__name__)�optsr r r �__init__t s �r c C s� t ||||d�}z |j| d�}ddiW S tyC } z$|j�di ��d�dkr1ddiW Y d }~S d td |�iW Y d }~S d }~ww ) a Given a domain name, check to see if the given domain exists. Returns True if the given domain exists and returns False if the given function does not exist. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.exists mydomain ��region�key�keyid�profile�� DomainName�existsT�ErrorZCodeZResourceNotFoundExceptionFN�error�boto3.get_error)� _get_conn� describe_elasticsearch_domainr �response�getr )r r r r r �conn�domain�er r r r y s ��r c s� t ||||d�}z%|j| d�� � r)d� v r)� �di �� d}d� fdd�|D �iW S ddiW S tyG } zd td |�iW Y d}~S d}~ww ) z� Given a domain name describe its status. Returns a dictionary of interesting properties. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.status mydomain r r � DomainStatus) ZEndpoint�CreatedZDeletedr ZDomainId� EBSOptions�SnapshotOptions�AccessPolicies� Processing�AdvancedOptions�ARN�ElasticsearchVersionr! c s i | ] }|� v r|� � |��qS r �r ��.0�k�r! r r � <dictcomp>� s zstatus.<locals>.<dictcomp>Nr r )r r r r r �r r r r r r �keysr" r r0 r �status� s ��r4 c s� t ||||d�}z#|j| d�� � r'd� v r'� d � d}d� fdd�|D �iW S ddiW S tyE } zd td |�iW Y d}~S d}~ww ) z� Given a domain name describe its properties. Returns a dictionary of interesting properties. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.describe mydomain r r � DomainConfig��ElasticsearchClusterConfigr% r' r& r) r! c s( i | ]}|� v r|� � |i �� d ��qS )�Optionsr, r- r0 r r r1 � s "z describe.<locals>.<dictcomp>Nr r )r Z$describe_elasticsearch_domain_configr r r2 r r0 r �describe� s �� ��r9 c C sJ z�t |||| d�} i } dD ]B} t� | durOt� | }t|t�rKz tjj�|�}W n! tyJ } zdd| � d|j � �d�W Y d}~ W S d}~ww || | < q d| v r_tjj� | d �| d< d | v rkt| d �| d < | j dd | i| ��}|r�d |v r�d d iW S t � d� d diW S ty� } zdtd |�d�W Y d}~S d}~ww )a� Given a valid config, create a domain. Returns {created: true} if the domain was created and returns {created: False} if the domain was not created. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.create mydomain \ {'InstanceType': 't2.micro.elasticsearch', 'InstanceCount': 1, \ 'DedicatedMasterEnabled': false, 'ZoneAwarenessEnabled': false} \ {'EBSEnabled': true, 'VolumeType': 'gp2', 'VolumeSize': 10, \ 'Iops': 0} \ {"Version": "2012-10-17", "Statement": [{"Effect": "Allow", "Principal": {"AWS": "*"}, "Action": "es:*", \ "Resource": "arn:aws:es:us-east-1:111111111111:domain/mydomain/*", \ "Condition": {"IpAddress": {"aws:SourceIp": ["127.0.0.1"]}}}]} \ {"AutomatedSnapshotStartHour": 0} \ {"rest.action.multi.allow_explicit_index": "true"} r )r7 r% r' r& r) r+ NF�Error parsing �: ��updatedr r' r+ r r# �createdTzDomain was not createdr )r> r r )r �locals� isinstance�strr r �json�loads� ValueError�message�dumpsZcreate_elasticsearch_domain�log�warningr r )r r7 r% r' r& r) r r r r r+ r �kwargsr/ �valr" r! r r r �create� s< # ���� ��rK c C s^ zt ||||d�}|j| d� ddiW S ty. } zdtd |�d�W Y d}~S d}~ww ) a Given a domain name, delete it. Returns {deleted: true} if the domain was deleted and returns {deleted: false} if the domain was not deleted. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.delete mydomain r r �deletedTFr )rL r N)r Zdelete_elasticsearch_domainr r )r r r r r r r" r r r �delete& s ��rM c C s0 i } dD ]A} t � | durEt � | } t| t�rAz tjj�| �} W n ty@ } zdd| � d| j� �d�W Y d} ~ S d} ~ ww | | | < qd| v rUtjj� | d �| d< z't |||| d�}|j dd | i| ��}|rnd |vrxt � d � d diW S d d iW S ty� } zdtd | �d�W Y d} ~ S d} ~ ww )a� Update the named domain to the configuration. Returns {updated: true} if the domain was updated and returns {updated: False} if the domain was not updated. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.update mydomain \ {'InstanceType': 't2.micro.elasticsearch', 'InstanceCount': 1, \ 'DedicatedMasterEnabled': false, 'ZoneAwarenessEnabled': false} \ {'EBSEnabled': true, 'VolumeType': 'gp2', 'VolumeSize': 10, \ 'Iops': 0} \ {"Version": "2012-10-17", "Statement": [{"Effect": "Allow", "Principal": {"AWS": "*"}, "Action": "es:*", \ "Resource": "arn:aws:es:us-east-1:111111111111:domain/mydomain/*", \ "Condition": {"IpAddress": {"aws:SourceIp": ["127.0.0.1"]}}}]} \ {"AutomatedSnapshotStartHour": 0} \ {"rest.action.multi.allow_explicit_index": "true"} r6 NFr: r; r< r' r r r5 zDomain was not updatedr= Tr r )r? r@ rA r r rB rC rD rE rF r Z"update_elasticsearch_domain_configrG rH r r )r r7 r% r' r& r) r r r r Z call_argsr/ rJ r" r r! r r r �update= s@ # ������ ��rN c K s zjt ||||d�}g }|�� D ]\} } t| ��d�rq|�t| �t| �d�� q|du rW| du r4td��t| ||||d�} | rCd| vrMt�d� d d iW S | � di �� d �}n| dur_td��|j ||d � d d iW S t y� } zd t d | �d�W Y d} ~ S d} ~ ww )a! Add tags to a domain Returns {tagged: true} if the domain was tagged and returns {tagged: False} if the domain was not tagged. CLI Example: .. code-block:: bash salt myminion boto_elasticsearch_domain.add_tags mydomain tag_a=tag_value tag_b=tag_value r �__)�Key�ValueN�6One (but not both) of ARN or domain must be specified.�r r r r r r! �Domain tags not updated�taggedFr* )r* �TagListTr �rU r ) r �itemsrA � startswith�appendr r4 rG rH r �add_tagsr r ) r r* r r r r rI r Ztagslistr/ �v� domaindatar" r r r r[ � sB �� � ��r[ c C s� zRt ||||d�}|du r8|du rtd��t|||||d�}|r$d|vr.t�d� ddiW S |�di ��d �}n|dur@td��|j|�di ��d �| d � dd iW S tym } zdtd | �d �W Y d} ~ S d} ~ ww )a Remove tags from a trail Returns {tagged: true} if the trail was tagged and returns {tagged: False} if the trail was not tagged. CLI Example: .. code-block:: bash salt myminion boto_cloudtrail.remove_tags my_trail tag_a=tag_value tag_b=tag_value r NrR rS r! rT rU Fr* )r* �TagKeysTr rW ) r r r4 rG rH r � remove_tagsr r ) r^ r r* r r r r r r] r" r r r r_ � s8 �� � ��r_ c C s zft ||||d�}|du r8| du rtd��t| ||||d�}|r$d|vr.t�d� ddiW S |�di ��d �}n| dur@td��|j|d �}t�|� |�d g �} i } | D ] } | �d �| | �d �< qUd| iW S ty� } zdtd | �iW Y d} ~ S d} ~ ww )z� List tags of a trail Returns: tags: - {...} - {...} CLI Example: .. code-block:: bash salt myminion boto_cloudtrail.list_tags my_trail r NrR rS r! rT rU Fr* )r* rV rQ rP �tagsr r ) r r r4 rG rH r � list_tagsr r ) r r* r r r r r r] �retZtlistZtagdict�tagr" r r r ra � sB �� � ��ra )NNNN) NNNNNNNNNN) NNNNNNNNN)NNNNNN) �__doc__�loggingZsalt.utils.compatr Zsalt.utils.jsonZsalt.utils.versionsZsalt.exceptionsr � getLoggerr rG r r Zbotocore.exceptionsr �setLevel�CRITICALr � ImportErrorr r r r4 r9 rK rM rN r[ r_ ra r r r r �<module> sd M � (' � G �F �3 �.�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings