再配布後にセロリのタスクIDが変更される

Question

celery_task_idという列を持つDjangoモデルがあります。私はRabbitMQをブローカーとして使用しています。モデルオブジェクトをパラメータとして取るセロリ関数test_celeryがあります。今私はセロリのタスクを作成する次のコード行を持っています。

def create_celery_task(): 
    celery_task_id = test_celery.apply_async((model_obj,), eta='Future Datetime Object') 
    model_obj.celery_task_id = celery_task_id 
    model_obj.save() 
    ---- 
    ---- 

セロリ関数の内部で、タスクIDがDBに格納されているものと同じかどうかを確認しています。

@app.task 
def test_celery(model_obj): 
    if model_obj.celery_task_id == test_celery.request.id: 
     ## Do something 

私の問題は、私はタスクが受信され、ログに成功したが、もし条件の内のコードを実行していないされて見ることができる例が多いです。

再配布後にセロリのタスクIDが変更される可能性はありますか？または、他の理由があるかどうか。

Answer 1

推奨事項の1つは、古いデータが含まれている可能性があるため、データベース/ ORMオブジェクトをCeleryタスクに渡すことではありません。タスクを次のように書き換えてみてください。

@app.task 
def test_celery(model_obj_id): 
    model_obj = YourModel.objects.get(id=model_obj_id) 
    if model_obj: 
     if model_obj.celery_task_id == test_celery.request.id: 
      ## Do something