私は約10-15秒の実行にかかるAPIを呼び出すセロリタスクを実装しようとしています。 APIを呼び出した後、http-getを使用して結果をポーリングする必要があります。今私は2秒ごとに結果を得たいと思っています。つまり、2秒間労働者が自由になることを意味します。その特定の労働者がその期間無料であることをどういうわけかセロリに伝えることはできますか? 自分自身を明確にしていないかどうか教えてください。Python-ある期間、プログラマチックにセロリの労働者を無料にすることはできますか?
答えて
セロリタスクを遅延させる方法は2つあります。
1st:
>>> tomorrow = datetime.now() + timedelta(days=1)
>>> add.apply_async(args=[10, 10], eta=tomorrow)
2nd:
>>> result = add.apply_async(args=[10, 10], countdown=3)
>>> result.get() # this takes at least 3 seconds to return
出典:https://ask.github.io/celery/userguide/executing.html#eta-and-countdown
これは、** add **を実行している作業者が次の3秒間ビジー状態になることを意味しません。 –
私はワーカーを解放し、そのコンテキストを保存し、応答がない場合は3秒後に再度実行したいと考えています。例えば、 ** add **に実行するのに1秒しかかからないと言うと、次の2秒間作業員は自由になりますか? –
いいえ、3秒間ビジーではありません。しかし、3秒後に実行されます。 – AceLearn
- 1. セロリは、労働者
- 2. セロリ労働者を別々のマシンにセットアップする方法は?
- 3. 労働者なしでセロリの仕事を実行する
- 4. セロリの労働者でテストを実行する
- 5. 異なる値を持つ異なるセロリ労働者を初期化する
- 6. スーパーユーザーがセロリの労働者を走らせる方法は?
- 7. セロリの労働者が死ぬと、仕事は再試行されますか?
- 8. セロリ「労働者-N」PID:XXXXは、私は私のtasks.pyファイルでhmmlearn
- 9. セロリの労働者のmongodbに正しく接続する方法は?
- 10. セロリの労働者からTensorFlowの応答がありません
- 11. 私のサイドキック労働者のIDを労働者の中に入れることはできますか? sidekiqのログファイルに
- 12. エラー502悪いゲートウェイNginxとセロリの労働者
- 13. セロリ花は一部の労働者を示していない?
- 14. サービス労働者は、これは私のサービスワーカーであるhtmlファイル
- 15. ヘロクの労働者を殺すには?
- 16. 同じ労働者を使ってセロリを再試行する方法は?
- 17. Pythonのセロリ - 労働者を無視し、私は次のコマンドを使用してい
- 18. WPFの背景の労働者は、労働者オブジェクト
- 19. どのように私は、APIで異なるコードベースとセロリを使用することができますし、労働者
- 20. 労働者が
- 21. セロリ複数の労働者が1つのキューを持っています
- 22. ガンコンの労働者と労働者のつながりの違いは?
- 23. セロリの労働者であっても、私はRabbitMQのキューには何のメッセージを持っていない
- 24. は演算子に割り当てることができません - python(時間外労働時間)
- 25. 時間をかけて労働者を失うことを避ける
- 26. ドッカーの群れまたは牧場経営の牛のセロリ労働者
- 27. 労働者のデザインパターン
- 28. スパークストリーミングでは、私は労働者にRDDを作成することができます
- 29. 私がセロリの労働者で働いているかどうかをどのように検出できますか?
- 30. 労働者からの要請は、サービスワーカーを通じて代理を受けることができますか?
あなたは2秒のタスクを遅らせたいと言って意味ですか? – AceLearn
はい。そのとおり。 –