先來一張圖，這是在網上最多的一張Celery的圖了，確實描述的非常好

Celery的架構由三部分組成，訊息中介軟體（message broker），任務執行單元（worker）和任務執行結果儲存（task result store）組成。

訊息中介軟體

Celery本身不提供訊息服務，但是可以方便的和第三方提供的訊息中介軟體整合。包括，RabbitMQ, Redis, MongoDB (experimental), Amazon SQS (experimental),CouchDB (experimental), SQLAlchemy (experimental),Django ORM (experimental), IronMQ

任務執行單元

Worker是Celery提供的任務執行的單元，worker併發的執行在分散式的系統節點中。

任務結果儲存

Task result store用來儲存Worker執行的任務的結果，Celery支援以不同方式儲存任務的結果，包括AMQP, Redis，memcached, MongoDB，SQLAlchemy, Django ORM，Apache Cassandra, IronCache

OK 廢話就說到這， 來點使用的。

首先你也看到了， 你要有一個訊息中介軟體，此處我們選擇rabbitmq，為什麼不用redis或者sqs呢，首先這兩個我都用過了，想接觸以下rabbitmq，所以果斷選擇這個。

Now 安裝rabbitmq！
官網介紹有安裝方法， 我貼以下網址吧，自己看看，很簡單很簡單。 我是Mac系統 http://www.rabbitmq.com/install-standalone-mac.html 如果是其他系統自己對應下。 可以把sbin的路徑配置到path裡面（我比較懶 沒加，所以去到解壓目錄，囧）

啟動管理外掛：sbin/rabbitmq-plugins enable rabbitmq_management
啟動rabbitmq：sbin/rabbitmq-server -detached

ok， now，rabbitmq已經啟動，可以開啟頁面來看看
地址：http://localhost:15672/#/

好了 訊息中介軟體有了，現在該來程式碼了，我是在celeby官網看的，如果覺得我程式碼有問題，可以自己去官網看，嘿嘿。

首先，定義一個task。

from celery import Celery

app = Celery('tasks', backend='amqp://[email protected]//', broker='amqp://[email protected]//')

@app.task
def add(x, y):
    return x + y

儲存為tasks.py
—>broker 就是中介軟體了，自己看著改吧, backend就是 後端來發送狀態訊息，保持追蹤任務的狀態，儲存或傳送這些狀態

Now 可以啟動了
命令: celery -A tasks worker –loglevel=info
想要檢視完整的命令列引數列表
命令：celery worker –help 或者
celery help

現在 另開一個terminal，啟用虛擬環境， ipython 啟動python console

In [9]: from tasks import add

In [10]: result = add.delay(6, 7)

現在你可以在用之前命令啟動的終端中看到輸出，而且可以驗證結果。
呼叫任務會返回一個 AsyncResult 例項，可用於檢查任務的狀態，等待任務完成或獲取返回值， 而且現在我們也設定了一個用於儲存結果和狀態等資訊的backend， 現在你可以成功的拿到結果， 如果你print result， 你會看到一串字串， 類似與uuid。
如下方式：

In [11]: result.ready()
Out[11]: True

In [12]: result.get(timeout=1)
Out[12]: 13

In [13]: result.get(propagate=False)
Out[13]: 13

ok 現在看到結果了吧。
注： propagate的作用 倘若任務丟擲了一個異常， get() 會重新丟擲異常， 但你可以指定 propagate 引數來覆蓋這一行為。

以上就是一些程式碼了。

下面是 celery的配置，配置的話 你不想看這個 可以去官網看，比我的詳細的多。

app.conf.update(
    CELERY_TASK_SERIALIZER='json',
    CELERY_ACCEPT_CONTENT=['json'],  # Ignore other content
    CELERY_RESULT_SERIALIZER='json',
    CELERY_TIMEZONE='Europe/Oslo',
    CELERY_ENABLE_UTC=True,
)

但是對於大型專案來說 這樣配置就顯得很low，這個時候可以用模組。你可以呼叫 config_from_object() 來讓 Celery 例項載入配置模組。
app.config_from_object(‘celeryconfig’)

celeryconfig.py

BROKER_URL = 'amqp://'
CELERY_RESULT_BACKEND = 'amqp://'

CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT=['json']
CELERY_TIMEZONE = 'Europe/Oslo'
CELERY_ENABLE_UTC = True

可以使用 python -m celeryconfig 來驗證配置是否正確。

好了 這是這篇部落格的全部，稍後還有有的，謝謝。