celcery是乙個任務分發系統,總體我的感覺就是通過將需要執行的任務交給celery,在celery內進行任務的執行,celery需要訊息中間價存放你的任務,這時可以用redis或者rabbitmq作為訊息中介軟體,用來存訊息和讀訊息。celery是乙個簡單、靈活可靠的,處理大量訊息的分布式系統,並且提供維護這樣乙個系統的必需的工具。專注於實時處理的任務佇列,同時也支援任務排程。
對於乙個簡單的例項,我們將任務建立、管理職程放在乙個模組中。
拿個簡答例子,我們需要批量計算a+b,那麼我們的任務排程**如下:
from celery import celery
defadd
(x,y):
return x+y
celery -a tasks worker –loglevel=info
from tasks import add
add.delay(4,4)
result.ready()
print result.get(timeout=1, propagate=false)
檢視rabbitmq-server的運**況:
localhost:15672
guest/guest
celery學習筆記
ubuntu系統下安裝指令 安裝rabbitmq sudo apt get install rabbitmq server 安裝celery sudo easy install celery 注意 這裡我開始採用官方文件的指令 pip install celery不過發現用不了,執行後面的指令提示不...
celery學習筆記
1.windows下 啟動redis命令 redis server redis.windows.conf 如果出現 5512 23 dec 16 53 14.121 creating server tcp listening socket 127.0.0.1 6379 bind no error 這...
Celery學習筆記(一)
在學習celery之前,我先簡單的去了解了一下什麼是生產者消費者模式。在實際的軟體開發過程中,經常會碰到如下場景 某個模組負責產生資料,這些資料由另乙個模組來負責處理 此處的模組是廣義的,可以是類 函式 執行緒 程序等 產生資料的模組,就形象地稱為生產者 而處理資料的模組,就稱為消費者。單單抽象出生...