セロリ - 親タスクのIDを記録するには？

Question

ログの種類のバックトレースをログに記録したいのですが、これはできますか？結果には親があり、グラフを出力することもできますが、タスク内の親タスクまたはタスクIDは表示されず、要求自体も表示されません。親のタスクIDを各サブタスクに手動で渡す必要がありますか？

結果：task_idを親と同じ値に設定しても安全ですか？

編集：コード例：理想的に私は、明らかに地元の人々を機能させるにはアクセスできませんログフィルタの内部呼び出しタスクIDを取得したい

@app.task() 
def root_task(arg): 
    if arg: 
     subtask.delay(arg) 


@app.task() 
def subtask(arg): 
    import celery 
    print(dir(celery.current_task)) # get parent task id here? 
    print(dir(celery.current_task.request)) # no parent here either 

ノート、どちらか私のためにありませんのでbind=True。

Answer 1

親task_idを手動で渡す必要はありません。

あなたはこの

@app.task() 
def task1(): 
    return('task1') 

@app.task() 
def task2(): 
    return('task2') 

c = chain(task1.si(), task2.si()) 

のような単純なチェーンを持っている場合は、親タスクID

In [17]: r = c() 

In [18]: r.task_id 
Out[18]: '9c17b0b6-206c-458f-96ca-be23bc20aa9b' 

In [19]: r.parent.task_id 
Out[19]: 'e1376a29-6052-427c-8c8e-b14abcb58477' 

r.parentを見ることができ、必要なすべての属性があります。