Celery定时任务仅在调用含.delay()、AsyncResult()接口时触发如何解决

从给出的celery-beat日志可以定位到核心问题：celery beat进程启动失败，根本没有正常运行，自然无法按配置定时推送任务。错误日志明确提示celerybeat.pid文件已存在，该文件是beat启动时生成的进程标识文件，一般是之前容器异常退出时没有正常清理该文件，导致新进程启动时检测到冲突直接终止。

1. 清理残留的pid文件
   由于你在docker-compose中把本地./backend目录挂载到了beat容器的工作目录，残留的pid文件存在于你本地的项目backend目录下，直接执行命令删除即可：

   rm -f ./backend/celerybeat.pid
   

2. 修改celery-beat启动命令，避免后续再出现pid冲突
   编辑docker-compose.yml中celery-beat服务的command配置，新增--pidfile参数禁用pid文件生成，或者指定临时目录下的pid路径，同时新增对backend服务的依赖，保证beat启动时已经加载了django的定时任务配置：

   celery-beat:
     build: ./backend
     # 修改启动命令，禁用pid文件
     command: celery -A backend beat -l info --pidfile=
     volumes:
       - ./backend/:/usr/src/app/
     depends_on:
       - redis
       - backend 
   

3. 可选优化：修复celery任务中asyncio的写法隐患
   你当前任务中asyncio.get_event_loop()的写法在celery prefork工作模式下可能出现event loop已关闭的异常，建议修改为更安全的写法：

   @shared_task
   def save_hackathon_to_db():
       logger.info('ran')
       statuses = ['ended', 'open', 'upcoming']
       # 用asyncio.run代替老的get_event_loop写法
       asyncio.run(send_data(statuses))
       logger.info('ended')
   

4. 重启celery-beat服务生效
   执行命令重建beat容器：

   docker-compose up -d --force-recreate celery-beat
   

重启完成后查看celery-beat日志，若没有pid相关报错，且打印出scheduler started的日志即为启动成功，等待3分钟即可在celery worker日志中看到定时任务的执行记录。

补充：如果beat启动正常后任务执行时间不符合预期，可检查Django settings中是否配置了正确的时区：

CELERY_TIMEZONE = "Asia/Shanghai" # 替换为你实际需要的时区
USE_TZ = True

内容的提问来源于stack exchange，提问作者A.K.M. Adib