問題タブ [celery-task]

django-celery をインストールし、ワーカーサーバーを起動しようとしましたが、機能が実装されていないという OSError が表示されます。VPS で CentOS リリース 5.4 (Final) を実行しています。

私は完全にめちゃくちゃですか、これを解決する簡単な方法はありますか?

Celery キューから (rabbitMQ を使用して) 実行されているタスクを中止できるようにしたいと考えています。を使用してタスクを呼び出します

ここで、AsyncBoot は定義済みのタスクです。

タスク ID (返される長い文字列であると仮定) を取得しapply_asyncてデータベースに保存することはできますが、abort メソッドを呼び出す方法がわかりません。Abortable タスク クラスでメソッドを中止可能にする方法はわかりましたが、タスク ID 文字列しかない場合、タスクで .abort() を呼び出すにはどうすればよいですか? ありがとう。

Celery のAbortableTask機能を使用しようとしていますが、ドキュメントの例がうまく機能していないようです。与えられた例は次のとおりです。

と

ただし、次のエラーが表示されます。

私は何を間違っていますか？

2 つのセロリ ワーカーがあり、ワーカー 1 にはタスク A と B、ワーカー 2 にはタスク A、B、および C があります。タスク C を送信すると、タスク C を持つセロリ ワーカーでは実行されないようです。ワーカー 2 だけがタスク C を割り当てられるようにする方法はありますか?

タスク（task_id）がまだセロリで処理されているかどうかをテストするにはどうすればよいですか？次のシナリオがあります。

1. Djangoビューでタスクを開始します
2. BaseAsyncResultをセッションに保存します
3. セロリデーモンを（ハード）シャットダウンして、タスクが処理されないようにします
4. タスクが「デッド」であるかどうかを確認します

何か案は？セロリによって処理されているすべてのタスクを検索し、私のものがまだそこにあるかどうかを確認できますか？

私はセロリを始めていますが、すでに開始されているセロリプロセスにモジュールを追加できるかどうか知りたいです。つまり、celeryconfig.pyを介してモジュールを追加する代わりに

ワーカーを開始する前に、ワーカープロセスの開始後に、後で何とかしてadditional_moduleを使用できるようにします。

前もって感謝します。

私はDjangoとCelery+RabbitMQを使用して、ユーザーがアップロードしているビデオのビデオ変換タスクを作成しています。これで、セロリにクエリを実行してステータスを取得する方法がわかりました。私の質問は、各タスクに関連付けられたtask_idをどこに保存するかですが、モデルまたはdjangoのキャッシュに保存する必要がありますか？

過去に同様の質問があったことは知っています。たとえば、このスタックオーバーフローの質問ですが、決定的な答えはまだありません。これに対する答えは開発者の好みによって異なることは知っていますが、誰かがさまざまなアプローチの長所/短所について教育できれば、それは素晴らしいことです。

繰り返しになりますが、task_idを使用して、フロントエンドからAJAXクエリを頻繁に実行し、ビデオ変換が完了したかどうかを確認します。

多くのタスクを開始しましたが、完了していないタスク (763 タスク) があり、PENDING 状態ですが、システムは何も処理していません... セロリに task_id を与えてこのタスクを再試行することは可能ですか?

add は celery doc のタスクです。なぜ8が得られず、ハングするだけなのか、私はとても混乱しています。

各タスクを知らなくても、保留中のすべてのタスクを削除するにはどうすればよいtask_idですか？