名字：Names
每一个任务都必须有一个唯一任务名称。 如果没有指定任务名称，装饰器会根据当前任务所在的模块以及任务函数的名称进行生成一个： 设置名称案例：
1
>>> @app.task(name='sum-of-two-numbers')
2
>>> def add(x, y):
3
... return x + y
4
5
>>> add.name
6
'sum-of-two-numbers'
Copied!
最好的做法是将模块名称作为任务名称空间，如果有一个任务与另外一个模块中的任务名称相同，这样就不会发生的冲突。
1
>>> @app.task(name='tasks.add')
2
>>> def add(x, y):
3
... return x + y
Copied!
可也通过调用任务的
.name 属性来进行获取任务名称：1
>>> add.name
2
'tasks.add'
Copied!
在案例中我们指定的任务名称为
task.add，如果该任务函数在 task.py 文件中时自动生成任务与我们指定的任务名称相同：tasks.py：
tasks.py
1
@app.task
2
def add(x, y):
3
return x + y
Copied!
1
>>> from tasks import add
2
>>> add.name
3
'tasks.add
Copied!
自动命名和相对导入
相对导入和自动命名兼容不是很好，如果导入方式为相对导入吗，建议明确设置名称。
绝对导入
Python 2 可以通过在每个模块中的顶部添加：
1
from __future__ import absolute_import
Copied!
使用之后会强制使用绝对导入，使用相对名称的任务不会出现问题。 绝对导入时 Python 3 默认的导入方式，如果开发使用的是 Python 3 就不需要写入以上代码。
例如，如果客户端导入模块
myapp.tasks 为 .tasks，职程（Worker）需要将模块导入为 myapp.tasks，生成的名称不会匹配，可能会出现 NotRegistered 错误信息。在使用 Django 和
project.myapp-style 在 INSTALLED_APPS 命名时也会出现这种情况：1
INSTALLED_APPS = ['project.myapp']
Copied!
如果以project.myapp的名称安装应用程序，则任务模块将作为project.myapp.tasks导入，因此必须确保始终使用相同的名称导入任务：
1
>>> from project.myapp.tasks import mytask # << GOOD
2
3
>>> from myapp.tasks import mytask # << BAD!!!
Copied!
在第二个案例中由于导入的模块不同，职程（Worker）和客户端会导致任务的命名不同：
1
>>> from project.myapp.tasks import mytask
2
>>> mytask.name
3
'project.myapp.tasks.mytask'
4
5
>>> from myapp.tasks import mytask
6
>>> mytask.name
7
'myapp.tasks.mytask'
Copied!
所以，必须在导入模块的方式一致 同样不应该使用 old-style 进行导入：
1
from module import foo # BAD!
2
3
from proj.module import foo # GOOD!
Copied!
可以使用 new-style 进行导入：
1
from .module import foo # GOOD!
Copied!
在不重构的代码的情况下，可以直接指定名称不依赖自动命名来进行使用：
1
@task(name='proj.tasks.add')
2
def add(x, y):
3
return x + y
Copied!
更改自动命名
4.0版中的新功能。 在某些情况默认的自动命名很合适。在许多不同的模块中有很多任务：
1
project/
2
/__init__.py
3
/celery.py
4
/moduleA/
5
/__init__.py
6
/tasks.py
7
/moduleB/
8
/__init__.py
9
/tasks.py
Copied!
如果使用自动命名，每一个人都会生成一个名词，例如
moduleA.tasks.taskA、moduleA.tasks.taskB、moduleB.tasks.test等。可以通过重写 app.gen_task_name() 进行修改默认的所有任务名称中的 tasks 。基于刚刚的例子，稍微修改(celery.py)：1
from celery import Celery
2
3
class MyCelery(Celery):
4
5
def gen_task_name(self, name, module):
6
if module.endswith('.tasks'):
7
module = module[:-6]
8
return super(MyCelery, self).gen_task_name(name, module)
9
10
app = MyCelery('main')
Copied!
这样所有的任务名称都类似
moduleA.taskA、moduleA.taskB、moduleB.test。警告
需要确保
app.gen_task_name() 是一个函数，同样的输出和输出都必须相同。Last modified 2yr ago