セロリの公式チュートリアルの作業を取得しようとしていますが、このエラーが発生し続けました:
D:\test>celery -A tasks worker --loglevel=info
-------------- celery@BLR122S v3.0.17 (Chiastic Slide)
---- **** --- --
--- * * * -- [構成]
-- * - **** --- . ブローカー: amqp://guest@localhost:5672//
- ** ---------- . app: tasks:0x2a76850
- ** ---------- . 並行性: 2 (プロセス)
- ** ---------- . events: OFF (このワーカーを監視するために -E を有効にします)
- ** ----------
- * --- * --- [Queues]
-- ******** ---- . celery: exchange:celery(direct) binding:celery
--- ***** -----
[タスク]
. tasks.add
[2013-03-29 17:50:52,533: WARNING/MainProcess] celery@BLR122S 準備完了。
[2013-03-29 17:50:52,568: INFO/MainProcess] 消費者: amqp://guest@ 127.0.0.1:5672// に接続されました。
[2013-03-29 17:51:32,496: INFO/MainProcess] ブローカーからタスクを取得しました: tasks.add[8345 9233-ce54-40ed-a2a8-ee0d60768006]
[2013-03-29 17:51:32,562: ERROR/ MainProcess] Task tasks.add[83459233-ce54-40ed-a 2a8-ee0d60768006] で例外が発生しました:種類 'tasks.add' のタスクが登録されていません。インポートされていることを確認してください。
トレースバック (最新の呼び出しが最後):ファイル「C:\Python27\lib\site-packages\billiard\pool.py」、293 行目、ワーカー
result = (True, func(*args, **kwds))
ファイル "C:\Python27\lib\site-packages\celery\task\trace.py"、320 行目、_fast_trace_task で
return _tasks[task].__trace__( uuid、args、kwargs、request)[0]
ファイル "C:\Python27\lib\site-packages\celery\app\registry.py"、20 行目、__missing__ で、
self.NotRegistered(key)
NotRegistered: 'tasks.追加'
celery==3.0.17 と rabbitMQ をインストールしました。次に、「 」で
セロリを開始するのは[タスク]にあるようですが、呼び出しは次のとおりです。D:\test>celery -A tasks worker --loglevel=info
tasks.add
>>> from tasks import add
>>> add.delay(1,1)
# Out: AsyncResult: 83459233-ce54-40ed-a2a8-ee0d60768006
上記の失敗をしました。誰も同じ問題を抱えていますか？
編集: ここに私の tasks.py がチュートリアルからコピーされています。
from celery import Celery
celery = Celery('tasks', broker='amqp://guest@localhost//')
@celery.task
def add(x, y):
return x + y