celerybeat

5熱

1答えて

セルロービートにこのコマンドを実行すると、 [2013年6月27日02：17：05936：INFO/MainProcess] Celerybeat：開始しています... [2013年6月27日02：17：05937：INFO/MainProcess]書き込みエントリ... [2013-06-27 02：17：08,711：INFO/MainProcess] DatabaseScheduler：スケ

2熱

2答えて

Celeryビートにスケジュールされたタスクを動的に追加する方法

Celery ver.3.1.23を使用して、スケジュールされたタスクをセロリのビートに動的に追加しようとしています。私は1人のセロリ労働者と1人のセロリがインスタンスを動かすビートを持っています。標準のセロリタスクをトリガするy task.delay（）を実行しても問題ありません。構成の設定としてスケジュールされた定期タスクを定義すると、セロリがそれを実行します。しかし、私が必要とするのは、

2熱

1答えて

セロリの作業員とセロリを糸として叩く

私はセロリを使っていくつかの時間をトリガーにした仕事をしています。通常のコマンドラインメソッドを使用すると、簡単にタスクを生成して実行することができます。このために私はデーモンを2つ作成しなければなりません。一つはセロリのためのもので、もう一つはセロリのためのものです。セロリは時間トリガータスクの作成と実行という私の問題を解決しますが、私のシステムには2つの追加デーモンが必要です。私はすでにデー

0熱

1答えて

djangoセロリでセロリインスタンスを停止せずにセロリで新しいタスクを追加する方法は？

@shared_task def forgot_email(subject,user_cipher,key_cipher,to): print "comes here in the mail" try: email_content = {'user_cipher':user_cipher,'key_cipher': key_cipher} messag

0熱

1答えて

同時にセロリのタスク間でOracleデータベース接続を共有する

私はPython2.7、Celery、cx_Oracleを使ってOracleデータベースにアクセスしています。私は多くのタスクを作成します。各タスクは、cx_Oracleを介してクエリを実行します。このタスクの多くは同時に実行されます。すべてのタスクが同じデータベース接続を共有する必要があります。 1つのタスクのみを起動すると、クエリが正しく実行されます。しかし、いくつかのクエリを起動すると、次

1熱

1答えて

長時間実行されているタスクの後ろにスタックすると、Celerybeatの定期的なタスクが複数回実行される

私はdjangoプログラムでセロリー3.1.17とredisをブローカーバージョン3.0.2として使用しています。 Ubuntu 14.04で動作しています。設定でが、私は同じようCELERYBEAT_SCHEDULE定義：ここで CELERYBEAT_SCHEDULE = { 'task1': { 'task': 'api.tasks.exsample.task1',

1熱

1答えて

エラー時に定期セロリタスクを再試行しないようにします。

celery scheduleのタスクが1分ごとに実行され、はエラー時に電子メールを送信します。エラーがある場合、データベースの利用不能などの永続性がより高いため、メールボックスに似た電子メールがスパムされます。考えられる回避策はありますか？プログラムは、データベースがコードがコンセプトのほんの一例であるオンラインに戻ったら、それはすでにFalseに戻って設定されますアラームメールを、送信され

6熱

1答えて

セロリビート設定を動的に変更する

実行中に特定のタスクの設定を変更するようセロリビートに指示する方法はありますか？これの有用性は、最もよくこの例で説明します。私は値を30秒ごとにチェックする定期的なタスクを持っています。場合によっては、（私が予測できない）外部トリガーに基づいて、このタスクでポーリング頻度を10秒に増やすことが必要になります。これは管理可能な方法で実行可能ですか？あなたがこれを見つけるschedules.py

9熱

1答えて

セロビットをクロノスに交換する

どの程度成熟していますかChronos？ Celery-beatのようなスケジューラーの代わりに実行可能なのでしょうか？現在、私たちのスケジューリングは、「未処理」イベントをチェックし、期限が過ぎている場合にそれらを起動する定期的な「ハートビート」タスクを実装しています。これを定義するためにpython-dateutilのルルールを使用しています。 Chronosは、1）ハートビートスケジュール

5熱

1答えて

エラストンBeanstalkのDjangoでの定期的な作業（おそらくセロリの拍子で）

私はElastic BeanstalkでDjangoアプリケーションの毎日のタスクを設定しようとしています。セロリのビートはDjangoの定期的なタスクのための解決策ですが、負荷分散された環境には適していないため、これを設定するための受け入れられた方法はありません。私は、1つのインスタンスのみを実行するためにleader_only = Trueでセロリのビートを設定するなどのいくつかの解決策を見