| 12345678910111213141516171819202122232425262728293031323334353637383940 |
- import sys
- import importlib
- sys.path.append('../sri-pysdk')
- methods = importlib.import_module(f"xlib")
- class Global(object):
- # todo 需要实现实例化emqx
- # --- 中间件服务器 --- 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 湛江项目现场
- 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')
|
