VhddlmZmZmZeZdZdZdZddl Z ddl m Z ddl m Z ddlmZdd lmZdd lmZ ddlZd ZeZd ZdZGddeZy#e$rd ZY!wxYw))absolute_importdivisionprint_functiona author: - Eric Belhomme (@eric-belhomme) version_added: '0.2.0' name: etcd3 short_description: Get key values from etcd3 server description: - Retrieves key values and/or key prefixes from etcd3 server using its native gRPC API. - Try to reuse M(community.general.etcd3) options for connection parameters, but add support for some E(ETCDCTL_*) environment variables. - See U(https://github.com/etcd-io/etcd/tree/master/Documentation/op-guide) for etcd overview. options: _terms: description: - The list of keys (or key prefixes) to look up on the etcd3 server. type: list elements: str required: true prefix: description: - Look for key or prefix key. type: bool default: false endpoints: description: - Counterpart of E(ETCDCTL_ENDPOINTS) environment variable. Specify the etcd3 connection with an URL form, for example V(https://hostname:2379), or V(:) form. - The V(host) part is overwritten by O(host) option, if defined. - The V(port) part is overwritten by O(port) option, if defined. env: - name: ETCDCTL_ENDPOINTS default: '127.0.0.1:2379' type: str host: description: - Etcd3 listening client host. - Takes precedence over O(endpoints). type: str port: description: - Etcd3 listening client port. - Takes precedence over O(endpoints). type: int ca_cert: description: - Etcd3 CA authority. env: - name: ETCDCTL_CACERT type: str cert_cert: description: - Etcd3 client certificate. env: - name: ETCDCTL_CERT type: str cert_key: description: - Etcd3 client private key. env: - name: ETCDCTL_KEY type: str timeout: description: - Client timeout. default: 60 env: - name: ETCDCTL_DIAL_TIMEOUT type: int user: description: - Authenticated user name. env: - name: ETCDCTL_USER type: str password: description: - Authenticated user password. env: - name: ETCDCTL_PASSWORD type: str notes: - O(host) and O(port) options take precedence over (endpoints) option. - The recommended way to connect to etcd3 server is using E(ETCDCTL_ENDPOINT) environment variable and keep O(endpoints), O(host), and O(port) unused. seealso: - module: community.general.etcd3 - plugin: community.general.etcd plugin_type: lookup requirements: - "etcd3 >= 0.10" a - name: "a value from a locally running etcd" ansible.builtin.debug: msg: "{{ lookup('community.general.etcd3', 'foo/bar') }}" - name: "values from multiple folders on a locally running etcd" ansible.builtin.debug: msg: "{{ lookup('community.general.etcd3', 'foo', 'bar', 'baz') }}" - name: "look for a key prefix" ansible.builtin.debug: msg: "{{ lookup('community.general.etcd3', '/foo/bar', prefix=True) }}" - name: "connect to etcd3 with a client certificate" ansible.builtin.debug: msg: "{{ lookup('community.general.etcd3', 'foo/bar', cert_cert='/etc/ssl/etcd/client.pem', cert_key='/etc/ssl/etcd/client.key') }}" z _raw: description: - List of keys and associated values. type: list elements: dict contains: key: description: The element's key. type: str value: description: The element's value. type: str N)AnsibleLookupError)missing_required_lib) to_native) LookupBase)DisplayTF)hostportca_certcert_key cert_certtimeoutuserpasswordc tjdi|}|j|S#t$r}t d|d}~wwxYw)Nz Cannot connect to etcd cluster: )etcd3clientstatus Exceptionr) client_paramsetcdexps j/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/general/plugins/lookup/etcd3.py etcd3_clientrsPK||,m,  K K #CC5!IJJKs%) AAAceZdZdZy) LookupModulec j|j||tstjt dyi}t j dj|jd}|rJ|jdr|jd|d<|jdr|jd|d<tD](}|j|s|j|||<*t|}d|vrd|d<tjd |t|}g} |D]} |jd rQ |j| D];\} } | s | s | jt!| j"t!| d =e |j)| \} } | r2| r0| jt!| j"t!| d | S#t$$r"} tj'd | Yd} ~ d} ~ wwxYw#t$$r#} tj'd | Yd} ~ d} ~ wwxYw)N) var_optionsdirectrza^(https?://)?(?P(\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})|([-_\d\w\.]+))(:(?P\d{1,5}))?/?$ endpointsr r rz zetcd3 connection parameters: prefix)keyvaluez'Caught except during etcd3.get_prefix: z Caught except during etcd3.get: ) set_optionsHAS_ETCDdisplayerrorrrecompilematch get_optiongroupetcd3_cnx_optsdictverboser get_prefixappendrr%rwarningget)selfterms variableskwargsrr-optcnx_logrrettermvalmetars rrunzLookupModule.runs Yv> MM.w7 8  p % , -  {{6"(- F(; f%{{6"(- F(; f%! :Cs#%)__S%9 c" :}%  ".GJ 7yABM* NDx(U%)__T%:^ T4JJy/BYWZ^'\]^ N $ICt 9TXX+>SV#XY N !UOO&McU$STTU!NOO&Fse$LMMNs=;GG2G AH H!G>>H H2H--H2N)__name__ __module__ __qualname__rArrrrs4rEr) __future__rrrtype __metaclass__ DOCUMENTATIONEXAMPLESRETURNr+ansible.errorsransible.module_utils.basicr+ansible.module_utils.common.text.convertersransible.plugins.lookupr ansible.utils.displayr rr( ImportErrorr)r0rrrrErrRsA@ \ | $  -;A-)H ) 6:67HsAAA