fix: mqtt 包引入调整

This commit is contained in:
caoqianming 2024-04-11 21:31:49 +08:00
parent 3e75683ee1
commit 2ea048cc53
1 changed files with 3 additions and 1 deletions

View File

@ -6,7 +6,7 @@ import logging
import json
from django.conf import settings
import traceback
from apps.enm.services import insert_mplogx_from_king_mqtt
BASE_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
sys.path.insert(0, BASE_DIR)
@ -14,6 +14,8 @@ sys.path.insert(0, BASE_DIR)
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'server.settings')
django.setup()
from apps.enm.services import insert_mplogx_from_king_mqtt
_logger = logging.getLogger('log')
def on_connect(mqttc, userdata, flags, rc, properties):