mirror of
https://git.oceanpay.cc/danial/kami_apple_exchage.git
synced 2025-12-18 21:23:49 +00:00
```
feat(config): 调整定时任务执行频率与批处理数量 将订单批量处理的定时任务执行间隔从每30秒一次调整为每10秒一次, 同时将每批次最大处理订单数从100调整为5,以优化系统负载和任务响应速度。 此外,生产环境的Worker最大任务数配置由100调整为40,进一步控制资源使用。 ```
This commit is contained in:
@@ -52,7 +52,7 @@ class ArqWorkerConfig:
|
||||
cron(
|
||||
batch_process_orders,
|
||||
name="batch-process-pending-orders",
|
||||
second={30, 0},
|
||||
second=set(range(0, 60, 10)), # 每10秒运行一次
|
||||
max_tries=3,
|
||||
timeout=3000,
|
||||
)
|
||||
|
||||
@@ -200,7 +200,7 @@ async def batch_process_orders(ctx) -> dict[str, Any]:
|
||||
links_service = LinksService(session)
|
||||
|
||||
processed_count = 0
|
||||
max_orders_per_batch = 100 # 每批处理的最大订单数
|
||||
max_orders_per_batch = 5 # 每批处理的最大订单数
|
||||
|
||||
while processed_count < max_orders_per_batch:
|
||||
user_data_id = await redis_manager.get_user_data_id()
|
||||
|
||||
@@ -65,7 +65,7 @@ services:
|
||||
- ENVIRONMENT=production
|
||||
- DATABASE_URL=postgresql+asyncpg://postgres:Kp9mX8vL2nQ5wR7@db:5432/apple_exchange
|
||||
- REDIS_URL=redis://:Df4jG7zN9pL1tY3@redis:6379/0
|
||||
- WORKER_MAX_JOBS=100
|
||||
- WORKER_MAX_JOBS=40
|
||||
- WORKER_JOB_TIMEOUT=1800
|
||||
- WORKER_MAX_TRIES=3
|
||||
- WORKER_HEALTH_CHECK_INTERVAL=30
|
||||
|
||||
Reference in New Issue
Block a user