python - redisとセロリの実用例

Question

私はとに不慣れredisですcelery。両方の基本的なチュートリアルを実行しましたが、実装方法がわかりません。task scheduling job

スクリプトの部分から始めることができません。キューを作成したり、ワーカーを実行したりするためのスクリプトを作成する方法がわかりません。実用的な例が必要です。

Answer 1

したがって、Redisでセロリを実行する方法の一般的な例を次に示します（スクリプトファイル名をmytasks.pyとします）。

from celery import Celery

celery = Celery('tasks', broker='redis://localhost:6379/0')

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

ご覧のとおり、ブローカーの引数は、ローカルマシンにインストールされているRedisを使用するように設定されています。次は、セロリサーバーを起動します。

$ celery -A mytasks worker --loglevel=info

タスクセロリサーバーが起動したので、mytasksスクリプトをインポートするだけで、たとえばPythonインタープリターインタラクティブモードからタスクを実行するために使用できます。

>>> from mytasks import add
>>> add.delay(1, 1)
2

しばらくすると、コンソールに「2」が表示されます。

これは、タスク実行環境をセットアップする方法の基本的な例です。