[求助] django + celery的问题

[ununique]

消息队列用的RabbitMQ，单独测试celery的worker和caller都没问题，但把caller的代码放到django里面后，worker端总是报错：

[2013-09-06 16:19:09,088: ERROR/MainProcess] Received unregistered task of type
'Test.tasks.add'.
The message has been ignored and discarded.

-----------------------------
worker的代码就是官方的demo,如下：
from celery import Celery, task

celery = Celery('tasks', backend='amqp', broker='amqp://xxx:xxx@xxx-xxx//')

@task
def add(x, y):
return x + y
-------------------------------------
django里面的代码：
import time
from Test.tasks import add

class Test(ListView):

def get(self, request):

res1 = add.delay(2, 3)
time.sleep(5)
return HttpResponse("result is %s" %tmp)

----------------------
请问应该怎么正确调用worker呢？谢谢
--

[m [34m※ 来源:·水木社区 http://www.newsmth.net·[FROM: 210.83.232.*] [m

[ununique]

现在需要在一台机运行Django, 在其他几台机器上运行其他任务，通过web页面去触发任务。
试验了下celery + RabbitMQ, 遇到个问题请教下大家

1. 看了下别人的例子，好像都是在同一台机运行django和celery，不知道在其他机运行celery是否能在admin的管理页面看到celery运行状态之类的信息呢？
2. 触发任务后，目标机收不到任务，队列里面的信息被其他机器获取，但因为task name不匹配被丢弃，这个应该怎么配置或者正确调用呢？

谢谢大家先
--

[m [31m※ 来源:·水木社区 http://www.newsmth.net·[FROM: 210.83.232.*] [m

[呸]

1 不清楚，但是应该可以
2 设置 router，celery运行的时候加个参数 -Q queue_name，然后router里面指定
Queue

【 在 ununique (ununique) 的大作中提到: 】
: 现在需要在一台机运行Django, 在其他几台机器上运行其他任务，通过web页面去触发
任务。
: 试验了下celery + RabbitMQ, 遇到个问题请教下大家

: 1. 看了下别人的例子，好像都是在同一台机运行django和celery，不知道在其他机运行
celery是否能在admin的管理页面看到celery运行状态之类的信息呢？

: ...................

--
如何才能赚钱呢？
省到就是赚到
z秒杀 >>>>>>>>>> http://t.cn/z8x42uv <<<<<<<<<<<<


[m [33m※ 来源:·水木社区 http://newsmth.net·[FROM: 180.169.36.*] [m

[ununique]

谢谢，问题2解决了。

【 在 koubuyi 的大作中提到: 】
: 1 不清楚，但是应该可以

: 2 设置 router，celery运行的时候加个参数 -Q queue_name，然后router里面指定
: Queue

: ...................

--

[m [35m※ 来源:·水木社区 http://www.newsmth.net·[FROM: 210.83.232.*] [m