修改异常捕获

common.py

@@ -17,6 +17,7 @@ def setup_proxy(proxy_url):
         "http": proxy_url,
         "http": proxy_url,
         "https": proxy_url
         "https": proxy_url
     }
     }
+    addr = proxy_url.split('@')[1].split(':')[0]
     # 配置重试机制
     # 配置重试机制
     retries = Retry(
     retries = Retry(
         total=5,
         total=5,

requirements.txt

+google~=3.0.0
+onnxruntime~=1.15.0
+numpy~=1.24.2
+protobuf~=3.20.2
+requests~=2.32.3
+websocket-client~=1.8.0
+PyExecJS~=1.5.1
+loguru~=0.7.3
+celery~=5.5.0
+fastapi~=0.115.11
+pydantic~=2.10.6
+curl_cffi~=0.10.0
+DrissionPage~=4.1.0.18
+urllib3~=2.3.0
+dynaconf~=3.2.10
+ddddocr~=1.5.6
+playwright~=1.50.0
+opencv-python~=4.11.0.86
+tenacity~=9.1.2
+tqdm~=4.67.1
+gevent~=25.5.1
+redis
+uvicorn
\ No newline at end of file

task_worker.py

@@ -225,7 +225,7 @@ def execute_get_schema(headers: dict, proxy_url: str, category_id: str):
             }
             }
         params['a_bogus'] = res['data']
         params['a_bogus'] = res['data']
         session = setup_proxy(proxy_url)
         session = setup_proxy(proxy_url)
-        response = session.post(url, params=params, headers=headers, json=json_data)
+        response = session.post(url, params=params, headers=headers, json=json_data, verify= False)
         if response.text and response.json().get('code') == 0:
         if response.text and response.json().get('code') == 0:
             result = response.json().get('data', {})
             result = response.json().get('data', {})
             return {
             return {
@@ -237,15 +237,22 @@ def execute_get_schema(headers: dict, proxy_url: str, category_id: str):
         return {
         return {
             'code': 500,
             'code': 500,
             'msg': '获取类目参数失败',
             'msg': '获取类目参数失败',
-            'data': None,
+            'data': response.text,
             'error_type': ''
             'error_type': ''
         }
         }
+    except AppError as e:
+        return {
+            'code': e.code,
+            'msg': e.msg,
+            'data': e.data,
+            'error_type': type(e).__name__
+        }
     except Exception as e:
     except Exception as e:
         logger.error(f'获取类目参数异常:{e}')
         logger.error(f'获取类目参数异常:{e}')
         logger.error(f'params-->{params}')
         logger.error(f'params-->{params}')
         logger.error(f'json_data-->{json_data}')
         logger.error(f'json_data-->{json_data}')
         logger.error(f'headers-->{headers}')
         logger.error(f'headers-->{headers}')
-        logger.error(f'proxies-->{proxy_url}')
+        logger.error(f'proxy_url-->{proxy_url}')
         return {
         return {
             'code': 500,
             'code': 500,
             'msg': f'获取类目参数失败:{e}',
             'msg': f'获取类目参数失败:{e}',