Django，导入错误：无法从“celery”导入名称“任务”

Question

我有使用 Celery 版本 4.4.2 的 Django 应用程序，它运行良好。

from celery import task
import logging


@task(ignore_result=True)
def log_user_activity(user_id):
    try:
        logging.info(user_id)
    except Exception as e:
        logging.error(str(e))

当我尝试将 Celery 版本更新到 v5.2.2 时，出现以下错误：

ImportError：无法从“celery”导入名称“task”

有人可以帮忙任务被替换成什么吗？他们这里还有同样的例子。 https://github.com/celery/celery/blob/v5.2.2/examples/celery_http_gateway/tasks.py

Answer 1

该 API 已被弃用，并在 5.0 中被删除。

该页面建议更改

from celery import task

进入

from celery import shared_task

还有其他更改不适用于您发布的代码片段，但可能适用于您的其余代码。有关更多详细信息，请参阅该页面（以及文档的其余部分，尤其是从 Celery 4.x 升级部分）。