celery

    -1

    1答えて

    呼ば取得されていない私はのようなコードの部分を持っているが class Job(): def start(): from threading import Timer t = Timer(10.0, self.cancel) t.start() self.status = "Started" submitChildTasks() #---

    2

    1答えて

    セロリのビートタスクに取り組んでいて、タスクが正常に動作しています(スケジュールされた時間に正常に動作しています)私の管理ページにタスクが表示されず、私のPostgreSQLデータベース(ex django_celery_beat_periodictask) 私はここで何が不足していますか? 要件 Django==1.9.7 python==3.5 celery==4.1.0 django-

    0

    2答えて

    「Djangoでの定期的なタスクの作成方法」については、this postのように質問しています。しかし、私はそのポスト(Celerityやcronを中心に)で言及されたオプションからJavascript/jQueryの定期的なタスクを使用することをお勧めします。 私が達成したいのは、毎日特定の時間にタスクを実行することです。 "view.py"から関数を呼び出す。この関数はURLに接続し、ファイ

    0

    1答えて

    私はDjangoアプリを持っており、Celery非同期タスクを追加する必要があります。私は、例えばMY_VARIABLE = 'test'のようなdev.pyの設定変数をタスクに呼びたいと思います。 from django.conf import settings @shared_task def test_task(): return settings.MY_VARIABLE

    1

    1答えて

    私がセロリの仕事を書いたことを想像して、サーバーにコードを書いてみましょう。しかし、サーバーにタスクを送信したいときは、前に書いたコードを再利用する必要があります。 私の質問は、サーバーとクライアントの間でコードを分離する方法があるということです。

    0

    1答えて

    私はKubernetesとGCPのドッカーコンテナでセロリを実行しています。その従業員は最近kill -9を取得し始めました - これはOOMKillerと関係があるようです。 kubectl get eventsにOOMイベントはありません。これは、ポッドがresources.limits.memoryの値を侵入したときにのみ表示されるイベントです。 だから、私の理論は殺さセロリのプロセスは、L

    1

    1答えて

    セリー・インテグレーションと特定のロガーを使用している監視対象の例は、兵士がエラーまたはロガーを受け取っているため動作しません。 とにかく看護師に送るロガーを制御するには? import logging import celery import raven from raven.contrib.celery import register_signal, register_logger_si

    0

    1答えて

    私はセロリのタスクをいくつか持っています。タスクIDを使用してAsyncResultをインスタンス化することによって、別々のプロセスから定期的に状態をチェックしています。 これから、私はタスクの状態を取得します。 hereのようにカスタム結果バックエンドと拡張AsyncResultクラスを実装することで、タスク名も取得できます。しかし、私は各タスクのカスタム表示名を得ることができます。人間が読める

    12

    1答えて

    Celery(RabbitMQをバックエンドMQとしている)を活用して、さまざまなキューからさまざまなフレーバのタスクを実行したいと考えています。 1つの要件は、特定のキューからの消費者(作業者による)が一時停止して再開する能力を持つ必要があることです。 セロリは、this capabilityと表示されており、add_consumerとcancel_consumerと呼びます。特定のワーカーの待

    0

    1答えて

    を持っていない私は、以下のコマンドを使用してセロリを起動しよう: celery -A converter worker --loglevel=info が、それは動作しません。 私converter.pyは次のとおりです。 from __future__ import absolute_import, unicode_literals from celery.task import task