File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/boto3_elasticsearch.cpython-310.pyc
Back
o ;j�� � @ s d Z ddlZddlZddlZddlZddlmZ ddlm Z z ddl Z ddl Z ddl m Z mZmZ e�d��ej� dZW n eyH dZY nw e�e�Zd d � Zd d � Z dHd d�Ze ddd� dIdd��Z dJdd�Z dKdd�Z e ddd�dIdd��Z dIdd �Z dId d �Z dId d �Z e dd!d� dLd"d#��Z!e dd$d� dLd%d&��Z"e dd$d� dLd'd(��Z#e dd)d� dLd*d+��Z$e dd)d�dId,d-��Z%e dd)d�dId.d/��Z&dId0d1�Z'e dd!d� dLd2d3��Z(e dd!d�dId4d5��Z) dMd6d7�Z*e dd$d� dLd8d9��Z+ dMd:d;�Z,e ddd� dId<d=��Z- dNd>d?�Z.e dd)d� dOd@dA��Z/dIdBdC�Z0dIdDdE�Z1e dd)d� dIdFdG��Z2dS )Pa* Connection module for Amazon Elasticsearch Service .. versionadded:: 3001 :configuration: This module accepts explicit IAM 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 All methods return a dict with: 'result' key containing a boolean indicating success or failure, 'error' key containing the errormessage returned by boto on error, 'response' key containing the data of the response returned by boto on success. :codeauthor: Herbert Buurman <herbert.buurman@ogd.nl> :depends: boto3 � N)�SaltInvocationError)�depends)� ClientError�ParamValidationError� WaiterError�boto3TFc C s t o tjjjddd�S )zg Only load if boto libraries exist and if boto libraries are greater than a given version. z1.2.7F)Z boto3_verZ check_boto)�HAS_BOTO�salt�utilsZversionsZcheck_boto_reqs� r r �T/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/boto3_elasticsearch.py� __virtual__O s �r c C s | }t r td td� d S d S )Nzboto3.assign_funcs�es)r � __utils__�__name__)�opts�_r r r �__init__Y s �r c C s t || f�s td��ddi}|du r;t| ||||d�}d|v r%|�|� n|d s4|�dd�| �i� n|d �d �}|r�|d d � |pDi �� D �d �} zt||||d �} | jdi | �� d|d< W |S t t fy� } z|�dt d | �d i� W Y d} ~ |S d} ~ ww |S )aH Attaches tags to an existing Elasticsearch domain. Tags are a set of case-sensitive key value pairs. An Elasticsearch domain may have up to 10 tags. :param str domain_name: The name of the Elasticsearch domain you want to add tags to. :param str arn: The ARN of the Elasticsearch domain you want to add tags to. Specifying this overrides ``domain_name``. :param dict tags: The dict of tags to add to the Elasticsearch domain. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.add_tags domain_name=mydomain tags='{"foo": "bar", "baz": "qux"}' �5At least one of domain_name or arn must be specified.�resultFN�� domain_name�region�key�keyid�profile�error�)The domain with name "{}" does not exist.�response�ARNc S s g | ] \}}||d ��qS )�ZKeyZValuer )�.0�k�valuer r r � <listcomp>� � �z add_tags.<locals>.<listcomp>)r �TagList�r r r r T�boto3.get_error�messager ) �anyr � describe_elasticsearch_domain�update�format�get�items� _get_conn�add_tagsr r r ) r �arn�tagsr r r r �ret�res� boto_params�conn�expr r r r1 _ sP �� ��� �� �$��r1 �botocorez1.12.21)�versionc C s� ddi}zt ||||d�}|j| d�}d|d< |d |d< W |S ttfyA } z|�dtd |�d i� W Y d }~|S d }~ww ) a� Cancels a scheduled service software update for an Amazon ES domain. You can only perform this operation before the AutomatedUpdateDate and when the UpdateStatus is in the PENDING_UPDATE state. :param str domain_name: The name of the domain that you want to stop the latest service software update on. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the current service software options. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r F�r r r r �� DomainNameT�ServiceSoftwareOptionsr r r( r) N)r0 �,cancel_elasticsearch_service_software_updater r r, r � r r r r r r4 r7 r5 r8 r r r r? � s �$��r? c C s� t jj�| t|p d�||t|t�rt jj�|�n|||||| | | d� �}ddi}z1t | |||d�}|j di |��}|rId|v rId|d< |d |d< | rW|� d �j | d � W |S W |S t ttfy| } z|�d td |�d i� W Y d}~|S d}~ww )aW Given a valid config, create a domain. :param str domain_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: Dictionary 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. If this is not enabled, the Elasticsearch domain will only be in one availability zone. - 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. Allowed values: 2, 3 - 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 sensitive) 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 sensitive) 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. 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. 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 to wait (block) until the Elasticsearch domain has been created. Note: Not all instance types allow enabling encryption at rest. See https://docs.aws.amazon.com /elasticsearch-service/latest/developerguide/aes-supported-instance-types.html :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the domain status configuration. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.create_elasticsearch_domain mydomain \ elasticsearch_cluster_config='{ \ "InstanceType": "t2.micro.elasticsearch", \ "InstanceCount": 1, \ "DedicatedMasterEnabled": False, \ "ZoneAwarenessEnabled": False}' \ ebs_options='{ \ "EBSEnabled": True, \ "VolumeType": "gp2", \ "VolumeSize": 10, \ "Iops": 0}' \ access_policies='{ \ "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"]}}}]}' \ snapshot_options='{"AutomatedSnapshotStartHour": 0}' \ advanced_options='{"rest.action.multi.allow_explicit_index": "true"}' � ) r= �ElasticsearchVersion�ElasticsearchClusterConfig� EBSOptions�AccessPolicies�SnapshotOptions� VPCOptions�CognitoOptionsZEncryptionAtRestOptionsZNodeToNodeEncryptionOptions�AdvancedOptions�LogPublishingOptionsr Fr' � DomainStatusTr �ESDomainAvailabler< r r( r) Nr )r r �data� filter_falsey�str� isinstance�dict�json�dumpsr0 �create_elasticsearch_domain� get_waiter�waitr r r r, r )r �elasticsearch_version� elasticsearch_cluster_config� ebs_options�access_policies�snapshot_options� vpc_options�cognito_optionsZencryption_at_rest_optionsZ node_to_node_encryption_options�advanced_options�log_publishing_options�blockingr r r r � boto_kwargsr4 r7 r5 r8 r r r rT � sF ��� ��$��rT c C s� ddi}z#t ||||d�}|j| d� d|d< |r%|�d�j| d� W |S W |S tttfyJ } z|�dtd |�d i� W Y d }~|S d }~ww ) a Permanently deletes the specified Elasticsearch domain and all of its data. Once a domain is deleted, it cannot be recovered. :param str domain_name: The name of the domain to delete. :param bool blocking: Whether or not to wait (block) until the Elasticsearch domain has been deleted. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr' r< TZESDomainDeletedr r( r) N) r0 �delete_elasticsearch_domainrU rV r r r r, r ) r r` r r r r r4 r7 r8 r r r rb { s ��$��rb z1.7.30c C st ddi}zt | |||d�}|�� d|d< W |S ttfy9 } z|�dtd |�d i� W Y d}~|S d}~ww ) a� Deletes the service-linked role that Elasticsearch Service uses to manage and maintain VPC domains. Role deletion will fail if any existing VPC domains use the role. You must delete any such Elasticsearch domains before deleting the role. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; Tr r( r) N)r0 �!delete_elasticsearch_service_roler r r, r )r r r r r4 r7 r8 r r r rc � s �$��rc c C � ddi}z't ||||d�}|j| d�}|r&d|v r)d|d< |d |d< W |S W |S W |S ttfyM } z|�dtd |�d i� W Y d }~|S d }~ww ) a� Given a domain name gets its status description. :param str domain_name: The name of the domain to get the status of. :rtype: dict :return: Dictionary ith key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the domain status information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr' r< rK Tr r r( r) N)r0 r+ r r r, r r@ r r r r+ � s" ���$��r+ c C rd ) a: Provides cluster configuration information about the specified Elasticsearch domain, such as the state, creation date, update version, and update date for cluster options. :param str domain_name: The name of the domain to describe. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the current configuration information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr' r< � DomainConfigTr r r( r) N)r0 �$describe_elasticsearch_domain_configr r r, r r@ r r r rf � s" ���$��rf c C s� ddi}z't ||||d�}|j| d�}|r&d|v r)d|d< |d |d< W |S W |S W |S ttfyM } z|�dtd |�d i� W Y d }~|S d }~ww ) a� Returns domain configuration information about the specified Elasticsearch domains, including the domain ID, domain endpoint, and domain ARN. :param list domain_names: List of domain names to get information for. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the list of domain status information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.describe_elasticsearch_domains '["domain_a", "domain_b"]' r Fr; )� DomainNamesZDomainStatusListTr r r( r) N)r0 � describe_elasticsearch_domainsr r r, r ) Z domain_namesr r r r r4 r7 r5 r8 r r r rh � s" ���$��rh z1.5.18c C s� ddi}t jj�|| t|�d��}z)t||||d�} | jd i |��} | r5d| v r8d|d< | d |d< W |S W |S W |S ttfy\ } z|� dt d | �d i� W Y d } ~ |S d } ~ ww ) a� Describe Elasticsearch Limits for a given InstanceType and ElasticsearchVersion. When modifying existing Domain, specify the `` DomainName `` to know what Limits are supported for modifying. :param str instance_type: The instance type for an Elasticsearch cluster for which Elasticsearch ``Limits`` are needed. :param str elasticsearch_version: Version of Elasticsearch for which ``Limits`` are needed. :param str domain_name: Represents the name of the Domain that we are trying to modify. This should be present only if we are querying for Elasticsearch ``Limits`` for existing domain. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the limits information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.describe_elasticsearch_instance_type_limits \ instance_type=r3.8xlarge.elasticsearch \ elasticsearch_version='6.2' r F)r= Z InstanceTyperB r; Z LimitsByRoleTr r r( r) Nr ) r r rM rN rO r0 �+describe_elasticsearch_instance_type_limitsr r r, r ) Z instance_typerW r r r r r r4 r6 r7 r5 r8 r r r ri s. &�� ���$��ri z1.10.15c C � ddi}z3t ||||d�}d| i}g }|�d�jd i |��D ] } |�| d � q |r5d|d< ||d< W |S W |S ttfyY } z|�d td | �d i� W Y d } ~ |S d } ~ ww )a] Lists available reserved Elasticsearch instance offerings. :param str reserved_elasticsearch_instance_offering_id: The offering identifier filter value. Use this parameter to show only the available offering that matches the specified reservation identifier. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the list of offerings information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; �'ReservedElasticsearchInstanceOfferingId�2describe_reserved_elasticsearch_instance_offeringsZ&ReservedElasticsearchInstanceOfferingsTr r r( r) Nr �r0 � get_paginator�paginate�extendr r r, r ) �+reserved_elasticsearch_instance_offering_idr r r r r4 r7 r6 r5 �pager8 r r r rl E s2 ��� � ��$��rl c C rj )a9 Returns information about reserved Elasticsearch instances for this account. :param str reserved_elasticsearch_instance_id: The reserved instance identifier filter value. Use this parameter to show only the reservation that matches the specified reserved Elasticsearch instance ID. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a list of information on reserved instances. Upon failure, also contains a key 'error' with the error message as value. :note: Version 1.9.174 of boto3 has a bug in that reserved_elasticsearch_instance_id is considered a required argument, even though the documentation says otherwise. .. versionadded:: 3001 r Fr; Z ReservedElasticsearchInstanceId�)describe_reserved_elasticsearch_instancesZ ReservedElasticsearchInstancesTr r r( r) Nr rm ) Z"reserved_elasticsearch_instance_idr r r r r4 r7 r6 r5 rr r8 r r r rs o s2 ��� � ��$��rs z1.10.77c C s� ddi}t jj�d| i�}z)t||||d�}|jd i |��}|r1d|v r4d|d< |d |d< W |S W |S W |S ttfyX } z|�dt d | �d i� W Y d } ~ |S d } ~ ww ) a@ Returns a list of upgrade compatible Elastisearch versions. You can optionally pass a ``domain_name`` to get all upgrade compatible Elasticsearch versions for that specific domain. :param str domain_name: The name of an Elasticsearch domain. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a list of compatible versions. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr= r; Z CompatibleElasticsearchVersionsTr r r( r) Nr ) r r rM rN r0 �%get_compatible_elasticsearch_versionsr r r, r � r r r r r r4 r6 r7 r5 r8 r r r rt � s$ ���$��rt c C rj )a� Retrieves the complete history of the last 10 upgrades that were performed on the domain. :param str domain_name: The name of an Elasticsearch domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen). :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a list of upgrade histories. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; r= �get_upgrade_historyZUpgradeHistoriesTr r r( r) Nr rm ) r r r r r r4 r7 r6 r5 rr r8 r r r rv � s$ ��$��rv c C s� ddi}d| i}z t ||||d�}|jd i |��}d|d< ||d< |d= W |S ttfyH } z|�dtd | �d i� W Y d } ~ |S d } ~ ww ) a� Retrieves the latest status of the last upgrade or upgrade eligibility check that was performed on the domain. :param str domain_name: The name of an Elasticsearch domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen). :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with upgrade status information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr= r; Tr ZResponseMetadatar r( r) Nr )r0 �get_upgrade_statusr r r, r ru r r r rw � s �$��rw c C s� ddi}z*t | |||d�}|�� }|r)d|v r,d|d< dd� |d D �|d< W |S W |S W |S ttfyP } z|�d td |�d i� W Y d }~|S d }~ww ) a� Returns the name of all Elasticsearch domains owned by the current user's account. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a list of domain names. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; rg Tc S s g | ]}|d �qS r< r �r! �itemr r r r$ s z%list_domain_names.<locals>.<listcomp>r r r( r) N)r0 �list_domain_namesr r r, r )r r r r r4 r7 r5 r8 r r r rz � s" ���$��rz c C s� ddi}z;t ||||d�}tjj�t| �|d��}g } |�d�jd i |��D ] } | �| d � q&| r=d|d< | |d< W |S W |S t t fya } z|� d t d | �d i� W Y d } ~ |S d } ~ ww )a) List all Elasticsearch instance types that are supported for given ElasticsearchVersion. :param str elasticsearch_version: Version of Elasticsearch for which list of supported elasticsearch instance types are needed. :param str domain_name: DomainName represents the name of the Domain that we are trying to modify. This should be present only if we are querying for list of available Elasticsearch instance types when modifying existing domain. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a list of Elasticsearch instance types. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; )rB r= �!list_elasticsearch_instance_typesZElasticsearchInstanceTypesTr r r( r) Nr ) r0 r r rM rN rO rn ro rp r r r, r ) rW r r r r r r4 r7 r6 r5 rr r8 r r r r{ s0 �� � ��$��r{ c C s� ddi}z+t | |||d�}g }|�d��� D ] }|�|d � q|r-d|d< ||d< W |S W |S ttfyQ } z|�dtd |�d i� W Y d }~|S d }~ww ) ao List all supported Elasticsearch versions. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a list of Elasticsearch versions. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; �list_elasticsearch_versionsZElasticsearchVersionsTr r r( r) Nrm ) r r r r r4 r7 r5 rr r8 r r r r| F s" ��$��r| c C s t || f�s td��ddi}|du r;t| ||||d�}d|v r%|�|� n|d s4|�dd�| �i� n|d �d �}|r�z"t||||d �}|j|d �}d |d< d d� |�dg �D �|d< W |S tt fy� } z|�dt d | �d i� W Y d} ~ |S d} ~ ww |S )ag Returns all tags for the given Elasticsearch domain. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with a dict of tags. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r r FNr r r r r r' )r Tc S s i | ] }|d |d �qS r r rx r r r � <dictcomp>� r% z list_tags.<locals>.<dictcomp>r& r( r) ) r* r r+ r, r- r. r0 � list_tagsr r r ) r r2 r r r r r4 r5 r7 r8 r r r r~ a sL �� ��� ��$��r~ c C s� ddi}t jj�| ||d��}z t||||d�} | jd i |��} | r-d|d< | |d< W |S W |S ttfyQ } z|�dt d | �d i� W Y d } ~ |S d } ~ ww ) a� Allows you to purchase reserved Elasticsearch instances. :param str reserved_elasticsearch_instance_offering_id: The ID of the reserved Elasticsearch instance offering to purchase. :param str reservation_name: A customer-specified identifier to track this reservation. :param int instance_count: The number of Elasticsearch instances to reserve. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with purchase information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r F)rk ZReservationNameZ InstanceCountr; Tr r r( r) Nr ) r r rM rN r0 �1purchase_reserved_elasticsearch_instance_offeringr r r, r ) rq Zreservation_nameZinstance_countr r r r r4 r6 r7 r5 r8 r r r r � s* �� ��$��r c C s� t ||f�s td��ddi}|du r;t|||||d�}d|v r%|�|� n|d s4|�dd�|�i� n|d �d �}|rvzt||||d �} | j|| d � d |d< W |S tt fyu } z|�dt d | �d i� W Y d} ~ |S d} ~ ww |S )a Removes the specified set of tags from the specified Elasticsearch domain. :param list tag_keys: List with tag keys you want to remove from the Elasticsearch domain. :param str domain_name: The name of the Elasticsearch domain you want to remove tags from. :param str arn: The ARN of the Elasticsearch domain you want to remove tags from. Specifying this overrides ``domain_name``. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.remove_tags '["foo", "bar"]' domain_name=my_domain r r FNr r r r r r' )r ZTagKeysTr( r) ) r* r r+ r, r- r. r0 � remove_tagsr r r ) Ztag_keysr r2 r r r r r4 r5 r7 r8 r r r r� � sF �� ��� �$��r� c C s� ddi}d| i}z)t ||||d�}|jd i |��}|r,d|v r/d|d< |d |d< W |S W |S W |S ttfyS } z|�dtd | �d i� W Y d } ~ |S d } ~ ww ) a� Schedules a service software update for an Amazon ES domain. :param str domain_name: The name of the domain that you want to update to the latest service software. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with service software information. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr= r; r> Tr r r( r) Nr )r0 �+start_elasticsearch_service_software_updater r r, r ru r r r r� s$ ���$��r� c C s� ddi}t jj�| ||||||t|t�rt jj�|�n||d� �}z7t| | | | d�}|j di |��}|r8d|vr>t � d� n d|d< |d |d< | rV|� d �j | d � W |S W |S tttfy{ } z|�d td |�d i� W Y d}~|S d}~ww )a� Modifies the cluster configuration of the specified Elasticsearch domain, for example setting the instance type and the number of instances. :param str domain_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 dict elasticsearch_cluster_config: Dictionary 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). :param dict snapshot_options: Dict specifying the snapshot options. Keys (case sensitive) 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 sensitive) 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 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 str/dict access_policies: Dict or JSON string with the IAM access policy. :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 to wait (block) until the Elasticsearch domain has been updated. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the domain configuration. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.update_elasticsearch_domain_config mydomain \ elasticsearch_cluster_config='{\ "InstanceType": "t2.micro.elasticsearch", \ "InstanceCount": 1, \ "DedicatedMasterEnabled": false, "ZoneAwarenessEnabled": false}' \ ebs_options='{\ "EBSEnabled": true, \ "VolumeType": "gp2", \ "VolumeSize": 10, \ "Iops": 0}' \ access_policies='{"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"]}}}]}' \ snapshot_options='{"AutomatedSnapshotStartHour": 0}' \ advanced_options='{"rest.action.multi.allow_explicit_index": "true"}' r F) r= rC rD rF rG rH rI rE rJ r; re zDomain was not updatedTr rL r< r r( r) Nr )r r rM rN rP rQ rR rS r0 �"update_elasticsearch_domain_config�log�warningrU rV r r r r, r )r rX rY r\ rZ r[ r] r^ r_ r` r r r r r4 ra r7 r5 r8 r r r r� ! s@ {��� ��$��r� c C s� ddi}t jj�| t|�|d��} z+t||||d�} | jd i | ��} | r,d|d< | |d< |r:| �d�j| d� W |S W |S t t t fy_ } z|� d t d | �d i� W Y d } ~ |S d } ~ ww )a@ Allows you to either upgrade your domain or perform an Upgrade eligibility check to a compatible Elasticsearch version. :param str domain_name: The name of an Elasticsearch domain. Domain names are unique across the domains owned by an account within an AWS region. Domain names start with a letter or number and can contain the following characters: a-z (lowercase), 0-9, and - (hyphen). :param str target_version: The version of Elasticsearch that you intend to upgrade the domain to. :param bool perform_check_only: This flag, when set to True, indicates that an Upgrade Eligibility Check needs to be performed. This will not actually perform the Upgrade. :param bool blocking: Whether or not to wait (block) until the Elasticsearch domain has been upgraded. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with the domain configuration. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.upgrade_elasticsearch_domain mydomain \ target_version='6.7' \ perform_check_only=True r F)r= Z TargetVersionZPerformCheckOnlyr; Tr �ESUpgradeFinishedr< r r( r) Nr )r r rM rN rO r0 � upgrade_elasticsearch_domainrU rV r r r r, r ) r Ztarget_version�perform_check_onlyr` r r r r r4 r6 r7 r5 r8 r r r r� � s. *����$��r� c C s� ddi}zt ||||d�}|j| d� d|d< W |S ttfyN } z'|j�di ��d�dkrC|�d td |�d i� W Y d }~|S W Y d }~|S d }~ww ) ae Given a domain name, check to see if the given domain exists. :param str domain_name: The name of the domain to check. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr' r< T�ErrorZCodeZResourceNotFoundExceptionr r( r) N)r0 r+ r r r r. r, r )r r r r r r4 r7 r8 r r r �exists� s �$ ���r� c C s� ddi}zt ||||d�}|�d�j| d� d|d< W |S tttfy? } z|�dtd |�d i� W Y d }~|S d }~ww ) ag Block until an upgrade-in-progress for domain ``name`` is finished. :param str name: The name of the domain to wait for. :rtype dict: :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 r Fr; r� r< Tr r( r) N)r0 rU rV r r r r, r )r r r r r r4 r7 r8 r r r �wait_for_upgrade s �$��r� c C s� ddi}t | ||||d�}d|v r|S |d d d }t|�|vr3d|d< d|d< d �||�|d< |S t| |dd||||d �}d|v rE|S t| ||||d�}d|v rT|S t| ||||d�}d|d< |d d d kop|d d dk|d< |S )a� Helper function to determine in one call if an Elasticsearch domain can be upgraded to the specified Elasticsearch version. This assumes that the Elasticsearch domain is at rest at the moment this function is called. I.e. The domain is not in the process of : - being created. - being updated. - another upgrade running, or a check thereof. - being deleted. Behind the scenes, this does 3 things: - Check if ``elasticsearch_version`` is among the compatible elasticsearch versions. - Perform a check if the Elasticsearch domain is eligible for the upgrade. - Check the result of the check and return the result as a boolean. :param str name: The Elasticsearch domain name to check. :param str elasticsearch_version: The Elasticsearch version to upgrade to. :rtype: dict :return: Dictionary with key 'result' and as value a boolean denoting success or failure. Upon success, also contains a key 'reponse' with boolean result of the check. Upon failure, also contains a key 'error' with the error message as value. .. versionadded:: 3001 CLI Example: .. code-block:: bash salt myminion boto3_elasticsearch.check_upgrade_eligibility mydomain '6.7' r Fr; r r r ZTargetVersionsTz4Desired version "{}" not in compatible versions: {}.)r� r` r r r r Z UpgradeStepZPRE_UPGRADE_CHECKZ StepStatusZ SUCCEEDED)rt rO r- r� r� rw ) r rW r r r r r4 r5 Zcompatible_versionsr r r �check_upgrade_eligibility+ sN & � �� � ��r� )NNNNNNN)NNNN)NNNNNNNNNNNFNNNN)FNNNN)NNNNN)NNNNNN) NNNNNNNNFNNNN)NFNNNN)3�__doc__�loggingZsalt.utils.compatr Zsalt.utils.jsonZsalt.utils.versionsZsalt.exceptionsr Zsalt.utils.decoratorsr r r9 Zbotocore.exceptionsr r r � getLogger�setLevel�INFOr � ImportErrorr r� r r r1 r? rT rb rc r+ rf rh ri rl rs rt rv rw rz r{ r| r~ r r� r� r� r� r� r� r� r r r r �<module> s 5 � � H � � 7 � � � � " � 8 � ) � - � � / � 4 �. � @ � � � > �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings