問題タブ [celery-task]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - タスクの 1 つが失敗するとセロリ チェーンが壊れる
タスクの 1 つが失敗した場合、チェーン全体が壊れる場合、Celery チェーンのポイントは何ですか?!!
私はこのセロリチェーンを持っています:
そして、次のような再試行で workme2 が失敗するようにしました。
celery - Celery サブタスクが最終結果を取得
を使用したメソッドでCelery
あるドキュメントの例を使用しようとすると、最終結果が得られません。add
subtask
でタスクを呼び出すと;
3
ご覧のとおり、代わりに を返します8
。
これらの部分を実行すると、ワーカーにエラーが発生します。なぜそれが起こっているのかわかりません。
結果から8を取得するにはどうすればよいですか?
ありがとう!
celery - セロリマルチが期待どおりに機能しない
これは私のプロジェクトフォルダー構造です
タスクには、というタスクがありますExamineColumns
を使用してワーカーを起動しますcelery worker -A api.jobs --loglevel=Info
正常に動作し、タスクを実行できます。
これは、セロリの検査コマンドの出力です
しかし、マルチモードを試してみると、うまくいきません。実行して実行しようとしています
でも全然始まらない。
なぜ機能しないのかわかりません
python - セロリでは、特定のタスク名のすべてのタスクのタスクステータスを取得する方法は?
セロリでは、特定のタスク名のすべてのタスクのタスク ステータスを取得したいと考えています。そのために、以下のコードを試しました。
今、このコードで空のリストを取得しています。
celery - Celery タスク チェーン/ワーカー リリース
他のセロリ タスクを呼び出すセロリ タスクを作成した場合、下流のタスクが完了するのを待たずに親タスク/ワーカーを解放できますか?
状況: 次の API 呼び出しのデータと引数を返す API を使用しています。API の背後にあるすべてのデータをデータベースに入れたい。私の現在の方法は、バッチが動作するように API をクエリし、いくつかのダウンストリーム プロセッサを起動してから、API+処理チェーンを再帰的に再呼び出しすることです。これにより、ワーカーが子の結果を気にしない場合、すべての再帰 API 呼び出しが完了するのを待っているワーカーがロックされるのではないかと心配しています。
擬似コード:
ここから、上記は非常に悪いことに近いことを理解しています。API 内のすべてのデータが処理されるまで、processList() を処理するワーカーをロックしたくありません。ダウンストリーム タスクを開始して親ワーカーを解放する方法、またはワーカーをロックしないように上記をリファクタリングする方法はありますか?
テストの結果、ワーカーは実際には次のようにロックされていることがわかりました。
python - セロリ ワーカー エラー: ImportError セロリという名前のモジュールがありません
セロリ ワーカーを起動しようとすると、インポート エラーが発生します。問題が何であるかわかりません。どんな助けでも大歓迎です。
私のプロジェクト:
私は呼び出してアプリケーションを実行しようとします:
ここのすべての手順に従いました - http://docs.celeryproject.org/en/latest/getting-started/next-steps.html#about-the-app-argument
トレースバック:
ここに私のcelery.pyがあります
python - セロリのインポートエラー
これは私が実行しているコードです:
上記のコードを実行すると、次のエラーが表示されます。