celery

    5

    2答えて

    手動トランザクション管理でDjango - Celeryタスクを実行したいのですが、注釈がスタックしないようです。 TypeError: pong() got an unexpected keyword argument 'task_name' で def ping(): print 'ping' pong.delay('arg') @task(ignore_resul

    5

    2答えて

    先週私のローカルシステムでRabbitMQとCeleryをテストした後、実動システムにRabbitMQとCeleryをセットアップしました。 まだ私は約1200のタスクがまだキューに入っているので、私のタスクは生産で実行されていないと感じます。 私はcelerydとcelerybeatのデーモンとWSGI wsgiモジュールへのインポートを行ったCentOS 5.4セットアップを実行します。 私は

    1

    1答えて

    私はバックグラウンドで定期的に実行する必要のある特定のタスクを必要とする動的サイトを配備することを考えています。私が出力する必要があるデータは、厳密にそれらのクエリの結果に依存しています。 ここで問題となるのは、これらのタスクには一定の時間が必要であるということです。 8〜10分:ユーザーがページを尋ねて特定のビューが呼び出され、そのタスクがまだ処理中の場合、すべてが悪くなります。 ここで質問しま

    1

    1答えて

    私は、djangoのセロリ(バージョン2.3.2)を使って複数のシミュレーションをタスクとして実行しています。最初のタスク(setup_simulations)が完了した後、私がしようと @task(priority=1) def setup_simulations(parameters): task_ids = [] for i in range(number_of_sim

    1

    1答えて

    私はdjangoセロリを使ってプロジェクトを開始しています。私は 'djcelery.urls'によって提供されたタスクURLをajax呼び出ししています。 私は、このデータについてのいくつかのことを知っていただきたいと思います: その情報が格納されている ?私のdjangoプロジェクトデータベースのdjceleryテーブルから呼び出されているのですか、それともRabbitMQサーバーに保持されて

    0

    1答えて

    私はpelongoを使って、多くの非同期タスクを実行するためにCeleryも使用するアプリケーションでmongodbにアクセスしています。私はpymongoの接続プールが非同期ワーカー(ドキュメントに基づいて)をサポートしていないことを知っています。 コレクションにアクセスするには、アプリケーションに合った特定のロジックをラップするCollectionクラスが必要です。私はこのラッパーで継承したコ

    8

    3答えて

    私はPython用の分散cronのようなフレームワークを探していて、Celeryを見つけました。しかし、ドキュメントでは、「一度に1つのスケジューラーしかスケジュールされていないことを確認する必要があります。それ以外の場合は、重複するタスクが発生します」とCeleryはスケジュールをローカル・ファイルに保管するcelery.beat.PersistentSchedulerを使用しています。 私の質

    0

    1答えて

    UNIXドメインソケットで動作するセロリなどはありますか?私の現在のホスト(dreamhost)は、IPソケットを受信するサーバーの実行を禁止しているので、ドメインソケットで動作するものが必要です。 明らかに、より簡単な解決法が好まれますが、Pythonクライアントライブラリとドメインソケットサポートを備えたメッセージキューイングソフトウェアが私を務めます。

    20

    5答えて

    私はRabbitMQでCeleryを使用しています。最近、多数の一時的なキューが作成されていることがわかりました。 タスクが失敗したとき(つまりタスクが例外を発生させるとき)、ランダムな名前の一時的なキュー(c76861943b0a4f3aaa6a99a6db06952cなど)が形成され、キューが残っていることを実験したところ、 次のようにrabbitmqadminに見られるような一時的なキューの

    5

    4答えて

    特定の間隔で特定の間隔で実行するタスクをhereから設定することができますが、これはタスク宣言時にのみ行われます。定期的に動的に実行するタスクを設定するにはどうすればよいですか?あなたは、あなたが新しい作成後のX秒のために何かを実行したい例えばD :