File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/boto3_elasticsearch.cpython-310.pyc
Back
o ;j�� � @ s� d Z ddlZddlZddlmZ e�e�ZdZ dd� Z dd� Z dd d �Z dd d �Z ddd�Zddd�Z ddd�ZdS )a Manage Elasticsearch Service ============================ .. versionadded:: 3001 :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 es.keyid: GKTADJGHEIQSXMKKRBJ08H es.key: askdjghsdfjkghWupUjasdflkdfklgjsdfjajkghs A region may also be specified in the configuration: .. code-block:: yaml es.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 :codeauthor: Herbert Buurman <herbert.buurman@ogd.nl> :depends: boto3 � N)�VersionZboto3_elasticsearchc C s8 dg d�i} | d D ]}|t vrdd|� �f S q tS )zM Only load if boto3 and the required module functions are available. �salt)�1boto3_elasticsearch.describe_elasticsearch_domainz/boto3_elasticsearch.create_elasticsearch_domainz6boto3_elasticsearch.update_elasticsearch_domain_config�boto3_elasticsearch.exists�&boto3_elasticsearch.get_upgrade_status�$boto3_elasticsearch.wait_for_upgrade�-boto3_elasticsearch.check_upgrade_eligibility�0boto3_elasticsearch.upgrade_elasticsearch_domainFz/A required function was not found in __salt__: )�__salt__�__virtualname__)Z requirements�req� r �S/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/boto3_elasticsearch.py� __virtual__7 s � ��r c C s& | d dkrd| d< | d � d� | S )a Helper function to check if the 'result' key of the return value has been properly set. This is to detect unexpected code-paths that would otherwise return a 'success'-y value but not actually be successful. :param dict ret: The returned value of a state function. �result�oopsF�commentzJAn internal error has occurred: The result value was not properly changed.)�append)�retr r r �_check_return_valueP s �r Tc C s� | dg i d�}d}d}t jjj| ||t|t�r t jj�|�n||||| | d� dd�}td | ||||d�}|d sUd |d < d |d v rKd }d|d�}nr|d � |d � nht jjj|d dd�}|d }dD ] }||v ro||= qfdD ]}||� di �v r�|d |= qrd|v r�d|vr�|d d s�|d= d|vr�d|d v r�|d d= |d s�|d= t jj� ||�}|r�d}|r�||kr�d}|dv �rct d r�d|d < |d � d � | |�� ||d < n�t jj�i d |�d |�d!|�d"|�d#|�d$|�d%|�d&|�d'| �d(| �d)| �d*| �d+|�d,|�d-|�d.|��}|dk�r$d/D ] }||v �r"||= �qtd0� ||dk�r/d1nd2� | fi |��}d |v �rLd |d < |d � |d � nTd3|d < |d � d4| � d5|� d6�� ||d < n=|dk�r�t| |||||d�}|d |d < |d �|d � |d �r�t jj�|d7|d d8 � t jj�|d9|d d: � | du�r�t| | d3||||d;�}|d |d < |d �|d � d8|d v �r�t jj�|d<|d d8 � d:|d v �r�t jj�|d=|d d: � t|�}|S )>a� Ensure an Elasticsearch Domain exists. :param str name: The name of the Elasticsearch domain that you are creating. Domain names are unique across the domains owned by an account within an AWS region. Domain names must start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen). :param str elasticsearch_version: String of format X.Y to specify version for the Elasticsearch domain eg. "1.5" or "2.3". :param dict elasticsearch_cluster_config: Dict specifying the configuration options for an Elasticsearch domain. Keys (case sensitive) in here are: - InstanceType (str): The instance type for an Elasticsearch cluster. - InstanceCount (int): The instance type for an Elasticsearch cluster. - DedicatedMasterEnabled (bool): Indicate whether a dedicated master node is enabled. - ZoneAwarenessEnabled (bool): Indicate whether zone awareness is enabled. - ZoneAwarenessConfig (dict): Specifies the zone awareness configuration for a domain when zone awareness is enabled. Keys (case sensitive) in here are: - AvailabilityZoneCount (int): An integer value to indicate the number of availability zones for a domain when zone awareness is enabled. This should be equal to number of subnets if VPC endpoints is enabled. - DedicatedMasterType (str): The instance type for a dedicated master node. - DedicatedMasterCount (int): Total number of dedicated master nodes, active and on standby, for the cluster. :param dict ebs_options: Dict specifying the options to enable or disable and specifying the type and size of EBS storage volumes. Keys (case sensitive) in here are: - EBSEnabled (bool): Specifies whether EBS-based storage is enabled. - VolumeType (str): Specifies the volume type for EBS-based storage. - VolumeSize (int): Integer to specify the size of an EBS volume. - Iops (int): Specifies the IOPD for a Provisioned IOPS EBS volume (SSD). :type access_policies: str or dict :param access_policies: Dict or JSON string with the IAM access policy. :param dict snapshot_options: Dict specifying the snapshot options. Keys (case senstive) in here are: - AutomatedSnapshotStartHour (int): Specifies the time, in UTC format, when the service takes a daily automated snapshot of the specified Elasticsearch domain. Default value is 0 hours. :param dict vpc_options: Dict with the options to specify the subnets and security groups for the VPC endpoint. Keys (case sensitive) in here are: - SubnetIds (list): The list of subnets for the VPC endpoint. - SecurityGroupIds (list): The list of security groups for the VPC endpoint. :param dict cognito_options: Dict with options to specify the cognito user and identity pools for Kibana authentication. Keys (case senstive) in here are: - Enabled (bool): Specifies the option to enable Cognito for Kibana authentication. - UserPoolId (str): Specifies the Cognito user pool ID for Kibana authentication. - IdentityPoolId (str): Specifies the Cognito identity pool ID for Kibana authentication. - RoleArn (str): Specifies the role ARN that provides Elasticsearch permissions for accessing Cognito resources. :param dict encryption_at_rest_options: Dict specifying the encryption at rest options. This option can only be used for the creation of a new Elasticsearch domain. Keys (case sensitive) in here are: - Enabled (bool): Specifies the option to enable Encryption At Rest. - KmsKeyId (str): Specifies the KMS Key ID for Encryption At Rest options. :param dict node_to_node_encryption_options: Dict specifying the node to node encryption options. This option can only be used for the creation of a new Elasticsearch domain. Keys (case sensitive) in here are: - Enabled (bool): Specify True to enable node-to-node encryption. :param dict advanced_options: Dict with option to allow references to indices in an HTTP request body. Must be False when configuring access to individual sub-resources. By default, the value is True. See http://docs.aws.amazon.com/elasticsearch-service/latest/developerguide /es-createupdatedomains.html#es-createdomain-configure-advanced-options for more information. :param dict log_publishing_options: Dict with options for various type of logs. The keys denote the type of log file and can be one of the following: - INDEX_SLOW_LOGS - SEARCH_SLOW_LOGS - ES_APPLICATION_LOGS The value assigned to each key is a dict with the following case sensitive keys: - CloudWatchLogsLogGroupArn (str): The ARN of the Cloudwatch log group to which the log needs to be published. - Enabled (bool): Specifies whether given log publishing option is enabled or not. :param bool blocking: Whether or not the state should wait for all operations (create/update/upgrade) to be completed. Default: ``True`` :param dict tags: Dict of tags to ensure are present on the Elasticsearch domain. .. versionadded:: 3001 Example: This will create an elasticsearch domain consisting of a single t2.small instance in the eu-west-1 region (Ireland) and will wait until the instance is available before returning from the state. .. code-block:: yaml Create new domain: boto3_elasticsearch.present: - name: my_domain - elasticsearch_version: '5.1' - elasticsearch_cluster_config: InstanceType: t2.small.elasticsearch InstanceCount: 1 DedicatedMasterEnabled: False ZoneAwarenessEnabled: False - ebs_options: EBSEnabled: True VolumeType: gp2 VolumeSize: 10 - snapshot_options: AutomatedSnapshotStartHour: 3 - vpc_options: SubnetIds: - subnet-12345678 SecurityGroupIds: - sg-12345678 - node_to_node_encryption_options: Enabled: False - region: eu-west-1 - tags: foo: bar baz: qux r ��namer r �changesN) Z DomainNameZElasticsearchClusterConfigZ EBSOptionsZAccessPoliciesZSnapshotOptions� VPCOptions�CognitoOptions�AdvancedOptionsZLogPublishingOptions� )Z recurse_depthr ��region�keyid�key�profiler F�ResourceNotFoundException�error�create��old�newr �response�ElasticsearchVersion) ZDomainIdZUpgradeProcessing�CreatedZDeleted� ProcessingZ EndpointsZARNZEncryptionAtRestOptionsZNodeToNodeEncryptionOptionsr) ZServiceSoftwareOptions)ZVPCIdZAvailabilityZonesr r ZEnabledr z&rest.action.multi.allow_explicit_index�update�upgrade)r$ r, �testz2The Elasticsearch Domain "{}" would have been {}d.r �elasticsearch_version� elasticsearch_cluster_config� ebs_options� vpc_options�access_policies�snapshot_options�cognito_options�encryption_at_rest_options� node_to_node_encryption_options�advanced_options�log_publishing_options�blockingr r r r! )r/ r6 r7 z-boto3_elasticsearch.{}_elasticsearch_domain{}Z_config� TzElasticsearch Domain "z " has been zd.zchanges:old:versionr& zchanges:new:versionr' )�tags�replacer r r r! zchanges:old:tagszchanges:new:tags)r �utils�dataZ filter_falsey� isinstance�dict�json�dumpsr r �getZrecursive_diff�__opts__�format�upgraded�extendZ dictupdateZset_dict_key_value�taggedZupdate_dict_key_valuer )r r/ r0 r1 r3 r4 r2 r5 r6 r7 r8 r9 r: r< r r r r! r �action�current_domainZ target_conf�resZ config_diffZcurrent_domain_version�itemZ boto_kwargsr r r �present` sF ��� � � � ��� �� �������� � � � � ����� ����� � � �� � ��rN c C s" | dg i d�}t d | ||||d�}d|v r$d|d< |d �|d � ng|d r|td rCd |d< |d �d | � d �� | d d �|d< nHt d | |||||d�}d|v red|d< |d �d�| |d �� n&d|d< |d �d | � d�� | d d �|d< nd|d< |d �d | � d�� t|�}|S )a� Ensure the Elasticsearch Domain specified does not exist. :param str name: The name of the Elasticsearch domain to be made absent. :param bool blocking: Whether or not the state should wait for the deletion to be completed. Default: ``True`` .. versionadded:: 3001 Example: .. code-block:: yaml Remove Elasticsearch Domain: boto3_elasticsearch.absent: - name: my_domain - region: eu-west-1 r r r r r# Fr r r. N�Elasticsearch domain "z" would have been removed.r% r z/boto3_elasticsearch.delete_elasticsearch_domain)� domain_namer: r r r r! z,Error deleting Elasticsearch domain "{}": {}Tz" has been deleted.z" is already absent.)r r rE rF r )r r: r r r r! r rL r r r �absent� sL � ���� �rQ c C sF | dg i d�}d}t d | ||||d�} | d s8d|d< d| d v r.|d �d | � d �� n?|d �| d � n5| d }|d } |rV| |krVd|d< |d �d�| |�� nt|�t| �k rmd|d< |d �d�| |�� t|d t�rv|S t�dt� t d | ||||d�} d | v r�d|d< |d �d�| | d �� |S | d � d�dkr�|r�t d | ||||d�} d | v r�d|d< |d �d�| | d �� n/| d � dd�� |�r�d|d< |d �d�| |�� nd|d< |d �d �| | d � d��� t|d t��r|S t�d t� t d | |||||d�} d | v �r,d|d< |d �d �| | d �� nq| d �sAd|d< |d �d �| |�� n\t�d!t� t d" �rad|d< |d �d#� |d |d$�|d%< n<t d& | ||||||d'�} d | v �r�d|d< |d �d(�| | d �� nd|d< |d �d)�| |�� |d |d$�|d%< t |�}|S )*a� Ensures the Elasticsearch domain specified runs on the specified version of elasticsearch. Only upgrades are possible as downgrades require a manual snapshot and an S3 bucket to store them in. Note that this operation is blocking until the upgrade is complete. :param str name: The name of the Elasticsearch domain to upgrade. :param str elasticsearch_version: String of format X.Y to specify version for the Elasticsearch domain eg. "1.5" or "2.3". .. versionadded:: 3001 Example: .. code-block:: yaml Upgrade Elasticsearch Domain: boto3_elasticsearch.upgraded: - name: my_domain - elasticsearch_version: '7.2' - region: eu-west-1 r r Nr r r Fr" r# r �The Elasticsearch domain "�" does not exist.r( r) TzBThe Elasticsearch domain "{}" is already at the desired version {}z?Elasticsearch domain "{}" cannot be downgraded to version "{}".z'%s :upgraded: Check upgrade in progressr z;Error determining current upgrade status of domain "{}": {}Z StepStatusZ IN_PROGRESSr z8Error waiting for upgrade of domain "{}" to complete: {}Z UpgradeNamer; z5Elasticsearch Domain "{}" is already at version "{}".z?An upgrade of Elasticsearch domain "{}" is already underway: {}z'%s :upgraded: Check upgrade eligibilityr z6Error checking upgrade eligibility for domain "{}": {}zKThe Elasticsearch Domain "{}" is not eligible to be upgraded to version {}.z %s :upgraded: Start the upgrader. zCThe Elasticsearch version for domain "{}" would have been upgraded.r% r r )r: r r r r! z-Error upgrading Elasticsearch domain "{}": {}z>The Elasticsearch domain "{}" has been upgraded to version {}.) r r rF r r@ �bool�log�debug�__name__rD �endswithrE r ) r r/ r: r r r r! r rK rL �current_versionZres2r r r rG � s� � �� ��� �������� � �� � � �� ��� �rG c C s. | dg i d�}t d | ||||d�}d|v r(d|d< |d �d �| |d �� n(|d d }d } t d | ||||d�}d|v rPd|d< |d �d�| |d �� t|d t�rY|S z |d d d �d�} W n tyo Y nw |s�d|d< |d �d| � d�� n[| s�d|d< |d �d�| |�� nI|�d�} | �d�} |r�| d | d ks�td r�d |d< |d �d�| | �� || d�|d< nt | | ||||d�}nd|d< |d �d �| |�� t |�}|d �r|d �r|�st | |||||d �}|d �r|d �r|d d |d d < |d � |d � |S ) a� Ensures the Elasticsearch domain specifies runs on the latest compatible version of elasticsearch, upgrading it if it is not. Note that this operation is blocking until the upgrade is complete. :param str name: The name of the Elasticsearch domain to upgrade. :param bool minor_only: Only upgrade to the latest minor version. .. versionadded:: 3001 Example: The following example will ensure the elasticsearch domain ``my_domain`` is upgraded to the latest minor version. So if it is currently 5.1 it will be upgraded to 5.6. .. code-block:: yaml Upgrade Elasticsearch Domain: boto3_elasticsearch.latest: - name: my_domain - minor_only: True - region: eu-west-1 r r r )rP r r r r! r# Fr r z:Error getting information of Elasticsearch domain "{}": {}r( r) Nz9boto3_elasticsearch.get_compatible_elasticsearch_versionszQError getting compatible Elasticsearch versions for Elasticsearch domain "{}": {}r ZTargetVersions���TrR z" can not be upgraded.zEThe Elasticsearch domain "{}" is already at the lastest version "{}".�.r. zBElasticsearch domain "{}" would have been updated to version "{}".r% r r zDElasticsearch domain "{}" is already at its latest minor version {}.)� minor_onlyr r r r! r' ) r r rF r@ rT �pop� IndexError�splitrE rG r �latestrH ) r r\ r r r r! r rL rY Zlatest_versionZa_current_versionZa_latest_versionr r r r` � s� ��� � � �� �� ��r` Fc C s | dg i d�}i }t d | ||||d�} | d r@t d | ||||d�} d| v r9d|d< |d �d �| | d �� n| d p>i }nd|d< |d �d | � d �� t|d t�rX|S tjj�||�} | srd|d< |d �d | � d�� n�|ry| |d< n ||� |�d�|d< t d r�d|d< |d �d�| |r�dnd�� nl|r�t d |� � | ||||d�} d| v r�d|d< |d �d�| | d �� i |d< t|d t�r�|S t d | |||||d�} d| v r�d|d< |d �d �| | d �� i |d< nd|d< |d �d �| |�rdnd�� t |�}|S ) av Ensures the Elasticsearch domain has the tags provided. Adds tags to the domain unless ``replace`` is set to ``True``, in which case all existing tags will be replaced with the tags provided in ``tags``. (This will remove all tags if ``replace`` is ``True`` and ``tags`` is empty). :param str name: The Elasticsearch domain to work with. :param dict tags: The tags to add to/replace on the Elasticsearch domain. :param bool replace: Whether or not to replace (``True``) all existing tags on the Elasticsearch domain, or add (``False``) tags to the ES domain. .. versionadded:: 3001 r r r r r z boto3_elasticsearch.list_tagsr# Fr z4Error fetching tags of Elasticsearch domain "{}": {}r( rO rS Tz!" already has the specified tags.r r% r. Nz7Tags on Elasticsearch domain "{}" would have been {}ed.Zreplac�addz boto3_elasticsearch.remove_tags)Ztag_keysrP r r r r! z>Error removing current tags from Elasticsearch domain "{}": {}z boto3_elasticsearch.add_tags)rP r< r r r r! z+Error tagging Elasticsearch domain "{}": {}z1Tags on Elasticsearch domain "{}" have been {}ed.) r r rF r@ rT r r> Z dictdifferZ deep_diffr, rE �keysr ) r r< r= r r r r! r Z current_tagsrL Z diff_tagsr r r rI s� � ��� � ��� ���� ��rI )NNNNNNNNNNNTNNNNN)TNNNN)NFNNNN)�__doc__�loggingZsalt.utils.jsonr Zsalt.utils.versionsr � getLoggerrW rU r r r rN rQ rG r` rI r r r r �<module> sN - � LB � 1q�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings