From c436d098a8167ad8989171abe0fac40419cca05b Mon Sep 17 00:00:00 2001 From: H Vs Date: Wed, 26 Mar 2025 11:00:14 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=86=E5=B8=83=E5=BC=8F=E8=B0=83=E5=BA=A6?= =?UTF-8?q?=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- celery_app.py | 2 +- run.py | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/celery_app.py b/celery_app.py index 02325fa..7cdc343 100644 --- a/celery_app.py +++ b/celery_app.py @@ -70,7 +70,7 @@ celery_app.conf.update( beat_scheduler="redbeat.RedBeatScheduler", # 使用 RedBeat 作为调度器 redbeat_redis_url=f"redis://:telpo%231234@{redis_host}:{redis_port}/{redis_db}" # redbeat 存储任务调度信息的 Redis , - redbeat_lock_timeout=10, # 避免多个 Beat 实例冲突 + redbeat_lock_timeout=60, # 避免多个 Beat 实例冲突 beat_max_loop_interval=5 # 让 Celery Beat 每 5 秒检查一次任务 ) diff --git a/run.py b/run.py index 0fdb27f..fe50869 100644 --- a/run.py +++ b/run.py @@ -26,11 +26,11 @@ def start_celery_beat(): if __name__ == "__main__": # 启动 FastAPI、Celery Worker 和 Celery Beat - fastapi_process = start_fastapi() - #celery_worker_process = start_celery_worker() - #celery_beat_process = start_celery_beat() + #fastapi_process = start_fastapi() + celery_worker_process = start_celery_worker() + celery_beat_process = start_celery_beat() # 等待子进程完成 - fastapi_process.wait() - #celery_worker_process.wait() - #celery_beat_process.wait() + #fastapi_process.wait() + celery_worker_process.wait() + celery_beat_process.wait()