django-post-request-task 0.5

用法

from celery import Celery
from post_request_task.task import PostRequestTask


app = Celery('myapp', task_cls=PostRequestTask)

@app.task
def my_task():
    # If .delay() is called on this task inside a django request-response
    # cycle it will be called once the request is finished, and not before.
    pass

或者，如果您直接使用装饰器

from post_request_task.task import shared_task

@shared_task
def my_task():
    pass

就这样。如果任务在django请求-响应周期之外调用，则它将正常触发。

作为附加功能，如果在请求-响应周期中多次使用相同的参数调用相同的任务，它只会排队一次。

运行测试

$ make testenv
$ make test

默认情况下，测试使用已安装的任何Django版本运行。如果您想为其他版本运行测试，请使用tox。

$ make testenv
$ tox -e 3.7-2.0.x # or any other environment defined in our tox.ini