出现429时移除token

core/utils.py

@@ -274,6 +274,17 @@ async def process_streaming_response(request: ChatRequest, app_secret: str, curr
             )
         except httpx.HTTPStatusError as e:
             # 这里需要处理401错误
+
+            # 处理429错误
+            if e.response.status_code == 429:
+                token_str = os.getenv('TOKEN', '')
+                token_array = token_str.split(',')
+                token_array.pop(current_index)
+                os.environ["TOKEN"] = ','.join(token_array)
+                refresh_token_str = os.getenv('REFRESH_TOKEN', '')
+                refresh_token_array = refresh_token_str.split(',')
+                refresh_token_array.pop(current_index)
+                os.environ["REFRESH_TOKEN"] = ','.join(refresh_token_array)
             logger.error(f"HTTP error occurred: {e}")
             raise HTTPException(status_code=e.response.status_code, detail=str(e))
         except httpx.RequestError as e: