shuim/auto-stock
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update
Some checks failed
CI/CD Pipeline / test-backend (push) Has been cancelled
Details
CI/CD Pipeline / test-frontend (push) Has been cancelled
Details
CI/CD Pipeline / build-and-push (push) Has been cancelled
Details

Browse Source
This commit is contained in:
shuim
2026-03-27 21:40:01 +09:00
parent c818810667
commit 94ccd0f3f6
1 changed files with 26 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
backend/app/services/korea_investment_api.py
View File

@@ -477,34 +477,34 @@ class KoreaInvestmentAPI:
**kwargs **kwargs
) )
# 성공 # 성공
if response.status_code == 200: if response.status_code == 200:
duration = time.time() - start_time duration = time.time() - start_time
self.monitor.record_call(success=True, duration=duration, retries=retry_count) self.monitor.record_call(success=True, duration=duration, retries=retry_count)
self.circuit_breaker.record_success() self.circuit_breaker.record_success()
if self.monitor.should_alert(threshold=settings.API_ERROR_THRESHOLD): if self.monitor.should_alert(threshold=settings.API_ERROR_THRESHOLD):
logger.warning(f"⚠️ API 오류율 높음: {self.monitor.get_error_rate():.1%}") logger.warning(f"⚠️ API 오류율 높음: {self.monitor.get_error_rate():.1%}")
return response.json(), response.headers return response.json(), response.headers
# 서버 오류 (5xx, 429) — 재시도 # 서버 오류 (5xx, 429) — 재시도
elif response.status_code in [429, 500, 502, 503, 504]: elif response.status_code in [429, 500, 502, 503, 504]:
retry_count += 1 retry_count += 1
if attempt < self.max_retries: if attempt < self.max_retries:
delay = self.retry_delay * (self.retry_backoff ** attempt) delay = self.retry_delay * (self.retry_backoff ** attempt)
logger.warning(f"⏳ API 재시도 {attempt + 1}/{self.max_retries}: {response.status_code}, {delay:.1f}초 후") logger.warning(f"⏳ API 재시도 {attempt + 1}/{self.max_retries}: {response.status_code}, {delay:.1f}초 후")
await asyncio.sleep(delay) await asyncio.sleep(delay)
continue continue
else:
self.circuit_breaker.record_failure()
raise Exception(f"API 최대 재시도 초과: {response.status_code}")
# 클라이언트 오류 (4xx) — 재시도 불필요
else: else:
self.monitor.record_call(success=False, duration=time.time() - start_time, retries=retry_count) self.circuit_breaker.record_failure()
try: raise Exception(f"API 최대 재시도 초과: {response.status_code}")
return response.json(), response.headers
except Exception: # 클라이언트 오류 (4xx) — 재시도 불필요
return {"rt_cd": str(response.status_code), "msg1": response.text[:200], "output": None}, None else:
self.monitor.record_call(success=False, duration=time.time() - start_time, retries=retry_count)
try:
return response.json(), response.headers
except Exception:
return {"rt_cd": str(response.status_code), "msg1": response.text[:200], "output": None}, None
except httpx.TimeoutException as e: except httpx.TimeoutException as e:
retry_count += 1 retry_count += 1