这个设置开启后, 一个在task_queues中还未定义的命名队列会被自动创建。这让简单的路由任务变得很容易。...定义一个新路由器时,你所要做的就是定义一个函数,带有签名 (name, args, kwargs, options, task=None, **kw):
def route_task(name, args...:
task_routes = (route_task,)
Router 函数也可以通过名字添加:
task_routes = ('myapp.routers.route_task',)
对于简单的任务名...,在第一个返回真值的路由器处停止,选择它作为任务的最终路由。...你也可以在一个序列中定义多个路由器:
task_routes = [
route_task,
{
‘myapp.tasks.compress_video’: {
‘queue’: ‘video’,
‘