Django-celery 安裝.介紹及使用(2)

排程及interval管理 進入admin後台




簡簡單單就可以設定排程 不過Task在選擇上面必須要有@task register過的才可以 subtask 於主

task執行結束後執行 並且繼承主task return 值 可快速的用來多重task的執行並且按照順序 

實作、

task.py

@task()
def count(number1, number2):
    print(number1, number2)
    return (number1 + number2)

執行:

count.apply_async((1, 1), link=count.s(10))

結果:

如何透過handler來掌握task執行結束時通知並且do something? 方法、 透過抽象類別來做

handler機制 不用註冊task就可以調用base的class


task.py

class CallbackTask(Task):

    abstract = True

    def on_success(self, retval, task_id, args, kwargs):
        do-something
        .
        .
        print('on success')

@task(base=CallbackTask)
def count(number1, number2):
    print(number1, number2)
    return (number1 + number2)

則結果會於當主要程序執行完後,進入on_success