为什么我得到 name 'shared_task' is not defined error with Celery

Why am I getting name 'shared_task' is not defined error with Celery

我正在按照这个 tutorial.

学习芹菜

我像他一样创建了任务并尝试了 运行 代码。但是我收到以下错误

NameError: name 'shared_task' is not defined

这是我的代码

import requests
from bs4 import BeautifulSoup
import json
from datetime import datetime
import lxml

@shared_task
def scrape():
    try:
        ...

此代码适用于他,但我收到上述错误。不确定我做错了什么。请帮助我

提前致谢

您需要将 celery shared_task decorator 导入为

<b>from celery import shared_task


@shared_task</b>
def scrape():
    ...
    # your code