django-celery

    11

    2答えて

    前回の実行が完了する前にCeleryが定期的なタスクを実行しないようにするにはどうすればよいですか? 共通のデータベースサーバーにリンクされ、Celeryタスクを実行しているサーバーのクラスタを持っていて、各サーバーが同じタスクを同時に実行することがあります。これは、痛みを伴う微妙な方法でデータを破壊している多くの競合状態を引き起こしています。 私はCelery's docsから読んできましたが、

    0

    1答えて

    私はこれを使用しようとしましたsolutionしかし成功なし。タスクを実行する日を指定するにはどうすればよいですか?私のソリューションは、私はTUがジャンゴ・セロリとそれを実行してみてください class DayOfMonth(schedule): def __init__(self, day=1): self.day = day def is_due(self

    6

    2答えて

    マイセロリログが一貫し(あまり)長いエラーメッセージを切り捨てログメッセージを切り捨て、次のように:回答 [2012-04-08 04:53:10,084: INFO/MainProcess] Task mainapp.tasks.async_submitter[2df2fe93-156b-4944-9ecf-c55ba53e8aaa] succeeded in 0.190640926361s:

    3

    1答えて

    これは初めてのセロリですので、これは本当に簡単な質問かもしれません。私はtutorialに従っています。私はBROKER_URL = "amqp://guest:[email protected]:5672/"を自分の設定ファイルに追加しました。私は私のアプリに簡単なタスクを追加しました。今、私は=設定はWindowsマシンcelery-django can't find settingsのために

    1

    2答えて

    これはCeleryの使用目的をすべて破っていることは分かっていますが、結果が返されるまでブロックする機能はありますか? MyTask.delay(some_arg="foo")の代わりに、結果をフェッチしてブロックし、結果を返すことができるactual_result = MyTask.dont_delay(some_arg="foo")を呼び出すことができますか?

    0

    1答えて

    私はセロリのタスクによって質問されるハードウェアセンサーノードを分散させました。各センサノードには、最新の読み取り値と設定データを保持するオブジェクトが関連付けられています。 1つのsensornodeを調べるセロリタスクを複数回実行することは決してありません。しかし、以前の要求から依然として作業が行われている間に、ノードに問い合わせるようにリクエストが来る可能性があります。 セロリドキュメントの

    17

    2答えて

    私はちょうどdjango-celeryを使用し始めています。私はデーモンとしてceleryd runningを設定したいと思います。しかし、instructionsは、一度に1つのサイト/プロジェクトに対してのみ設定できることを示唆しています。 celerydは複数のプロジェクトを処理できますか、それとも1つしか処理できませんか?この場合、各設定に対して自動的に起動するようにcelerydを設定す

    9

    1答えて

    ... def testview1(request): for i in xrange(0,1000): result = add.delay(i, 4,task_id = i) print result.info #value = result.wait() return HttpResponse("Done") @task() d

    1

    2答えて

    私は現在プロジェクトに取り掛かっています。非同期タスク処理と、ある種のメッセージキューを早期に統合して、すぐにスケールアップすることができますメッセージキュープロセッサーサーバーをクラスターに追加する。 私はCeleryを訪れ、私の目を引っ張った。それはDjangoと非常によく統合されているので、私はかなり良いサポートを得るだろうと思った。私はどのように起動するのかは分かりません。多くの設定が必要

    3

    2答えて

    セロリ(より具体的にはジャンゴ・セロリ)を使い始めたばかりで、まだ私はそれに精通していません。 私は、各タスクが完了するのに約3分かかり、作業者が遠隔で実行されるタスクを送信するアプリケーションを開発しています。 (重い処理ではなく、ウェブクロールのものですが、それは無関係です)。 タスクを送信すると、結果を取得するための参照が取得されます。 >>> result = task_name.dela