問題タブ [celery-task]

次のコードを実行しようとしています:

しかし、このコードは request_id として None を与えています。サイド セロリ タスク クラスで ID を読み取れない理由を説明してください

しばらくの間、セロリを機能させようとしています。同期的にテストすると、すべての crontab が正常に動作します

しかし、私がするとき

私のcrontabはどれも機能しません。なぜかわからない

注：他のスケジュール間隔も同様に試しましたtime deltaが、同じことが起こります。

したがって、これはcrontabの問題ではなく、セロリマルチの開始方法に何らかの形で関連していると確信しています。

また、 Celery Flowerで見ることができるのでワーカーは正常にオンになりますが、タスクは実行されません。

ログの目的で、セロリ タスクがそれを実行しているワーカーの名前を取得できるようにしたいと考えています。ブローカーに直接クエリを実行するのではなく、タスク内からこれを処理する必要があります。これを行う方法はありますか？それが重要な場合は、RabbitMQ でセロリを使用しています。

ユーザーが登録してからちょうど 48 時間後にメールを送信したいのですが、セロリを使用してこれを達成するにはどうすればよいですか? メールを送信する定期的なタスクを作成する場合、そのタスクを実行する特定の時間を決定する必要があります。送信する必要のある電子メールがあるかどうかを確認するために、毎秒セロリ タスクを実行し続けたくありません。

Celery 結果のバックエンドを追加していますが、タスクを送信するという問題があり、一部は受け入れられますが、一部は受け入れられません。

実行されるタスクと実行されないタスクの両方で、次のログ出力が表示されます。

実行されたものは、次の出力を示します。

実行されていないタスクが上記の行に到達することはありません。

タスクの送信方法:

私のセロリの設定は、次のように報告することから：

私の起動コマンドは次のとおりです。

また、セロリを停止すると、受け入れられなかったタスクがキューから取り出されます。その後、再起動すると、それらを受け入れて実行します。

この動作に関するヘルプは大歓迎です。バックエンドの構成に問題があることは確かですが、問題の切り分けや修正に苦労しています。ありがとう！

私はセロリとジャンゴ全般にかなり慣れていないので、知識不足を許してください。テストを実行していくつかの計算を行い、テストが終了するのを待って、正しい答えが得られるようにします。

ここに私が持っているものがあります:

app/tests.py 内

app/tasks.py で

セロリログでタスクが正常に完了したと表示されていても、状態が保留中から変わることはありません

CELERY_IGNORE_RESULT = False も mainapp/settings.py に入れましたが、これは何もしていないようです。

Django Web サイトを実行していて、Celery を実行したばかりですが、紛らわしいエラーが発生します。コードの構造は次のとおりです。

tests.py で:

tasks.py で:

mainapp/settings.py で:

リスト/タプルによるマストのセロリデバッグコンソールログ：

私が得ているエラーは上記のとおりですAsyncResult(c.id).result: task args must be a list or tuple。これは簡単な解決策のはずですが、そうではありません。リストにすると次のようになります。

それから気が変わって、私にこう言いますAsyncResult(c.id).result: int() argument must be a string or a number, not 'list'

ご想像のとおり、何が問題なのか、私は非常に混乱しています。

編集

タスク.py

tests.py

function.app の出力