如何在多個佇列和伺服器上部署 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 個歌曲佇列中獲取訊息;