セロリーadd_consumerが呼び出された後にワーカーがタスクを消費しない

Question

Celery（RabbitMQをバックエンドMQとしている）を活用して、さまざまなキューからさまざまなフレーバのタスクを実行したいと考えています。 1つの要件は、特定のキューからの消費者（作業者による）が一時停止して再開する能力を持つ必要があることです。

セロリは、this capabilityと表示されており、add_consumerとcancel_consumerと呼びます。特定のワーカーの待ち行列からタスクの消費を取り消すことができましたが、従業員にadd_consumerを呼び出すことで、消費を再開させることはできません。 The code to reproduce this issue is provided here。私の推測では、celeryconfigの中で提供されるパラメータや、ワーカーを起動する際の引数を使用して、何らかのパラメータが欠落している可能性がありますか？

これについていくつか新鮮なペアを取得することは素晴らしいことでしょう。 add_consumerやGithubに関するStackoverflowに関する議論はあまりありません。だから私は、ここにいくつかの専門家が彼らの思考/経験を共有して欲しいと思っています。

-

私は、以下の実行しています：あなたは、キューから再開するには

のWindows OS、RabbitMQの3.5.6、アーラン18.1、Pythonの3.3.5、セロリ3.1.15

Answer 1

をキュー名とターゲットワーカーを指定する必要があります。ここでそれを行う方法です。ここで

app.control.add_consumer(queue='high', destination=['celery@asus']) 

がadd_consumer署名あなたの場合

def add_consumer(state, queue, exchange=None, exchange_type=None, 
      routing_key=None, **options): 

で、あなたはとてもhigh状態に渡さなっていると、キューが空である

app.control.add_consumer('high', destination=['celery@high1woka']) 

と呼んでいます。だから、再開することはできません。