celery

    0熱

    1答えて

    セテリにbyteaではなくjsonオブジェクトを返すようにするにはどうすればよいですか？

    これは初めてのPython 3でセロリを使って作業しています。足を濡らすために、ワーカーの結果として「これはこんにちはタスクです」という文字列を返しています。これはPostgresデータベースです。私のデータベースから結果にアクセスすると、Pythonのメモリビューの形式になります。データベース自体には、データ型byteaとしてのcelery_taskmetaの結果カラムがあります（これはCele
    python json postgresql celery 2017-06-11

    1熱

    1答えて

    Django 1.11でセロリの作業者を実行する方法

    バージョン1.7からバージョン1.11.2にDjangoを、バージョン3.1.25からバージョン4.0.1にCeleryをアップグレードしました。 このアップグレードは、私はセロリの労働者を実行することができたの前に、このようにdjango-celeryパッケージを投げる： python manage.py celery worker -Q <my_queue> --app=proj.celery
    python django python-2.7 celery 2017-06-12

    2熱

    1答えて

    は、各ワーカープロセスごとに、またはアプリケーションごとに1回ずつ初期化されたCelery Taskですか？

    私は初期化に時間がかかり、多くのメモリを消費する重い外部ライブラリクラスを持っています。タスクインスタンスごとに最低1回は作成したいと思います。 class NlpTask(Task): def __init__(self): print('initializing NLP parser') self._parser = nlplib.Parser()
    python python-3.x multiprocessing celery celery-task 2017-06-13

    0熱

    1答えて

    Celery-rabbitmqでタスクの依存関係を処理する人

    Celeryの初心者として本当に混乱しています。クライアント（ipython）がCelery Canvasを使用してDAGを送信すると、rabbitmqがメッセージ依存関係を処理する方法についていくつかの入力が必要ですワークフロー）プリミティブ（チェーン、コード、グループなど） A（> B、C） - > D（Diamond DAG）ここでAが最初に実行され、BとCが並行してBとCの出力が使用される
    rabbitmq celery celery-task 2017-06-14

    0熱

    1答えて

    セロリはどのようにタスクの結果をレディスに保存するのですか

    私はPythonとCelery-Redisを初めて使うので、私の理解が間違っていれば修正してください。 TaskClass - - >セロリタスク HandlerClass1, HandlerClass2 - >これらは、PythonのクラスはObjectクラスに拡張されているアプリケーションが作成 がTaskClassが言うdumyTaskインスタンス 私のような構造を有しているコードベースのデ
    python redis celery task-queue 2017-06-16

    1熱

    1答えて

    セロリのタスク

    のためのパラメータとして、それを使用するために、Redisのに文字列のバイトを送信する私はブローカーとしてのRedisを使用してセロリのタスクに文字列内のバイトを送信したいが、私は以下のようにエラー受けています： [2017-06-17 21:27:13,826] ERROR in app: Exception on /endpoint_method [POST] Traceback (most
    python redis celery celery-task binascii 2017-06-17

    1熱

    1答えて

    1つの関数を正常に実行した後に別のタスクを実行する

    私はceleryモジュールを初めて使用しているので、特定の関数の実行後に1つのタスクを実行したい。 tasks.pyを作成 import djcelery djcelery.setup_loader() BROKER_URL = 'amqp://rahul:[email protected]:5672//' CELERY_ACCEPT_CONTENT = ['json'] CELERY_T
    python django celery django-celery 2017-06-21

    -2熱

    1答えて

    CrontabでDjango Celery Nohupを実行

    私はdjangoでいくつかのタスクを実行したいです。私はこれを行うためにセロリを使用しています。通常、私は、タスクを実行するには、次のコマンドを実行します。私は、このたびのcrontabを持つマシンの再起動をしたい source myvirtualenvpath/bin/activate nohup python manage.py celeryd -E -B --loglevel=DEBUG
    python django celery nohup 2017-06-21

    1熱

    1答えて

    デフォルトのセロリーRaabitMQのキュー名

    私はqueue_emailとqueue_pushの2つのキューを作成したdjangoプロジェクトにCeleryとrabbitmqを使用しています。 しかし、RabbitMQのは、デフォルトで作成され、同様にキューを以下ました： celery celery.pidbox celeryev reply.celery.pidbox どのように、なぜこれらのデフォルトのキューが作成されますか？
    rabbitmq celery 2017-06-30

    0熱

    1答えて

    セロリは与えられたETAでタスクの実行を再開しません

    私はPython 3.6でCelery 4.0.2アプリケーションを実行しています。 eta = datetime.datetime.now() + datetime.timedelta(minutes=15) task.apply_async(args=args, eta=eta) メッセージはとても基本的に、アプリケーションがそれを取っている必要があります私のブローカー（RabbitMQ
    python celery 2017-07-02
最新の質問