如何解决芹菜'Not Registered'异常

Question

dev env
django = 3.2.4
celery = 5.2.3
redis

我使用芹菜来异步处理。我使用电子邮件传输和AI推理功能,但@sharedtask应用于电子邮件工作没有任何问题。然而，AI推理功能是不同的。一旦成功，然后执行相同的操作，将显示"未注册"异常。为什么会发生这种情况?同一任务的成功与失败如下图所示。

输入图片描述

Answer 1

我猜你们的工人对call_ai_engine_api_task不熟悉。

有几种方法可以这样做，例如:

app = Celery("my_app", broker=..., backend=..., include=["path.to.call_ai_engine_api_task", ..])  

或使用此技术

你可以在worker启动日志中看到注册的任务列表。