2016-05-03 35 views
2

キューにタスクを追加し、そのタスクを消費するセラー労働者を追加するAPIコードがあります。djangoなしでセロリを使うことができます

現在、私は両方のコードベースが同じです。しかし、私はセクシーな労働者が仕事を処理するだけで、それのためのdjangoを必要としない単純なプレーンなPythonのタスクとdjangoのコードを持ってほしいです。出来ますか。セロリワーカーを開始するために

は、私はそこにはいすることができます

答えて

2

django_projectの代わりに書くべきことこのライン

celery -A django_project worker --queue high 

を使用する必要があります。 Celeryは汎用非同期タスク・キューです。 "django_project"の代わりにあなたのモジュールを指しています。例については、http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html#applicationを参照してください。ここで

はセロリを使ってサンプルプロジェクトのレイアウトです:

のmymodule/celery.pyで
project-dir/ 
    mymodule/ 
     __init__.py 
     celery.py 
     tasks.py 
    tests/ 
    setup.py 
    etc, etc (e.g. tox.ini, requirements.txt, project management files) 

:のmymodule/tasks.pyで

# -*- coding : utf-8 -*- 
from __future__ import absolute_import 

from celery import Celery 

app = Celery('mymodule', 
      broker='amqp://', 
      backend='amqp://', 
      include=['mymodule.tasks']) 

if __name__ == '__main__': 
    app.start() 

from __future__ import absolute_import 

from mymodule.celery import app 

@app.task 
def add(x, y): 
    return x + y 
+0

がどうあるべきかcelery.pyの内容 – Karl

+0

そのおかげで – Karl

関連する問題