我有一个celery应用，我的文件是这样的：
/fetcher.py
/mirad
celery.py
fetcher_tasks.py
在celery.py我导入fetcher_tasks.py并且在fetcher.py中，我从fetcher_tasks.py调用了一个任务，我想celery.control在fetcher.py中导入，但是我做不到，我该怎么做呢？
这是我的提取程序代码的一部分：
from __future__ import absolute_import
import mirad.fetcher_tasks as tasks
from mirad.models.models import SourceModel
from mirad.settings import *
from mirad.celery.control import inspect
parse_feed_tasks = list()
def fetch():
for source in SourceModel.objects(active=True):
a = tasks.parse_feed.delay(source)
看起来您在项目中混入了celery.py，该项目用于使用celery软件包启动Celery应用，从中可以导入必需的功能。
您应该inspect从celery.task.control包中导入函数。
from __future__ import absolute_import
import mirad.fetcher_tasks as tasks
from mirad.models.models import SourceModel
from mirad.settings import *
from celery.task.control import inspect
parse_feed_tasks = list()
def fetch():
for source in SourceModel.objects(active=True):
a = tasks.parse_feed.delay(source)
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句