已删除的Celery任务仍在日志中报错的问题求助

兄弟，我太懂这种糟心情况了！你遇到的这个错误，核心原因是消息队列里还积压着之前发送的post_jobs任务消息——虽然你已经在代码里删掉了这个任务的定义，但Celery Worker在消费队列时，还是会读到这些旧消息，而现在Worker找不到对应的任务注册，就会抛出这个错误。

下面给你几个靠谱的解决办法：

• 彻底清理积压的旧任务消息
  这是最直接的方式，把队列里残留的旧任务全部清掉：

  • 如果用Redis作为消息中间件：登录Redis控制台，执行FLUSHDB（注意：这个命令会清空当前Redis数据库的所有数据，如果你的Redis还用来存其他业务数据，别用这个！），或者更精准地删除Celery队列的键，比如执行DEL celery（不同的Celery配置，队列键名可能不一样，你可以用KEYS *celery*先查看）。
  • 如果用RabbitMQ：可以用命令行执行rabbitmqctl purge_queue celery来清空默认队列，或者登录RabbitMQ的管理界面，找到对应的队列手动清空。

• 临时注册空任务过渡
  如果你不想清空队列（比如队列里还有其他有用的任务），可以临时在tasks.py里加一个空的post_jobs任务，让Worker能处理掉这些积压的旧消息：

  from celery import task
  
  @task(name='post_jobs')
  def post_jobs(*args, **kwargs):
      # 空实现，只是用来消化队列里的旧消息
      pass
  

  等日志里不再出现这个错误（说明旧消息都处理完了），再把这个临时任务删掉就行。

• 后续预防建议
  以后要删除Celery任务时，最好先停止Worker，然后清理队列里该任务的残留消息，再重启Worker并部署新代码，这样就能避免类似的问题啦。

内容的提问来源于stack exchange，提问作者Zorgan