Vh&ddlmZmZmZeZdZdZddlZddl Z ddl Z ddl Z ddl m Z dZdZ ddlZddlmcmZddlmZmZdd lmZd Zed k(reyy#e$re j*ZdZY9wxYw) )absolute_importdivisionprint_functiona module: mqtt short_description: Publish a message on an MQTT topic for the IoT description: - Publish a message on an MQTT topic. extends_documentation_fragment: - community.general.attributes attributes: check_mode: support: full diff_mode: support: none options: server: type: str description: - MQTT broker address/name. default: localhost port: type: int description: - MQTT broker port number. default: 1883 username: type: str description: - Username to authenticate against the broker. password: type: str description: - Password for O(username) to authenticate against the broker. client_id: type: str description: - MQTT client identifier. - If not specified, a value C(hostname + pid) will be used. topic: type: str description: - MQTT topic name. required: true payload: type: str description: - Payload. The special string V("None") may be used to send a NULL (that is, empty) payload which is useful to simply notify with the O(topic) or to clear previously retained messages. required: true qos: type: str description: - QoS (Quality of Service). default: "0" choices: ["0", "1", "2"] retain: description: - Setting this flag causes the broker to retain (in other words keep) the message so that applications that subsequently subscribe to the topic can received the last retained message immediately. type: bool default: false ca_cert: type: path description: - The path to the Certificate Authority certificate files that are to be treated as trusted by this client. If this is the only option given then the client will operate in a similar manner to a web browser. That is to say it will require the broker to have a certificate signed by the Certificate Authorities in ca_certs and will communicate using TLS v1, but will not attempt any form of authentication. This provides basic network encryption but may not be sufficient depending on how the broker is configured. aliases: [ca_certs] client_cert: type: path description: - The path pointing to the PEM encoded client certificate. If this is not None it will be used as client information for TLS based authentication. Support for this feature is broker dependent. aliases: [certfile] client_key: type: path description: - The path pointing to the PEM encoded client private key. If this is not None it will be used as client information for TLS based authentication. Support for this feature is broker dependent. aliases: [keyfile] tls_version: description: - Specifies the version of the SSL/TLS protocol to be used. - By default (if the python version supports it) the highest TLS version is detected. If unavailable, TLS v1 is used. type: str choices: - tlsv1.1 - tlsv1.2 requirements: [mosquitto] notes: - This module requires a connection to an MQTT broker such as Mosquitto U(http://mosquitto.org) and the I(Paho) C(mqtt) Python client (U(https://pypi.org/project/paho-mqtt/)). author: "Jan-Piet Mens (@jpmens)" z - name: Publish a message on an MQTT topic community.general.mqtt: topic: 'service/ansible/{{ ansible_hostname }}' payload: 'Hello at {{ ansible_date_time.iso8601 }}' qos: 0 retain: false client_id: ans001 delegate_to: localhost N) LooseVersionTF) AnsibleModulemissing_required_lib) to_nativecti} tj|d< tj|d<t t t dt ddt d t d t dt d gd  t d dt dt ddt dddgt dddgt dddgt dddg  d}t s |jtdt|jjdd}|jjdd}|jjd}|jjd}|jjdd}t|jjdd }|jjd!}|jjd"d} |jjd#d} |jjd$d} |jjd%d} |jjd&d} |jjd'd}|+tjd(tj }|r|d)k(rd}d}| | | d*}d}| c|r!|j|tj"}n9t%t'j(t%d+krtj"}| | | |d,} t+j,|||||||||- |j7d |/y#t$rYHwxYw#t$rYDwxYw#t.$r;}|jd.t1|zt3j4Yd}~sd}~wwxYw)0Nztlsv1.2ztlsv1.1 localhost)defaulti[int)r typeT)required0)r12)r choicesFbool)r no_logpathca_certs)r raliasescertfilekeyfile) serverporttopicpayload client_idqosretainusernamepasswordca_cert client_cert client_key tls_version) argument_specsupports_check_modez paho-mqtt)msg exceptionrrrrrr rr!r"r#r$r%r&r'_None)r"r#z3.5.2)rrrr')r r!rhostnamerauthtlsz#unable to publish to MQTT broker %s)changedr)sslPROTOCOL_TLSv1_2AttributeErrorPROTOCOL_TLSv1_1rdict HAS_PAHOMQTT fail_jsonrPAHOMQTT_IMP_ERRparamsgetr socketgetfqdnosgetpidPROTOCOL_SSLv23rplatformpython_versionmqttsingle Exceptionr traceback format_exc exit_json)tls_mapmodulerrrrrr r!r"r#rrrr'r0r1es j/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/general/plugins/modules/mqtt.pymainrNs\G  11   11  ,d/%$'4(S/:F3$'$t4FZLIT MDv {KTIy3IJ !!F& 1+>JZ[ ]]  x 5F ==  VT *D MM  g &Emm *G !!+r2I fmmq) *C ]]  x (F}}  T2H}}  T2H}}  D1H}}  5Hmm d3G--##M48K%~~/= 7f$ D$(; C !++k33F3FGKH3356,w:OO"11 ! &      " U%0{       d  5 ! D**,    s:MM#!M3 M M # M0/M03 N7<1N22N7__main__) __future__rrrr __metaclass__ DOCUMENTATIONEXAMPLESr?r3rGrBBansible_collections.community.general.plugins.module_utils.versionrr8r:r=paho.mqtt.publishrDpublish ImportErrorrHansible.module_utils.basicrr+ansible.module_utils.common.text.convertersr rN__name__rMr]sA@ ] ~  [ $$ KAb1J zFc+y++-Ls AA32A3