打破链式操作：Breaking the chain
虽然可以依赖于当前设置的应用程序，但最佳做法是始终将应用程序实例传递给需要它的任何内容。 通常将这种做法称为
app chain，根据传递的应用程序创建一系列实例。 下面的这个实例实不可取的：1
from celery import current_app
2
3
class Scheduler(object):
4
5
def run(self):
6
app = current_app
Copied!
应该将
app 作为参数进行传递：1
class Scheduler(object):
2
3
def __init__(self, app):
4
self.app = app
Copied!
在celery内部实现中，使用 celery.app_or_default() 函数使得模块级别的 API 也能正常使用：
1
from celery.app import app_or_default
2
3
class Scheduler(object):
4
def __init__(self, app=None):
5
self.app = app_or_default(app)
Copied!
在开发环境中，可以通过设置 CELERY_TRACE_APP 环境变量在应用实例链被打破时抛出一个异常：
1
$ CELERY_TRACE_APP=1 celery worker -l info
Copied!
API 发展
从 Celery 诞生， 2009 年就是发生了很大的变化。 例如，可以在开始时调用任何可调用任务：
1
def hello(to):
2
return 'hello {0}'.format(to)
3
4
>>> from celery.execute import apply_async
5
6
>>> apply_async(hello, ('world!',))
Copied!
也可以创建 Task 类来进行配置，覆盖其它行为：
1
from celery.task import Task
2
from celery.registry import tasks
3
4
class Hello(Task):
5
queue = 'hipri'
6
7
def run(self, to):
8
return 'hello {0}'.format(to)
9
tasks.register(Hello)
10
11
>>> Hello.delay('world!')
Copied!
后来，决定传递任意可调用的是一个反模式，因为它使得使用除pickle之外的序列化器非常困难，并且该功能在2.0中被删除，被任务装饰器取代：
1
from celery.task import task
2
3
@task(queue='hipri')
4
def hello(to):
5
return 'hello {0}'.format(to)
Copied!
Last modified 2yr ago
Export as PDF
Copy link