如何在多个队列和服务器上部署 Celery

芹菜英语 [ sel ri] 梅 [ s l ri] n芹菜; 欧芹粉; 芹菜种子;

例句]不要吃薯片和巧克力，而是啃芹菜或胡萝卜

不要吃薯条和巧克力，吃芹菜和胡萝卜。

其他]复数：celeries

许多 Django 应用程序需要执行异步任务，以免延迟 HTTP 请求的执行。 有很多方法可以完成异步任务，使用 Celery 是一个不错的选择，因为 Celery 有很多社区支持，可以完美扩展，并且与 Django 集成得很好。

芹菜不仅用于 Django，还用于其他地方。

因此，一旦你学会了使用芹菜，就很容易在其他项目中使用它。

安装。 需要安装 RabbitMQ、celery 和 django-celery

芹菜和 django-celery 的安装只是点。

添加 RabbitMQ 的配置：

import djcelery

broker_url = 'amqp://guest:guest@localhost:5672/'

或。 #broker_host = "localhost"

#broker_port = 5672

#broker_user = "guest"

#broker_password = "guest"

#broker_vhost = "/"

创建数据库。

python syncdb #default

python migrate djcelery #for south

定义和调用任务

from celery import task

task()

def add(x, y):

return x + y

启用 worker：

python celery worker --loglevel=info

#or python celeryd -l info --settings=settings

调用任务：python shell

in [1]: from import add

in [2]: a=,1)

在 [3] 中：未启用工作线程。

out[3]: false

在[4]中：a=，1）启动 worker 并再次执行它。

in [5]:

out[5]: true

in [9]: #waits until the task is done and returns the retval.

out[9]: 2

in [10]:

out[10]: true

8） 运行索引：$python 8000，运行 celery：$python celeryd -l info --settings=settings

1.Celery 客户端：当生产者在 Flask 上工作时，生产者发送消息并在 Flask 应用程序中运行。

2.Celert worker：由使用者用来处理后台任务。

使用者可以是本地的，也可以是远程的。 我们可以在运行 Flask 的服务器上运行一个消费者，然后在达到业务量时添加更多的消费者。

3.芹菜经纪人：生产者和消费者使用消息队列进行信息交互，芹菜支持消息队列的几种方式，其中最长的是 rabbitmq 和 redis，我们在使用它的过程中使用了 redis！

使用 rabbitmq+celery 可以完全满足您的需求，在灵活性、可靠性和可扩展性方面，唯一的缺点是它太重量级了。

RabbitMQ 的性能方法如下： Sakura 1.声明 7 个不同属性的队列，并将它们绑定到名为 Test Extreme 的交易所（因为交易所是扇出类型的，所以测试中的路由密钥实际上不起作用）;2.向Exchange发送具有持久属性的邮件（传递模式=2）; 3. 创建 7 个消费者，从以上 7 个歌曲队列中获取消息;