fw
/
yzk_wechat_event
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

回调状态修改

This commit is contained in:
AKW 2023-12-22 14:23:40 +08:00
parent 3130d49276
commit 4e9a03eb21
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/msg/utils.py
View File

@ -1,5 +1,6 @@
import json import json
import logging import logging
import os
from redis import Redis from redis import Redis
from django.conf import settings from django.conf import settings
@ -22,7 +23,8 @@ class JQRMSGPubSubUtils:
def listen(): def listen():
logger.info('监听消息队列-----') api = os.environ.get('api')
logger.info(f'监听消息队列-----{api}')
from apps.jqr.serializers import TbMessageModelSerializer from apps.jqr.serializers import TbMessageModelSerializer
while True: while True:
data = JQRMSGPubSubUtils.rc.brpop(Constant.JQR_MSG_PUBSUB_CHANNEL, 5) data = JQRMSGPubSubUtils.rc.brpop(Constant.JQR_MSG_PUBSUB_CHANNEL, 5)
@ -41,5 +43,6 @@ def listen():
JQRMSGPubSubUtils.msg_list.clear() JQRMSGPubSubUtils.msg_list.clear()
t = Thread(target=listen) if not settings.DEBUG:
t.start() t = Thread(target=listen)
t.start()

2
docker-compose.yml
View File

@ -7,6 +7,8 @@ services:
context: . context: .
dockerfile: ./Dockerfile dockerfile: ./Dockerfile
command: ./start command: ./start
environment:
- api=true
volumes: volumes:
- .:/app - .:/app
ports: ports: