zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 完善mqtt获取数据

This commit is contained in:
caoqianming 2024-04-02 10:19:17 +08:00
parent a104191341
commit 567c40e962
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/mqtt/client.py
View File

@ -6,6 +6,7 @@ import logging
import json import json
from django.conf import settings from django.conf import settings
import traceback import traceback
from apps.enm.services import insert_mplogx_from_king_realdata
BASE_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) BASE_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
sys.path.insert(0, BASE_DIR) sys.path.insert(0, BASE_DIR)
@ -25,12 +26,10 @@ def on_connect(mqttc, userdata, flags, rc, properties):
_logger.error('Mqtt Bad connection. Code:', rc) _logger.error('Mqtt Bad connection. Code:', rc)
def on_message(mqttc: mqtt, userdata, msg): def on_message(mqttc: mqtt, userdata, msg):
print(f'Received message on topic: {msg.topic} with payload: {msg.payload}')
topic = msg.topic topic = msg.topic
payload = json.loads(msg.payload)
if topic == 'datachange_S_KIO_Project': if topic == 'datachange_S_KIO_Project':
print(payload) payload = json.loads(msg.payload)
mqttc.publish('testtopic', 'ok') insert_mplogx_from_king_realdata(payload, settings.KING_MQTT_OFFSET)
def start_mqtt(): def start_mqtt():
if settings.MQTT_ENABLED: if settings.MQTT_ENABLED: