diff --git a/util/api.py b/util/api.py index c2773c3..1380c29 100644 --- a/util/api.py +++ b/util/api.py @@ -24,6 +24,7 @@ def sync_center(): 'accessKey': os.getenv('ACCESS_KEY'), 'clientStatus': util.system.get_sys_info() }, timeout=10) + response.raise_for_status() except requests.RequestException as e: logger.error("请求失败!", e) return [] @@ -49,6 +50,7 @@ def get_template_info(template_id): response = session.post('{0}/template/{1}'.format(os.getenv('API_ENDPOINT'), template_id), json={ 'accessKey': os.getenv('ACCESS_KEY'), }, timeout=10) + response.raise_for_status() except requests.RequestException as e: logger.error("请求失败!", e) return None @@ -107,6 +109,7 @@ def report_task_success(task_info): response = session.post('{0}/{1}/success'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={ 'accessKey': os.getenv('ACCESS_KEY'), }, timeout=10) + response.raise_for_status() except requests.RequestException as e: logger.error("请求失败!", e) return None @@ -117,6 +120,7 @@ def report_task_start(task_info): response = session.post('{0}/{1}/start'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={ 'accessKey': os.getenv('ACCESS_KEY'), }, timeout=10) + response.raise_for_status() except requests.RequestException as e: logger.error("请求失败!", e) return None @@ -127,6 +131,7 @@ def report_task_failed(task_info): response = session.post('{0}/{1}/fail'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={ 'accessKey': os.getenv('ACCESS_KEY'), }, timeout=10) + response.raise_for_status() except requests.RequestException as e: logger.error("请求失败!", e) return None @@ -137,6 +142,7 @@ def upload_task_file(task_info, ffmpeg_task): response = session.post('{0}/{1}/uploadUrl'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={ 'accessKey': os.getenv('ACCESS_KEY'), }, timeout=10) + response.raise_for_status() except requests.RequestException as e: logger.error("请求失败!", e) return False