如何在 docker 中重置rabbitmq 服务时自动使用

如何解决如何在 docker 中重置rabbitmq 服务时自动使用

有时会在我的 docker 服务中重置rabbitmq 服务

重置后，rabbitmq消费者变为零 我必须在终端中使用 docker-compose 像下面的代码一样运行 kill & up

docker-compose kill datacleanup
docker-compose up -d datacleanup

在我运行它之后，rabbitmq 消费者正在工作而不是零了

但每次发生时我都必须运行它

我想知道有没有办法通过rabbitmq服务本身自动做到这一点？

这是我的rabbitmq连接代码：

def start(self):
        try:
            credentials = pika.PlainCredentials(settings.RABBIT_USER,settings.RABBIT_USER)
            connection = pika.BlockingConnection(
                pika.ConnectionParameters(host=settings.SERVER_RABBITMQ_URL,credentials=credentials,heartbeat=600,blocked_connection_timeout=300))
            channel = connection.channel()
            channel.queue_declare(queue=os.environ.get('QUEUENAME'),durable=True)
            channel.basic_qos(prefetch_count=1)
            channel.basic_consume(queue=os.environ.get('QUEUENAME'),on_message_callback=self.callback)
            channel.start_consuming()
            connection.close()

        except Exception as e:
            print("consuming exception: {}".format(str(e)))