From 20cb35fc6e46bcdd71c572a9bce9b12a8063f622 Mon Sep 17 00:00:00 2001 From: win Date: Mon, 23 Mar 2026 10:58:41 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E7=A7=BB=E9=99=A4=20push=5Fto=5Fremote?= =?UTF-8?q?=20=E7=9A=84=20print(data)=EF=BC=8C=E9=81=BF=E5=85=8D=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E6=92=91=E7=88=86=E7=A3=81=E7=9B=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 每条 job 含 base_data 几十KB，全量 print 到 stdout 导致 Docker json-file 日志无限增长（930GB+） --- app/services/ingest/remote_push.py | 24 +++++++++++------------- 1 file changed, 11 insertions(+), 13 deletions(-) diff --git a/app/services/ingest/remote_push.py b/app/services/ingest/remote_push.py index 399b296..4ce62dc 100644 --- a/app/services/ingest/remote_push.py +++ b/app/services/ingest/remote_push.py @@ -59,20 +59,18 @@ async def push_to_remote(data: Dict[str, Any]) -> bool: source_type = data.get("source_type", "未知平台") title = data.get("title", "未知职位") company = data.get("company_name", data.get("name", "未知公司")) - logger.info(f"上报数据: [{source_type}] {title} - {company}") - print(data) - # try: - # url = _build_auth_url() - # client = get_http_client() - # response = await client.post(url, json=data, headers=_PUSH_HEADERS) - # if response.status_code == 200: - # return True - # logger.error(f"数据发送失败: {response.status_code} - {response.text[:100]}") - # return False - # except Exception as e: - # logger.error(f"发送异常: {e}") - # return False + try: + url = _build_auth_url() + client = get_http_client() + response = await client.post(url, json=data, headers=_PUSH_HEADERS) + if response.status_code == 200: + return True + logger.error(f"数据发送失败: {response.status_code} - {response.text[:100]}") + return False + except Exception as e: + logger.error(f"发送异常: {e}") + return False async def batch_push_to_remote(data_list: List[Dict[str, Any]]) -> None: