Django和芹菜：任务不导入

我使用Django的芹菜运行中涉及到的联系人/电子邮件解析背景两个任务。Django和芹菜：任务不导入

结构是：

project 
    /api 
    /core 
     tasks.py 
    settings.py

settings.py文件包含：

BROKER_URL = 'django://' 
BROKER_BACKEND = "djkombu.transport.DatabaseTransport" 

#celery 
BROKER_HOST = "localhost" 
BROKER_PORT = 5672 
BROKER_USER = "guest" 
BROKER_PASSWORD = "guest" 
BROKER_VHOST = "/" 

sys.path.append(os.path.dirname(os.path.basename(__file__))) 
CELERY_IMPORTS = ['project.core.tasks'] 

import djcelery 
djcelery.setup_loader() 

# .... 

INSTALLED_APPS = (
    #... 

    'kombu.transport.django', 
    'djcelery', 
)

tasks.py包含：

from celery.task import Task 
from celery.registry import tasks 

class ParseEmails(Task): 
    #... 

class ImportGMailContactsFromGoogleAccount(Task): 
    #... 

tasks.register(ParseEmails) 
tasks.register(ImportGMailContactsFromGoogleAccount)

此外，在wsgi.py添加

os.environ["CELERY_LOADER"] = "django"

现在，我有这个应用程序托管在WebFactional服务器上。在我的本地这个运行良好，但WebFaction服务器，其中Django应用程序部署在Apache服务器上，我得到：

2013-01-23 17:25:00,067: ERROR/MainProcess] Task project.core.tasks.ImportGMailContactsFromGoogleAccount[df84e03f-9d22-44ed-a305-24c20407f87c] raised exception: Task of kind 'project.core.tasks.ImportGMailContactsFromGoogleAccount' is not registered, please make sure it's imported.

但任务显示为注册。如果我运行

python2.7 manage.py celeryd -l info

我获得：

-------------- [email protected] v3.0.13 (Chiastic Slide) 
---- **** ----- 
--- * *** * -- [Configuration] 
-- * - **** --- . broker:  django://localhost// 
- ** ---------- . app:   default:0x1e55350 (djcelery.loaders.DjangoLoader) 
- ** ---------- . concurrency: 8 (processes) 
- ** ---------- . events:  OFF (enable -E to monitor this worker) 
- ** ---------- 
- *** --- * --- [Queues] 
-- ******* ---- . celery:  exchange:celery(direct) binding:celery 
--- ***** ----- 

[Tasks] 
    . project.core.tasks.ImportGMailContactsFromGoogleAccount 
    . project.core.tasks.ParseEmails

我认为这可能是一个相对导入错误，但我认为在settings.py的变化和wsgi.py会阻止。

我在想WebFactional支持的多个Python版本可能需要这样做，但是我安装了Python 2.7的所有库，并且我也运行了Django for 2.7，所以应该没有问题。

在本地主机上运行使用celeryd -l信息的任务列表中还显示了，当我启动工作，但是当我调用任务就不会输出错误 - 它运行完美。

谢谢

来源

2013-01-23 Vasco Patricio

我曾在一个新的Ubuntu 12.04 /阿帕奇/ mod_wsgi的/ Django的1.5 /芹菜3.0.13生产环境相同的问题。一切正常，我的Mac Os X 10.8笔记本电脑和我的旧服务器（其中有Celery 3.0.12），但没有在新的服务器上。

似乎有芹菜中的一些问题： https://github.com/celery/celery/issues/1150

我最初的溶液改变我的任务类基于任务为基础，以@task装饰，从这样的事情：

class CreateInstancesTask(Task): 
    def run(self, pk): 
     management.call_command('create_instances', verbosity=0, pk=pk) 
tasks.register(CreateInstancesTask)

喜欢的东西这个：

@task() 
def create_instances_task(pk): 
    management.call_command('create_instances', verbosity=0, pk=pk)

现在这个任务似乎工作，但我当然要做一些进一步的测试...

来源

2013-02-05 09:02:42

这是奇怪的，你提到的，我已经在使得它的工作是准确地从任务类更改为装饰功能也同时在做。然而这只有在某些方面运行芹菜时才有效。使用“celery -worker”工作，但例如“celery-multi start 1”不会在manage.py目录中使用“manage.py celeryd_multi start 1”，从而产生与使用不同的结果。我想我真正能做到的唯一方法就是深入调查问题。 –

Django和芹菜：任务不导入

回答

相关问题