为什么我在使用 Celery 时会出现名称“shared_task”未定义的错误

Question

我收到以下错误NameError: name 'shared_task' is not defined这是我的代码import requestsfrom bs4 import BeautifulSoupimport jsonfrom datetime import datetimeimport lxml@shared_taskdef scrape():    try:        ...这段代码对他有用，但我收到上述错误。不确定我做错了什么。请帮我

Answer 1

您需要将celeryshared_task装饰器导入为

from celery import shared_task

@shared_task

def scrape():

    ...

    # your code