Vh-ddlmZmZmZeZdZdZddlm Z  ddl Z ddl m Z dZ dd lmZdZd Zd Zd Zd ZdZdZdZdZdZedk(reyy#e$rdZ Y:wxYw))absolute_importdivisionprint_functiona module: consul_kv short_description: Manipulate entries in the key/value store of a Consul cluster description: - Allows the retrieval, addition, modification and deletion of key/value entries in a Consul cluster using the agent. The entire contents of the record, including the indices, flags and session are returned as C(value). - If the O(key) represents a prefix then note that when a value is removed, the existing value if any is returned as part of the results. - See http://www.consul.io/docs/agent/http.html#kv for more details. requirements: - python-consul - requests author: - Steve Gargan (@sgargan) - Colin Nolan (@colin-nolan) extends_documentation_fragment: - community.general.attributes attributes: check_mode: support: full diff_mode: support: none options: state: description: - The action to take with the supplied key and value. If the state is V(present) and O(value) is set, the key contents will be set to the value supplied and C(changed) will be set to V(true) only if the value was different to the current contents. If the state is V(present) and O(value) is not set, the existing value associated to the key will be returned. The state V(absent) will remove the key/value pair, again C(changed) will be set to V(true) only if the key actually existed prior to the removal. An attempt can be made to obtain or free the lock associated with a key/value pair with the states V(acquire) or V(release) respectively. A valid session must be supplied to make the attempt C(changed) will be V(true) if the attempt is successful, V(false) otherwise. type: str choices: [absent, acquire, present, release] default: present key: description: - The key at which the value should be stored. type: str required: true value: description: - The value should be associated with the given key, required if O(state) is V(present). type: str recurse: description: - If the key represents a prefix, each entry with the prefix can be retrieved by setting this to V(true). type: bool retrieve: description: - If the O(state) is V(present) and O(value) is set, perform a read after setting the value and return this value. default: true type: bool session: description: - The session that should be used to acquire or release a lock associated with a key/value pair. type: str token: description: - The token key identifying an ACL rule set that controls access to the key value pair. type: str cas: description: - Used when acquiring a lock with a session. If the O(cas) is V(0), then Consul will only put the key if it does not already exist. If the O(cas) value is non-zero, then the key is only set if the index matches the ModifyIndex of that key. type: str flags: description: - Opaque positive integer value that can be passed when setting a value. type: str host: description: - Host of the Consul agent. type: str default: localhost port: description: - The port on which the Consul agent is running. type: int default: 8500 scheme: description: - The protocol scheme on which the Consul agent is running. type: str default: http validate_certs: description: - Whether to verify the tls certificate of the Consul agent. type: bool default: true datacenter: description: - The name of the datacenter to query. If unspecified, the query will default to the datacenter of the Consul agent on O(host). type: str version_added: 10.0.0 a # If the key does not exist, the value associated to the "data" property in `retrieved_key` will be `None` # If the key value is empty string, `retrieved_key["data"]["Value"]` will be `None` - name: Retrieve a value from the key/value store community.general.consul_kv: key: somekey register: retrieved_key - name: Add or update the value associated with a key in the key/value store community.general.consul_kv: key: somekey value: somevalue - name: Remove a key from the store community.general.consul_kv: key: somekey state: absent - name: Add a node to an arbitrary group using Consul inventory (see consul.ini) community.general.consul_kv: key: ansible/groups/dc1/somenode value: top_secret - name: Register a key/value pair with an associated session community.general.consul_kv: key: stg/node/server_birthday value: 20160509 session: "{{ sessionid }}" state: acquire )to_textN)ConnectionErrorTF) AnsibleModulec|jj|\}}|s|dfS t|dd|k7}||fS#t$r|dfcYSwxYw)a Uses the given Consul client to determine if the value associated to the given key is different to the given target value. :param consul_client: Consul connected client :param key: key in Consul :param target_value: value to be associated to the key :return: tuple where the first element is the value of the "X-Consul-Index" header and the second is `True` if the value has changed (i.e. the stored value is not the target value) TValuesurrogate_or_strict)errors)kvgetr UnicodeError) consul_clientkey target_valueindexexistingchangeds o/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/general/plugins/modules/consul_kv.py_has_value_changedrsj$&&**3/OE8 d{(7+4IJlZg~ d{s= A  A c0|jjd}|dk(s|dk(r t||y|dk(r9|jjdtur t |yt |y|dk(r t |y|jd|y) NstateacquirereleasepresentvalueabsentzUnsupported state: msg)paramsrlockNOT_SET get_value set_value remove_value exit_json)modulers rexecuter)s MM  g &E Ui/ VU )  ==  W % 0 f  f  ( V@Ac t|}|jjd}|jjd}|jjd}|s|j|d|dt |||\}}|r|j s|dk(rS|j j|||jjd||jjd  }nR|j j|||jjd||jjd  }|j||| y) Nsessionrrz of lock for z" requested but no session suppliedrrcasflags)r-rr.)r-rr.)rrr) get_consul_apir!rfailr check_moder putr')r(r consul_apir,rrrrs rr"r"s6'Jmm *G --  E "C MM  g &E  C  ( C?NE7v(( I  mm''U,2MM,=,=e,D07.4mm.?.?.H(JG !mm''U,2MM,=,=e,D07.4mm.?.?.H(JG  W r*ct|}|jjd}|jj||jjd\}}|j d||y)Nrrecurser5F)rrdata)r/r!rr r')r(r3rrexisting_values rr$r$sb'J --  E "C&MM--c6==;L;LY;W-XE> U%nEr*c0t|}|jjd}|jjd}|turt d|zt |||\}}|r]|j sQ|jj|||jjd|jjd}d}|jjdr|jj|\}}|j||||y) Nrrz%Cannot set value of "%s" to `NOT_SET`r-r.)r-r.retrieverrrr7) r/r!rr#AssertionErrorrr1r r2r')r(r3rrrrstoreds rr%r%s'J --  E "C MM  g &E DsJKK' C?NE7v((--##C(. (9(9%(@*0--*;*;G*D$FF }}$" ))#. v W  "r*czt|}|jjd}|jj||jjd\}}|du}|rA|js5|jj ||jjd|j ||||y)z remove the value associated with the given key. if the recurse parameter is set then any key prefixed with the given key will be removed. rr5r6Nr;)r/r!rr r1deleter')r(r3rrrrs rr&r& s 'J --  E "C mm'' V]]&&y1(3OE8d"Gv(( S&--"3"3I">? W "$r*c dtj|jjd|jjd|jjd|jjd|jjd|jjdS)Nhostportschemevalidate_certstoken datacenter)rArBrCverifyrEdc)consulConsulr!rr(s rr/r/s ==fmm//7$mm//7 & 1 1( ; & 1 12B C%}}009"MM--l;  ==r*c6ts|jdyy)Nzhpython-consul required for this module. see https://python-consul.readthedocs.io/en/latest/#installationr)python_consul_installed fail_jsonrKs rtest_dependenciesrO&s" "` a #r*ctttdtddtdtdddtddtddtd dtd d td td dtdd gd tddtdttdd}t| t |y#t $rW}|j d|jjdd|jjdd|Yd}~yd}~wt$r%}|j t|Yd}~yd}~wwxYw)Nstr)type)rRdefaultTF)rRrequiredno_log localhosthttpboolinti4!r)rrrr)rRrSchoices)rRrU)r-rFr.rrArCrDrBr5r:rrErr,) argument_specsupports_check_modez%Could not connect to consul agent at rA:rBz , error was r) rdictr#rOr)rrNr!r ExceptionrQ)r(es rmainra,s- % 5E"%$u=5+6UF3VT:5$/f%vt4E9>ijE$/E73e$ !#F(f% F MM  f %v}}'8'8'@!E F F %SV$$%s% C E'$A D66 E'E""E'__main__) __future__rrrrR __metaclass__ DOCUMENTATIONEXAMPLES+ansible.module_utils.common.text.convertersrrIrequests.exceptionsrrM ImportErroransible.module_utils.basicrr#rr)r"r$r%r&r/rOra__name__r*rrmsA@ a H >@$3"5 * B @F"4$(=a %B zFo$#$s AAA