Server-py/sri-server-bg02/hub.py

import sys
import importlib

sys.path.append('../sri-pysdk')

methods = importlib.import_module(f"xlib")


class Global(object):
    """
    """

    save_dir = r'C:\logs'  # sri内网测试环境
    # save_dir = r'E:\logs'  # 湛江现场环境（容量为512G）

    # --- 中间件服务器 --- for test
    emqx_MessageListenerC001 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)
    emqx_MessageListenerV001 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)

    # --- 中间件服务器 --- for 湛江项目现场 todo 需要实现实例化emqx | 只能是哪里用到哪里实例化
    emqx_Veh0533 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)
    emqx_Veh0534 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)
    emqx_Veh0535 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)
    emqx_Veh0537 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)
    emqx_Veh0538 = importlib.import_module(f"xclient.xmqtt").Client(host='127.0.0.1', port=41883)

    aps = importlib.import_module(f"xpip.xapscheduler").APS(db_type='mongo',
                                                            db_host='127.0.0.1',
                                                            db_port=47017,
                                                            username='admin', password='admin',
                                                            database='bg', collection='LoopTask')

    # --- 业务数据数据库 ---
    mdb = importlib.import_module(f"xclient.xmongo").Client(host='127.0.0.1', port=47017, database='bg',
                                                            username='admin', password='admin')

    # emqx = importlib.import_module(f"xclient.xmqtt").Client(host='10.10.10.73', port=41883)

    # aps = importlib.import_module(f"xpip.xapscheduler").APS(db_type='mongo',
    #                                                         db_host='10.10.10.73',
    #                                                         db_port=47017,
    #                                                         username='admin', password='admin',
    #                                                         database='bg', collection='LoopTask')