celerybeat

15熱

1答えて

セロリビットが単一の障害点になるのを回避する

セロリ/ rabbitmq展開の単一障害点であるセロビットを回避するための推奨されるソリューションを探しています。私はこれまでにウェブを検索することで意味をなさないものは見つけられませんでした。 私の場合、1日1回のタイムスケジューラは、半日以上実行できる一連のジョブを開始します。 celerybeatインスタンスは1つしか存在できないため、実行中のサーバーやサーバーに何か問題が発生した場合、重要

celery celerybeat 2012-02-15

---

4熱

4答えて

セルラービートで一度に1つのタスクしか実行されないようにする

セロリビットを使用して1分に1回実行するタスクがあります。それはうまく動作します。しかし、場合によっては、タスクの実行に2分の時間がかかり、実行に数分かかることがあります。これは物事を混乱させる競合状態に繋がります。 私の仕事は正しく動作するように修正できますが、セロリーにはこれを確実にするための組み込み方法があるかどうかを知りたかったのです。私の大雑把なGoogle検索とRTFMでは結果が得られ

python celery celerybeat 2011-06-23

---

37熱

4答えて

どのように動的にセロリ（celerybeat）に定期的にタスクを追加/削除する

私は次のように定義された関数がある場合： def add(x,y): return x+y を動的にセロリPeriodicTaskとしてこの機能を追加して、それをキックオフする方法はありますランタイム？私は（擬似コード）のような何かを行うことができるようにしたい： some_unique_task_id = celery.beat.schedule_task(add, run_eve

python celery celerybeat 2012-04-17

---

11熱

2答えて

セロリとDjangoでセロリートエントリをプログラムで生成する方法

エントリが追加されたときにセロビートエントリをプログラムで生成し、セロビットを再同期できるようにしたいと考えています。ドキュメントhere状態が By default the entries are taken from the CELERYBEAT_SCHEDULE setting, but custom stores can also be used, like storing the ent

django celery django-celery celerybeat 2012-03-03

---

1熱

1答えて

有限のセロリビートタスク

私はサードパーティのAPIと統合されたプロジェクトでCeleryを使用しています。処理のためにファイルをサービスに送信する必要があります。ファイルを送信した後、処理が完了するまで10秒ごとに処理のステータスを要求する必要があります。 メインタスクは、サブタスクを処理して処理の状態をチェックします。私はこれらのサブタスクが有限のセロリビートタスクのように動作するようにしたいと思います。私はサブタスク

python django rabbitmq celery celerybeat 2012-03-09

---