Celery集成Pyramid
项目描述
注意:我已经做了最小修改,以便在Python 3.x和Pyramid 1.5上(看似)运行。我没有对这些更改进行广泛测试,但celery工作进程和celerybeat都已启动并开始工作。
入门
=====================
通过在您的.ini中设置包含来包含pyramid_celery,
或通过调用config.include('pyramid_celery').
``` python
pyramid.includes = pyramid_celery
```
现在您可以使用基于类的
``` python
from celery.task import task
from celery.task import Task
@task
class AddTask(Task)
定义 run(self, x, y)
打印 x+y
```
或者基于装饰器
``` python
from celery.task import task
@task
定义 add(x, y)
打印 x+y
```
配置
=====================
所有标准的 celery 配置选项都将生效。请查看 http://ask.github.com/celery/configuration.html
演示
=====================
要查看所有功能,请查看 pyramid_celery_demo,运行 rabbitmq-server 然后执行
``` python
$ python setup.py develop
$ populate_pyramid_celery_demo ./development.ini
$ pserve ./development.ini
$ pcelery ./development.ini worker
```
如果你使用 celery < 3.1,请使用旧的 celery 命令行绑定。
``` python
pceleryd development.ini
```
入门
=====================
通过在您的.ini中设置包含来包含pyramid_celery,
或通过调用config.include('pyramid_celery').
``` python
pyramid.includes = pyramid_celery
```
现在您可以使用基于类的
``` python
from celery.task import task
from celery.task import Task
@task
class AddTask(Task)
定义 run(self, x, y)
打印 x+y
```
或者基于装饰器
``` python
from celery.task import task
@task
定义 add(x, y)
打印 x+y
```
配置
=====================
所有标准的 celery 配置选项都将生效。请查看 http://ask.github.com/celery/configuration.html
演示
=====================
要查看所有功能,请查看 pyramid_celery_demo,运行 rabbitmq-server 然后执行
``` python
$ python setup.py develop
$ populate_pyramid_celery_demo ./development.ini
$ pserve ./development.ini
$ pcelery ./development.ini worker
```
如果你使用 celery < 3.1,请使用旧的 celery 命令行绑定。
``` python
pceleryd development.ini
```
项目详情
关闭
praekelt_pyramid_celery-1.4.0.tar.gz 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 24906f75e5cd366e77e31f37d3d7a743a542d5ab6a72724620445298cca03ca4 |
|
MD5 | 75a1a2f7267beba791a5dc1e43dac27e |
|
BLAKE2b-256 | fd127db02867ed07be0324c617a681791ba92b775ba01d6f70fa60a09fc473f2 |