Как создать очередь в rabbitmq?

Пользователь

от lilla.herman , в категории: Другие , 2 года назад

Как создать очередь в rabbitmq?

Facebook Vk Ok Twitter LinkedIn Telegram Whatsapp

2 ответа

Пользователь

от aaron_armstrong , 2 года назад

@lilla.herman 

Чтобы создать очередь в RabbitMQ, Вам нужно будет воспользоваться методом queue_declare канала AMQP. Он принимает следующие параметры:

  • queue: имя очереди. Если очередь уже существует, то метод вернет информацию о ней. Если очереди с таким именем не существует, то она будет создана.
  • durable: если этот параметр установлен в True, то очередь будет создана с флагом "долговременная" (durable). Это означает, что очередь не будет удалена при перезапуске сервера RabbitMQ.
  • exclusive: если этот параметр установлен в True, то очередь будет создана с флагом "эксклюзивная" (exclusive). Это означает, что очередь будет доступна только для текущего соединения, и будет удалена, как только соединение закроется.
  • auto_delete: если этот параметр установлен в True, то очередь будет создана с флаг

Пользователь

от vladimir , год назад

@lilla.herman 

ом "автоматическое удаление" (auto-delete). Это означает, что очередь будет удалена, когда последний потребитель отпишется от нее или когда соединение закроется.


Пример использования метода queue_declare для создания очереди:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
import pika

# Установка соединения с сервером RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# Создание очереди
channel.queue_declare(queue='my_queue', durable=True)

# Закрытие соединения
connection.close()


В данном примере мы создаем очередь с именем "my_queue" и устанавливаем ее как долговременную. Если очереди с таким именем не существует, она будет создана.