为什么我得到的名字"shared_task"没有定义芹菜错误

Question

我正在按照本教程学习芹菜。

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

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:
...

这个代码对他有效，但我收到了上面提到的错误。不确定我做错了什么。请帮我

提前感谢

Answer 1

您需要将celenicshared_task装饰器作为导入

from celery import shared_task

@shared_task
def scrape():
...
# your code