Celery无法执行代码的原因排查及修复方案咨询

看起来你已经在Django里搭好了Celery和RabbitMQ的基础环境，但任务没执行确实挺让人头疼的，我帮你梳理几个常见的排查方向，你可以一步步核对：

• 先确认Celery Worker是否正常启动
  光配置好Celery和RabbitMQ还不够，必须有Worker进程来消费队列里的任务。你可以在项目根目录执行以下命令启动Worker：

  celery -A your_project_name worker -l info
  

  记得把your_project_name换成你Django项目的名称（也就是存放settings.py的那个目录名）。如果启动时报错，比如连接RabbitMQ失败，那优先排查Broker的连接问题。

• 检查RabbitMQ SSL连接配置
  你用的是amqps协议（带SSL的RabbitMQ连接），这里容易踩坑的点不少：

  • 确认RabbitMQ已经开启SSL服务，并且监听5671端口。可以用telnet localhost 5671测试端口是否能连通，或者通过RabbitMQ管理界面（如果已开启）查看端口状态。
  • 核实配置里的证书路径/etc/rabbitmq/cacert.crt、key.pem、cert.crt是否真实存在，且Celery进程拥有读取这些文件的权限。
  • 可以临时关闭SSL测试：把CELERY_BROKER_URL改成amqp://guest:guest@localhost:5672/，同时注释掉CELERY_BROKER_USE_SSL相关配置，重启Worker和RabbitMQ后再测试任务。如果任务能正常执行，那问题肯定出在SSL配置上。

• 确认任务注册与调用方式正确

  • 你的任务代码里@sh...应该是@shared_task装饰器吧？要确保装饰器使用正确，且任务所在文件能被Django和Celery识别。
  • 调用任务时，必须使用Celery的延迟执行方法，比如your_task_name.delay()或者your_task_name.apply_async(countdown=30)。如果直接调用your_task_name()，会在当前进程同步执行，不会走Celery队列。
  • 启动Worker时，查看日志（用-l info参数会输出详细日志），里面会有“Registered tasks”列表，检查你的任务是否在其中。如果没有，说明任务未被注册，可能是任务所在的app没加入到Django的INSTALLED_APPS里，或者文件路径不符合Celery的加载规则。

• 通过日志排查执行细节
  你配置了CELERY_RESULT_BACKEND = "rpc://"（用RabbitMQ作为结果后端），但对于print测试来说，结果后端不影响任务执行，不过Worker的info级日志会显示任务的完整生命周期：是否被队列接收、是否开始执行、有没有抛出异常。如果任务默默失败，日志里大概率会有详细的错误信息。

• 时区配置一致性检查（提前规避后续问题）
  虽然你现在用print测试，但之后要实现延迟删除功能，必须确保Django的TIME_ZONE和Celery的CELERY_TIMEZONE配置一致，否则延迟时间会出现偏差。可以在settings.py里添加：

  CELERY_TIMEZONE = TIME_ZONE
  

  假设你已经配置了Django的TIME_ZONE参数。

备注：内容来源于stack exchange，提问作者coromo