django-celery

    -2

    1答えて

    私はdjangoコードで現在実行中のバックグラウンドプロセスのステータスを持っていないので、私はできません。 要求:そこから私はセロリのバックグラウンドタスクの状況を知っているとhtmlページをレンダリングする必要が @task_success.connect def task_sent_handler3(sender=None,result=None,**kwargs): # inf

    0

    1答えて

    セロリによって提供されるタスクイベントを使用してタスク引数を取得したい。 私はバックエンドとブローカー(シリアライザとしてのピクル)としてredisを使用しています。ドキュメントによると、task-receivedハンドラを聞いてこの情報を得ることができます。ここではargsが読み込まれます。 私が直面している問題は、小さなデータ入力の場合、これは期待どおりに機能します。大きな入力(バイナリファイ

    0

    1答えて

    )セロリのキュー(rabbitmq)の統計情報を取得しようとしています。私はcelery.app.control.Inspect()。stats()APIを使用しています。私はウェブサーバー上でこれをやっている、私は一度だけ統計を得ることができます。ページをリフレッシュすると「[Errno 104]接続がピアによってリセットされました」というエラーが発生しました。どうすればこれに対処できますか?

    1

    1答えて

    私はDjango + Celery + RabbitMQを実行しています。いくつかのタスク名を変更した後、私はDjango Celery BeatのPeriodicタスクテーブルからこのキーを使ってタスクを削除し、Celeryワーカーを再起動した後でも、 "未登録タスク" KeyErrorsを取得し始めました。 Celery/RabbitMQ tasks are persistentが判明しました

    1

    1答えて

    私はDjango + Celery + RabbitMQを実行しています。いくつかのタスク名を変更した後、私はDjango Celery BeatのPeriodicタスクテーブルからこのキーを使ってタスクを削除し、Celeryワーカーを再起動した後でも、 "未登録タスク" KeyErrorsを取得し始めました。 running with the --purge option以降であってもpersi

    1

    1答えて

    celeryプロセスで動的なDjangoモデルを作成しています。 celeryを使用せずにこれらのモデルを作成したとき、それらは管理パネルに表示されましたが、celeryでプロセスを実行すると、モデルは管理ページに表示されません。 makemigrationsを実行すると、新しく作成されたモデルが認識されるため、モデルが作成されていることが分かります。私のコードは次のようなものです: @disab

    0

    1答えて

    私はDjangoアプリでセロリを使用しています。私は、特定のユーザーがアプリケーションを実行するために使用しています。特定のユーザーデプロイヤーでdjangoサーバーを実行できますが、そのユーザーと一緒にセロリプロセスを実行することはできません。 rootユーザーでセロリを起動します。だから、そのユーザープロファイル(〜/ .bashrc)から環境変数を使用することはできません。セロリの 構成:ジ

    0

    2答えて

    多くのアイテム(〜100)ですべてを一度に見るのではなく、(時間がかかる)apiにクエリを実行したい。代わりに、私はクエリの間に少し遅延が欲しいです。 私が現在持っていることは、クエリの上に非同期で繰り返し処理を実行し、各反復の後にいくつかの時間を待ってますタスクです:私の質問は、それらの要求の倍数が入って来たときに、第二の意志、ある @shared_task def query_api_mul

    0

    1答えて

    私はdjango、セロリとrabbitmqに問題があります。 セロリを使用してFCMデバイスにメッセージを送信しますが、セルラーサーバーを再起動するまでセロリがそのFCMコマンドを実行してメッセージを送信しないという問題があります。 セロリを再起動しても同じことをやり直すと、すべてのアクションをやり直してから再起動する必要があります。 例コード: from __future__ import ab

    0

    2答えて

    タスクが最大再試行回数(on_failure)に達したときに何が起きるかをオーバーライドするために、カスタムCeleryタスククラスを作成しています。タスクが失敗した場合、ユーザーモデルのステータスを更新する必要があります。以下は は私のカスタムタスククラスです: class ReadyTask(Task): def run(self, user): try: