Server-py/sri-server-bg02/lib/MessageListenerC001.py

from hub import methods, Global

import threading
import time
import json
import os

# --- for linux
# save_dir = f"/home/server/logs"

# --- for windows
# save_dir = r'C:\SRI-DINO.Server-py\logs'  # sri内网测试环境
save_dir = r'C:\logs'  # sri内网测试环境


def method_c001(client, userdata, message):
    """消息处理方法"""
    # --- log ---
    methods.debug_log(f"MessageListenerC001|19", f"#message.payload: {message.payload}")


def subscribe_c001(cls):
    """"""
    Global.emqx.start_subscribe_loop(
        decorate_method=method_c001,
        subscribe_topic='Cockpit/CanBus/CanId001/Cop001'
    )