使用Django与芹菜接收未注册的任务

我有一个Django项目的芹菜设置，我似乎无法让我的任务正常运行。我在Ubuntu 13.04上使用Django 1.4.3，celery 3.0.1，django-celery 3.0.17和Python 2.7。使用Django与芹菜接收未注册的任务

我已经验证了我的RabbitMQ服务器是否正在运行：

sudo service rabbitmq-server status 
Status of node [email protected] ... 
[{pid,1667}, 
{running_applications,[{rabbit,"RabbitMQ","3.0.2"}, 
         {os_mon,"CPO CXC 138 46","2.2.9"}, 
         {mnesia,"MNESIA CXC 138 12","4.7"}, 
         {sasl,"SASL CXC 138 11","2.2.1"}, 
         {stdlib,"ERTS CXC 138 10","1.18.1"}, 
         {kernel,"ERTS CXC 138 10","2.15.1"}]}, 
{os,{unix,linux}}, 
{erlang_version,"Erlang R15B01 (erts-5.9.1) [source] [64-bit] [smp:8:8] [async-threads:30] [kernel-poll:true]\n"}, 
{memory,[{total,28112760}, 
      {connection_procs,93432}, 
      {queue_procs,42680}, 
      {plugins,0}, 
      {other_proc,9331824}, 
      {mnesia,65288}, 
      {mgmt_db,0}, 
      {msg_index,86656}, 
      {other_ets,764048}, 
      {binary,1343288}, 
      {code,12372068}, 
      {atom,512601}, 
      {other_system,3500875}]}, 
{vm_memory_high_watermark,0.4}, 
{vm_memory_limit,6719406080}, 
{disk_free_limit,1000000000}, 
{disk_free,122925531136}, 
{file_descriptors,[{total_limit,924}, 
        {total_used,7}, 
        {sockets_limit,829}, 
        {sockets_used,3}]}, 
{processes,[{limit,1048576},{used,151}]}, 
{run_queue,0}, 
{uptime,275789}] 
...done.

我有一个virtualenv中我的Django项目的设置。我有芹菜在settings.py文件配置为：

INSTALLED_APPS = [ 
    # django apps 

    # our apps ... 

    # third party modules ... 
    'djcelery', 
] 

import djcelery 
djcelery.setup_loader() 

CELERY_IMPORTS = ('my.task')

的RabbitMQ的经纪人是正确设置 - 我们还有其他任务芹菜运行正常。

我的任务：

import celery 

class MyClass(object): 

    @celery.task() 
    def my_task(self, new, old): 
     # do stuff 
     return 

    def kick_off_tasks(self): 
     # do stuff 
     new = 'something' 
     old = 'something else' 
     self.my_task.apply_async(args(new, old), kwarg1='new', kwarg2='old) 
     # do more stuff

当我运行调用kick_off_tasks我收到的celeryd信息日志中的以下观点：

./manage.py celeryd --loglevel=info 

[Tasks] 
    . my.task 
    . other.tasks 
    . more.tasks 
    . etc.etc.etc 

[2013-08-23 14:18:40,772: WARNING/MainProcess] [email protected] has started. 
[2013-08-23 14:20:40,757: ERROR/MainProcess] Received unregistered task of type 'my.task'. 
The message has been ignored and discarded. 

Did you remember to import the module containing this task? 
Or maybe you are using relative imports? 
Please see http://bit.ly/gLye1c for more information. 

The full contents of the message body was: 
{'retries': 0, 'task': 'my.task', 'eta': None, 'args': ('something, 'something else'), 'expires': None, 'callbacks': None, 'errbacks': None, 'kwargs': {}, 'id': 'bf4d5ee7-9701-42b6-a887-c6b6470d9810', 'utc': True} (2297b) 

Traceback (most recent call last): 
    File "/home/ricomoss/.virtualenvs/proton/local/lib/python2.7/site-packages/celery/worker/consumer.py", line 394, in on_task_received 
    strategies[name](message, body, message.ack_log_error) 
KeyError: 'my.task'

有什么建议？

来源

2013-08-23 Rico

我能够通过重构得到这个工作，以便任务不是类方法。我把它们放在我们的tasks.py文件中，一切正常。我没有时间研究为什么会出现这种情况，我打算这样做，但在此之前，如果有人遇到同样的问题，您可以快速解决问题。

来源

2013-08-26 15:51:52 Rico

你有没有找到一种方法使类方法作为任务工作？我有类似的问题。目前我使用'tasks.py'文件来调用类方法，当我想在后台运行它们时，我宁愿直接调用它们。 – Matthew

@Mthethew我从来没有能够成功地任务一个类或类方法。我相信这与它被腌制的方式有关，但我从来没有花时间去理解底层问题是什么。 – Rico

使用Django与芹菜接收未注册的任务

回答

相关问题