|
@@ -47,12 +47,11 @@ def update_device_shadow(request):
|
|
|
|
|
|
logger = logging.getLogger('info')
|
|
|
logger.info('---更新设备影子---, 使用配置:{}, 参数:{}'.format(SERVER_TYPE, request_dict.dict()))
|
|
|
- if SERVER_TYPE == 'Ansjer.formal_settings': # 如果不为美国配置,异步请求更新国内和欧洲数据
|
|
|
- domain_name_list = ['push.zositechc.cn'] # 后面加上欧洲域名
|
|
|
- for domain_name in domain_name_list:
|
|
|
- url = 'http://{}/deviceShadow/update'.format(domain_name)
|
|
|
- request_thread = threading.Thread(target=do_request_thread, args=(url, request_dict.dict()))
|
|
|
- request_thread.start()
|
|
|
+ # 如果为美国配置,异步请求更新国内和欧洲数据
|
|
|
+ if SERVER_TYPE == 'Ansjer.formal_settings':
|
|
|
+ domain_name_list = ['push.zositechc.cn', 'push.zositeche.com']
|
|
|
+ request_thread = threading.Thread(target=do_request_thread, args=(domain_name_list, request_dict.dict()))
|
|
|
+ request_thread.start()
|
|
|
|
|
|
try:
|
|
|
etk = request_dict.get('etk', None)
|
|
@@ -182,5 +181,7 @@ def update_device_shadow(request):
|
|
|
return JsonResponse(status=200, data={'code': 0, 'update_shadow_error': repr(e)})
|
|
|
|
|
|
|
|
|
-def do_request_thread(url, data):
|
|
|
- requests.post(url=url, data=data, timeout=2)
|
|
|
+def do_request_thread(domain_name_list, data):
|
|
|
+ for domain_name in domain_name_list:
|
|
|
+ url = 'http://{}/deviceShadow/update'.format(domain_name)
|
|
|
+ requests.post(url=url, data=data, timeout=2)
|