import threading import traceback # 系统配置 g_sys_conf_mtx = threading.Lock() g_sys_conf = {} # platform: 0-本地,1-云服务器 # 43.137.10.199 sys_conf_pro = { "module_name" : "LAS", "host_ip" : "localhost", "platform" : 0, "sp_id" : "LAS_123456789", "service": { "ip" : "43.137.10.199", "username" : "root", "password" : "Hfln@147888" }, "db": { "host" : "43.137.10.199", "username" : "root", "password" : "Hfln@147888", "database" : "lnxx_dev" }, "mqtt": { "broker" : "43.137.10.199", "port" : 1883, "username" : "lnradar", "password" : "lnradar" } } # 119.45.12.173 sys_conf_test = { "module_name" : "LAS", "host_ip" : "localhost", "platform" : 0, "sp_id" : "LAS_123456789", "service": { "ip" : "119.45.12.173", "username" : "root", "password" : "Hfln@147888" }, "db": { "host" : "119.45.12.173", "username" : "root", "password" : "Hfln@147888", "database" : "jkld" }, "mqtt": { "broker" : "119.45.12.173", "port" : 1883, "username" : "lnradar", "password" : "lnradar" } } # 8.130.28.21 sys_conf_dev = { "module_name" : "LAS", "host_ip" : "localhost", "platform" : 0, "sp_id" : "LAS_123456789", "service": { "ip" : "8.130.28.21", "username" : "root", "password" : "Hfln@667788" }, "db": { "host" : "8.130.28.21", "username" : "root", "password" : "Hfln@1024", "database" : "lnxx_dev" }, "mqtt": { "broker" : "8.130.28.21", "port" : 1883, "username" : "lnradar", "password" : "lnradar" } } def init_g_sys_conf(server_ip, module_name, sp_id): global g_sys_conf conf_map = { "43.137.10.199" : sys_conf_pro, "119.45.12.173" : sys_conf_test, "8.130.28.21" : sys_conf_dev, } try: if not server_ip in conf_map: return -1 with g_sys_conf_mtx: g_sys_conf.clear() g_sys_conf.update(conf_map.get(server_ip)) g_sys_conf["sp_id"] = sp_id g_sys_conf["module_name"] = module_name return 0 except Exception as e: tb_info = traceback.extract_tb(e.__traceback__) for frame in tb_info: print(f"[{frame.filename}:{frame.lineno}] @{frame.name}(), error: {e}") return -1