为什么我在使用 Celery 时会出现名称“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

您需要将celeryshared_task装饰器导入为from celery import shared_task@shared_taskdef scrape():    ...    # your code