celery是一個簡單、靈活和可靠的分散式任務處理系統。專注實時任務佇列，也支援任務排程。

一、celery主要包括四個部分

1、任務排程者，

2、中介軟體，傳遞任務 broker（常用的有redis、rabbitmq）

3、任務執行者（work）

4、結果儲存 backend（儲存執行完成的結果，告知任務排程者）

二、建立一個task, task.py

import celery

app = celery.Celery('tasks', broker='redis://localhost:6379')

@app.task
def first():
    print "hello world"
 

    -A 後面python檔名，  work表示啟動一個子程序

三、呼叫此任務

from test1 import first

first.delay()
first.apply_async()

看work程序就會答應下面的日誌，說明呼叫成功

2018-02-04 14:16:06,792: WARNING/ForkPoolWorker-4] hello world

四、celery配置設定

之前的例子是在celery初始化的時候設定，celery有許多配置

app = celery.Celery('tasks', broker='redis://localhost:6379')

設定時區

app.conf.CELERY_TIMEZONE = 'Europe/London'

如果這樣設定的話，會很麻煩，celery支援從檔案進行設定

app.config_from_object() 

例如task.py

import celery
from myceleryconfig import myconfig

app = celery.Celery()
print myconfig.BROKER_URL
app.config_from_object(myconfig)

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

class myconfig():
    BROKER_URL = 'redis://localhost:6379'

所有的celery設定都可以放在myceleryconfig.py裡面

具體設定哪些值，可以檢視celery.app.utils