|
@@ -75,6 +75,7 @@ def _upload_chunk(text: str, query: str, channel: str = "", max_retries: int = 3
|
|
for attempt in range(max_retries):
|
|
for attempt in range(max_retries):
|
|
try:
|
|
try:
|
|
resp = requests.post(CHUNK_API_URL, headers=headers, json=payload, timeout=15)
|
|
resp = requests.post(CHUNK_API_URL, headers=headers, json=payload, timeout=15)
|
|
|
|
+ logger.info(f"上传chunk成功: resp={resp.json()}")
|
|
if resp.status_code >= 200 and resp.status_code < 300:
|
|
if resp.status_code >= 200 and resp.status_code < 300:
|
|
return True
|
|
return True
|
|
logger.warning(f"上传失败,状态码: {resp.status_code}, 第{attempt+1}次重试")
|
|
logger.warning(f"上传失败,状态码: {resp.status_code}, 第{attempt+1}次重试")
|