2016-07-08 3 views
0
from celery import Celery 

app = Celery('tasks', backend='amqp://[email protected]', broker='amqp://[email protected]//') 


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

セロリのタスクを正常に送信できましたが、タスクの結果を取得しようとすると戻ってきません。私はこれが外部IPに設定されているバックエンドのIPによって引き起こされたと思うし、セロリはそれを尊重していません。上記なぜローカルホストではないipを指すセロリバックエンドが機能していないのですか?

- ** ---------- .> transport: amqp://guest:**@192.168.99.100:5672// 
- ** ---------- .> results:  amqp:// 

私は「セロリ-A workers.tasks労働者--loglevel =デバッグ」を実行したときに出力され

+0

あなたはゲスト以外の、別のアカウントで試したことがありますか? – cantSleepNow

+0

@cantSleepNowはい私は持っているが、スレッドスイッチは唯一の解決策であるようだ。 –

答えて

0

これは働いていた理由を正確に私は知らないが、それは

実行インクルードをしました--pool =スレッド/ソロスイッチを使用してコマンド

セロリ-A proj.tasks労働者-l情報--pool =スレッド-n W1

関連する問題