diff --git a/apps/msg/utils.py b/apps/msg/utils.py index e72c83f..2f83856 100644 --- a/apps/msg/utils.py +++ b/apps/msg/utils.py @@ -1,5 +1,6 @@ import json import logging +import os from redis import Redis from django.conf import settings @@ -22,7 +23,8 @@ class JQRMSGPubSubUtils: def listen(): - logger.info('监听消息队列-----') + api = os.environ.get('api') + logger.info(f'监听消息队列-----{api}') from apps.jqr.serializers import TbMessageModelSerializer while True: data = JQRMSGPubSubUtils.rc.brpop(Constant.JQR_MSG_PUBSUB_CHANNEL, 5) @@ -41,5 +43,6 @@ def listen(): JQRMSGPubSubUtils.msg_list.clear() -t = Thread(target=listen) -t.start() +if not settings.DEBUG: + t = Thread(target=listen) + t.start() diff --git a/docker-compose.yml b/docker-compose.yml index ee4769d..7fc8d57 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -7,6 +7,8 @@ services: context: . dockerfile: ./Dockerfile command: ./start + environment: + - api=true volumes: - .:/app ports: