混合django-celery和独立的芹菜 [英] Mixing django-celery and standalone celery

问题描述

我们正在运行一个使用Django和Piston构建的网站，我想实现芹菜将任务卸载到外部服务器。我真的不想在辅助服务器上运行Django，而只想运行一个纯Python芹菜工作者。我可以在Django服务器上编写简单的功能存根，并在二级服务器上写实际的功能逻辑吗？

ie

Django Side

 从芹菜进口任务
 
 @task 
 send_message（fromUser = None，toUser = None，msgType = None，msg = None）：
 pass 
  

服务器端

 从芹菜导入Celery 
 celery = Celery（'hello'，broker ='amqp： // guest @ localhost //'）
 @ celery.task 
 send_message（fromUser = None，toUser = None，msgType = None，msg = None）：
＃执行send_message逻辑
  

解决方案

这是很容易的。

如果您有一个纯蟒蛇芹菜工作者，只要使用相同的代理网址，您可以通过名称
发送任务：

芹菜进口Celery
celery = Celery（broker ='amqp：// guest @ localhost //'）

然后在某些视图中：

  celery.send_task（'send_message'，kwargs = {
'fromUser'：...，
}）
  

We are running a website built with Django and Piston and I want to implement celery to offload tasks to an external server. I don't really want to run Django on the secondary server and would like to simply run a pure Python celery worker. Is it possible for me to write simple function stubs on the Django server and write the actual function logic on the secondary server?

i.e.

Django Side

from celery import task

@task
send_message(fromUser=None, toUser=None, msgType=None, msg=None):
    pass

Server Side

from celery import Celery
celery =  Celery('hello', broker='amqp://guest@localhost//')
@celery.task
send_message(fromUser=None, toUser=None, msgType=None, msg=None):
    # Do send_message logic here

解决方案

That is easily possible.

If you have a pure-python Celery worker, you can send tasks by name as long as you use the same broker URL:

from celery import Celery
celery = Celery(broker='amqp://guest@localhost//')

then in some view:

 celery.send_task('send_message', kwargs={
     'fromUser': ...,
 })

这篇关于混合django-celery和独立的芹菜的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！