|
@@ -54,7 +54,7 @@ app = FastAPI(
|
|
|
scheduler = AsyncIOScheduler()
|
|
scheduler = AsyncIOScheduler()
|
|
|
|
|
|
|
|
# 并发控制
|
|
# 并发控制
|
|
|
-MAX_CONCURRENT_TASKS = int(os.getenv("MAX_CONCURRENT_TASKS", "3"))
|
|
|
|
|
|
|
+MAX_CONCURRENT_TASKS = int(os.getenv("MAX_CONCURRENT_TASKS", "1"))
|
|
|
task_semaphore = asyncio.Semaphore(MAX_CONCURRENT_TASKS)
|
|
task_semaphore = asyncio.Semaphore(MAX_CONCURRENT_TASKS)
|
|
|
|
|
|
|
|
# 统计信息
|
|
# 统计信息
|
