分布式调度器

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 秒检查一次任务
 )
 

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()