Как мы можем слушать непрерывно без запуска отдельного файла для RabbitMQ

В микросервисе python Django мы используем rabbitMQ для внутренней связи, теперь мне нужно запустить два терминала для одного сервиса

  1. run manage.py
  2. run receive.py for consuming

Как мы можем объединить это вместе для прослушивания и запуска проекта.

я следую этому документу https://www.rabbitmq.com/tutorials/tutorial-one-python.html

вы можете попробовать запустить в потребителе как фоновый поток.

вместо запуска инструкции потребителя, которая останавливает выполнение и ожидает получения нового сообщения

channel.start_consuming()

вы можете создать новый поток и связать с ним эту функцию.

import threading

#channel.start_consuming()


thread = threading.Thread(name='t', target=channel.start_consuming, args=())
thread.setDaemon(True)
thread.start()

и далее следуйте инструкциям гордепа.

Вернуться на верх