VhddlmZmZmZeZdZdZdZddl Z ddl m Z ddl m Z ddlmZmZdd lmZ ddlZd ZeZGd d e Zy#e$rd ZYwxYw))absolute_importdivisionprint_functiona name: rabbitmq author: John Imison (@Im0) short_description: Retrieve messages from an AMQP/AMQPS RabbitMQ queue. description: - This lookup uses a basic get to retrieve all, or a limited number C(count), messages from a RabbitMQ queue. options: url: description: - An URI connection string to connect to the AMQP/AMQPS RabbitMQ server. - For more information refer to the URI spec U(https://www.rabbitmq.com/uri-spec.html). required: True queue: description: - The queue to get messages from. required: True count: description: - How many messages to collect from the queue. - If not set, defaults to retrieving all the messages from the queue. requirements: - The python pika package U(https://pypi.org/project/pika/). notes: - This lookup implements BlockingChannel.basic_get to get messages from a RabbitMQ server. - After retrieving a message from the server, receipt of the message is acknowledged and the message on the server is deleted. - Pika is a pure-Python implementation of the AMQP 0-9-1 protocol that tries to stay fairly independent of the underlying network support library. - More information about pika can be found at U(https://pika.readthedocs.io/en/stable/). - This plugin is tested against RabbitMQ. Other AMQP 0.9.1 protocol based servers may work but not tested/guaranteed. - Assigning the return messages to a variable under C(vars) may result in unexpected results as the lookup is evaluated every time the variable is referenced. - Currently this plugin only handles text based messages from a queue. Unexpected results may occur when retrieving binary data. aO - name: Get all messages off a queue debug: msg: "{{ lookup('community.rabbitmq.rabbitmq', url='amqp://guest:guest@192.168.0.10:5672/%2F', queue='hello') }}" # If you are intending on using the returned messages as a variable in more than # one task (eg. debug, template), it is recommended to set_fact. - name: Get 2 messages off a queue and set a fact for re-use set_fact: messages: "{{ lookup('community.rabbitmq.rabbiotmq', url='amqp://guest:guest@192.168.0.10:5672/%2F', queue='hello', count=2) }}" - name: Dump out contents of the messages debug: var: messages a _list: description: - A list of dictionaries with keys and value from the queue. type: list contains: content_type: description: The content_type on the message in the queue. type: str delivery_mode: description: The delivery_mode on the message in the queue. type: str delivery_tag: description: The delivery_tag on the message in the queue. type: str exchange: description: The exchange the message came from. type: str message_count: description: The message_count for the message on the queue. type: str msg: description: The content of the message. type: str redelivered: description: The redelivered flag. True if the message has been delivered before. type: bool routing_key: description: The routing_key on the message in the queue. type: str headers: description: The headers for the message returned from the queue. type: dict json: description: If application/json is specified in content_type, json will be loaded into variables. type: dict N) AnsibleError) LookupBase) to_nativeto_text)DisplayTFceZdZddZy) LookupModuleNc *ts td|s td|s tdtjd|d|d|d|d|  t j |} t j|} |j} g} d } | j|\} }}| rtj| d|dt|dt!t|| j"| j$| j&| j(| j*|j,|j.|j0d }|j.dk(r t3j4|d|d<| j9|| j;| j&| dz } | j"d k(s| |k(rnn"|j<r| gS |j| gS#t $r}td t|zd}~wwxYw#t $r}td t|zd}~wwxYw#tjj$rt} |jnF#tjj$r&} td t|zt| d} ~ wwxYwtd t|zd}~wwxYw#t6$r)}td| j&dt|d}~wwxYw#tjj$rY| gSwxYw)Nz4pika python package is required for rabbitmq lookup.z$URL is required for rabbitmq lookup.z&Queue is required for rabbitmq lookup.zterms:z : variables:z url:z queue:z count:zURL malformed: %szConnection issue: %sz.Channel and connection closing issues: %s / %szChannel issue: %sr)queuez,  ) msg message_count routing_key delivery_tag redeliveredexchange delivery_mode content_typeheaderszapplication/jsonrjsonz"Unable to decode JSON for message z: )HAS_PIKArdisplayvvvpika URLParameters ExceptionrBlockingConnectionchannel exceptionsAMQPChannelErrorcloseAMQPConnectionError basic_getr dictrrrrrrrrrloads ValueErrorappend basic_ack is_closed)selfterms variablesurlrcount parameterse connection conn_channelieretidx method_frame propertiesbody msg_detailss n/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/rabbitmq/plugins/lookup/rabbitmq.pyrunzLookupModule.runus UV VEF FGH H 5R[]`bginop C++C0J F002J2J3?3L3L2>2J2J/;/D/D4>4L4L3=3J3J.8.@.@ $% & **.@@C.2jjU9K.L F+ ;'&&|'@'@Aq--2cUl=@   5L   "5Lw C2Yq\AB B C  F5 ! DE E F // C s  "??66 s"#SV_`aVb#bdmnpdqrr s2Yq\AB B  C<&C*YeYrYrt}~uA,BCCC"??66 5L sG'G?=H'J;K0 G< G77G<? H$HH$'J8IJ3J3!JJJ33J8; K-$K((K-0LL)NNNN)__name__ __module__ __qualname__r?r>r r ssGrDr ) __future__rrrtype __metaclass__ DOCUMENTATIONEXAMPLESRETURNransible.errorsransible.plugins.lookupransible.module_utils._textrr ansible.utils.displayr rr ImportErrorrr rCrDr>rPsuCB  D &% N '-9)H )I:I HsA AA