celery apply_async 為執行任務方法 提供 關鍵字 傳遞參數

 

 

 task_fun 是需要執行任務的方法，參數自定義， 通過 kwargs 將task_fun(key1, key2) 方法需要的 key1 key2 參數通過 關鍵字參數 傳過去：

task_fun.apply_async(kwargs={'key1': value1, 'key2': value2})

 

 也可以通過 args 傳遞 位置參數：

task_fun.apply_async(args=[value1, value2])

 

注意在只有一個參數要傳時 需要寫成列表的形式：

task_fun.apply_async(args=[value1, ])   # 需要加上逗號！