rabbitmq_publish – Опубликовать сообщение в очередь RabbitMQ
Новое в версии 2.8.
Описание
- Опубликовать сообщение в очередь RabbitMQ с использованием блокирующего соединения.
Требования
Ниже перечислены требования, необходимые на хосте, на котором выполняется этот модуль.
- pika
Параметры
| Параметр | Варианты/Значения по умолчанию | Комментарии |
|---|---|---|
| auto_delete boolean |
| Установить очередь для автоматического удаления. |
| body - | Тело сообщения. Значение body не может быть предоставлено, если указано src. | |
| content_type - | По умолчанию: "text/plain" | Тип содержимого тела. |
| durable boolean |
| Установить очередь как долговременную. |
| exchange - | Обмен для публикации сообщения. | |
| exclusive boolean |
| Установить очередь как эксклюзивную. |
| headers dictionary | По умолчанию: {} | Словарь заголовков для отправки вместе с сообщением. |
| host - | Имя хоста или IP-адрес сервера RabbitMQ. | |
| password - | Пароль RabbitMQ. | |
| port - | Порт сервера RabbitMQ. | |
| proto - |
| Протокол для использования. |
| queue - | Очередь для публикации сообщения. Если очередь не указана, RabbitMQ вернёт случайное имя очереди. | |
| routing_key - | Ключ маршрутизации. | |
| src - | Файл для загрузки в очередь. Автоматическое определение типа MIME выполняется, если content_type не определён (оставлен по умолчанию). Значение src не может быть предоставлено, если указано body. Имя файла добавляется в заголовки отправленного сообщения в RabbitMQ. Ключ - filename, значение - имя файла.псевдонимы: файл | |
| url - | Строка подключения URL для подключения к серверу RabbitMQ.
url и host/port/user/pass/vhost взаимно исключают друг друга. Используйте либо одно, либо другое, но не оба. | |
| username - | Имя пользователя RabbitMQ. | |
| vhost - | Виртуальный хост для назначения. Если нужен виртуальный хост по умолчанию, используйте '%2F'. |
Примечания
Примечание
- Этот модуль требует библиотеки pika python https://pika.readthedocs.io/.
- Pika — это чисто Python-реализация протокола AMQP 0-9-1, которая старается оставаться достаточно независимой от базовой библиотеки поддержки сети.
- Этот плагин протестирован на RabbitMQ. Другие серверы, основанные на протоколе AMQP 0.9.1, могут работать, но не протестированы/не гарантируются.
Примеры
- name: Publish a message to a queue with headers
rabbitmq_publish:
url: "amqp://guest:guest@192.168.0.32:5672/%2F"
queue: 'test'
body: "Hello world from ansible module rabbitmq_publish"
content_type: "text/plain"
headers:
myHeader: myHeaderValue
- name: Publish a file to a queue
rabbitmq_publish:
url: "amqp://guest:guest@192.168.0.32:5672/%2F"
queue: 'images'
file: 'path/to/logo.gif'
- name: RabbitMQ auto generated queue
rabbitmq_publish:
url: "amqp://guest:guest@192.168.0.32:5672/%2F"
body: "Hello world random queue from ansible module rabbitmq_publish"
content_type: "text/plain"
Возвращаемые значения
Общие возвращаемые значения документированы здесь, следующие — это поля, уникальные для этого модуля:
| Ключ | Возвращённое значение | Описание |
|---|---|---|
| result dictionary | успех | Содержит статус msg, тип содержимого content_type и имя очереди queue. Пример: 'result': { 'content_type': 'text/plain', 'msg': 'Сообщение успешно опубликовано в очередь test', 'queue': 'test' } |
Статус
- Гарантия обратной совместимости интерфейса этого модуля не предоставляется. [предварительный просмотр]
- Этот модуль поддерживается сообществом Ansible здесь. [сообщество]
Авторы
- John Imison (@Im0)
Подсказка
Если вы обнаружите проблемы в этой документации, вы можете отредактировать этот документ, чтобы улучшить его.
© 2012–2018 Michael DeHaan
© 2018–2019 Red Hat, Inc.
Licensed under the GNU General Public License version 3.
https://docs.ansible.com/ansible/2.8/modules/rabbitmq_publish_module.html
