問題タブ [flower]

私は celery 3.1.11 と flower 0.6.0 を実行しています。

そのように構成されたセロリアプリケーションがあります。

次のコマンドを使用してセロリ ワーカーを実行します。

ワーカー出力で使用可能なタスクの完全なリストを確認できます。

次に、次のコマンドでフラワー サーバーを実行します。

現在、Flower REST API を介して新しいタスクを投稿しようとすると、「不明なタスク TASK_NAME」というエラー メッセージとともに 404 エラーが発生します。

flower API ハンドラーに pdb ブレークポイントを設定しました。リクエストが処理されるときに使用できるタスクは次のとおりです。

利用可能なタスクがないようです。ただし、async_apply()シェルで task メソッドを使用すると、worker によってタスクが実行されます。

私が間違っていることは何か分かりますか？ありがとうございました！

編集: セロリ 3.0.19 とフラワー 0.5.0 を使用している場合、一見うまく動作しません。

https://github.com/jorillallo/celery-flower-herokuの指示に従って、Flower celery 監視アプリを Heroku にデプロイします。

アプリを構成してデプロイした後、heroku ログに次のように表示されます。

.datそこにある付録に注目してください。どこから来たのかわからない、DATABASE_URL環境変数に存在しない。

なお、上記の誤差は flower 0.7 のものです。また、0.6 をインストールしてみました。これにより、さらに進んでいます (つまり、DB が正しく認識され、接続が確立されます)。しかし、flower が起動すると、次の警告が表示されます。

ブラウザに花をロードすると、いくつかのタブが表示されますが、データはありません。

これらの問題を解決するにはどうすればよいですか?

タスクが失敗したときに電子メールアラートを送信するようにセロリを構成するにはどうすればよいですか?

たとえば、3 つ以上のタスクが失敗したとき、または 10 個以上のタスクが再試行されたときに、Celery に通知してもらいたいとします。

セロリやユーティリティ（花など）を使用することは可能ですか、それとも独自のプラグインを作成する必要がありますか?

サーバーでFlowerを実行してCeleryおり、タスクは問題なく実行され、Flower UI 内で監視できるように正しく登録および更新されていますが、ワーカーまたは Flower 自体を再起動しても、ワーカーのステータスは常に問題ではありません。ファイル (オプションで指定) は空なので、エラーも何もありません。Offline--log_file_prefix

私が見ることができる唯一のことは、クロム開発ツールが以下に示すように Websocket Handshake エラーを表示することです: とメッセージCAUTION: Provitional headers are shown.

Websocket ハンドシェイクを成功させるには、サーバーがUpgrade: websocketおよびヘッダーで応答するようにする必要があることを読みました。Connection: upgrade私はApacheを使用しています。次に、次のように指定してみました/etc/apache2/sites-enabled/mysite.conf：

しかし、うまくいきませんでした。

誰もこのエラーの手がかりを持っていますか? さらに情報が必要な場合はお知らせください。

ありがとう！！

Celery、Django-Celery、Kombu、Flower をインストールしました。

セロリフラワーは元気に監視中。ワーカーをシャットダウンすることはできますが、再起動することはできません。

花の反応:

1 つのサーバーに複数のプロジェクトがあり、BROKER_URL が異なるセロリ パッケージを使用しています。Flower では、コマンド オプションとして 1 つの BORKER_URL を使用できます。

すべてのブローカーに対して 1 つのフラワー プロセスを実行するにはどうすればよいですか?

これと同様の問題があります: 新しいタスクを投稿すると、Celery Flower で「不明なタスク」エラーが発生する

ただし、以前の問題で言及された修正が既に行われている flower 0.7.3 を実行しています。花をロードすると、次のように表示されます。

しかし、POST が失敗したことがわかるように、次のように投稿しようとしています。

これが私がCeleryを実行している方法です: celery -A myapp worker --loglevel=info

そして、次のように別のプロセスで花を実行しています: flower --conf=src/crossbar/flowerconfig.py

async-apply を send-task に置き換えると、200 が返されますが、セロリ コンソールでは次のエラーが表示されます。

OK、受け入れられるコンテンツのリストに「pickle」を追加すると、シリアル化エラーが発生しなくなりました。ただし、花はまだ私のタスクを認識していないため、async-apply は機能しません。私はセロリアプリを介して初期化しているのではなく、flowerconfig.pyを使用しているため、flower -Aアプリを機能させることができませんでした。それらを花で登録する適切な方法は何でしょうか?

セロリを使用していくつかのタスクを処理しています。アクティブなタスクやスケジュールされたタスクの数などを確認できますが、失敗したタスクを確認する方法が見つかりません。Flower はステータスを表示しますが、タスクが開始されて失敗したときに実行されていた場合のみです。失敗したすべてのタスクを取得するコマンドはありますか (STATUS: FAILURE)?

タスクが作成されたときのタスクIDを持っています。しかし、それらは何百万もあります。なので、タスクIDで確認する方法があっても1つずつ確認することはできません。しかし、そのようなコマンドがあれば教えてください。

花、セロリの監視ツールを設定しようとしています。これは全体的に問題なく動作しますが、ブローカー タブの下に何も表示されません。「workers」、「tasks」、「monitor」の下にあるものが表示され、グラフが更新されています。私は花を始めるために以下を使用しています:

関連するエラー メッセージは次のとおりです: ブローカー情報を取得できません: 401 クライアント エラー: 権限がありません

http://:15672/ から、ユーザー名 guest とパスワード guest を使用して、RabbitMQ 管理にログインできます。

ブローカータブの下にメッセージが表示されない理由について何か考えはありますか?

私のコードには、定義済みのセロリタスクがあります。my_proj.tasks.my_celery_task

(アプリケーション経由ではなく) コマンドライン/HTTP リクエストを介してタスクをアクティブ化したいと考えています。

ドキュメントを検索しました (saw flower および curl オプション) が、定義済みのタスクを呼び出す実際の良い例はありません。これを達成する方法は？