cubicweb-celery 1.1.1

入门指南

在您的 myapp CubicWeb实例中启用‘celery’cube

$ cubicweb-ctl shell myapp
entering the migration python shell
just type migration commands or arbitrary python code and type ENTER to execute it
type "exit" or Ctrl-D to quit the shell and resume operation
>>> add_cube('celery')
>>> ^D

如果需要，在 all-in-one.conf 中配置 broker_url。默认情况下，并且仅当使用postgresql数据库时，将使用 trunk 传输作为代理；请确保已安装。

编写一个任务

from cubicweb_celery import app

@app.cwtask
def ping(self):
    return 'pong'

@app.cwtask
def users(self):
    return [str(x[0]) for x in self.cw_cnx.execute('String L WHERE U login L')]

或者作为一个类

from cubicweb_celery import app

class MyTask(app.Task):
    need_cnx = True  # if false (the default), self.cw_cnx will not be set
                     # before running the task

    def run(self):
        self.cw_cnx.execute('Any X WHERE ...')

然后启动一个celery worker

celery -A cubicweb_celery -i INSTANCE_NAME worker [ --beat ]

然后您可以通过调用它来使worker执行一个任务，例如从一个 操作。您还可以从 cubicweb-ctl shell 运行任务

$ cubicweb-ctl shell myapp
>>> from cubes.myapp.sobjects import ping, users
>>> print ping.delay().wait()
'pong'
>>> print users.delay().wait()
['anon', 'admin']