celery英文官方網(wǎng)站：www.celeryproject.org
中文網(wǎng)站：http://docs.jinkan.org/docs/celery/

celery

Celery 是一個(gè)簡(jiǎn)單、靈活且可靠的，處理大量消息的 分布式系統(tǒng) ，并且提供維護(hù)這樣一個(gè)系統(tǒng)的必需工具。
專(zhuān)注于實(shí)時(shí)處理的任務(wù)隊(duì)列，同時(shí)也支持任務(wù)調(diào)度。

作用：

• 解決耗時(shí)操作：開(kāi)一個(gè)新的進(jìn)程，去操作耗時(shí)操作，不影響原有進(jìn)程 定時(shí)操作，使
• List item

用celery定時(shí)執(zhí)行

操作：

1. 定義一個(gè)任務(wù)task，也就是一個(gè)python函數(shù)
2. 將耗時(shí)任務(wù)存儲(chǔ)到隊(duì)列queue中
3. 在一個(gè)新的進(jìn)程中，負(fù)責(zé)執(zhí)行隊(duì)列中的任務(wù)，worker
4. broker：負(fù)責(zé)調(diào)度，將任務(wù)加到隊(duì)列中，在布置環(huán)境中使用redis

安裝包

            
              pip install celery
pip install celery
              
                -
              
              
                with
              
              
                -
              
              redis
pip install django
              
                -
              
              celery

            
          

配置settings
將djcelery包加入到INSTALLED_APPS中
并添加以下代碼：

            
              
                import
              
               djcelery
djcelery
              
                .
              
              setup_loader
              
                (
              
              
                )
              
              
                # 初始化所有的task
              
              
BROKER_URL 
              
                =
              
              
                'redis://127.0.0.1:6379/0'
              
              
                # 把所有的任務(wù)放在queue中，默認(rèn)用0這個(gè)數(shù)據(jù)庫(kù)
              
              
CELERY_IMPORTS 
              
                =
              
              
                (
              
              
                'test1.task'
              
              
                )
              
              
                # 在test1這個(gè)應(yīng)用下使用任務(wù)
              
            
          

在test1應(yīng)用目錄下創(chuàng)建task.pty文件

            
              
                import
              
               time

              
                from
              
               celery 
              
                import
              
               task

@task

              
                def
              
              
                show
              
              
                (
              
              
                )
              
              
                :
              
              
                print
              
              
                (
              
              
                'hello...'
              
              
                )
              
              
	time
              
                .
              
              sleep
              
                (
              
              
                5
              
              
                )
              
              
                print
              
              
                (
              
              
                'world...'
              
              
                )
              
            
          

遷移，生成celery需要的數(shù)據(jù)表
此時(shí)不需要生成遷移，直接進(jìn)行遷移

            
              python manage
              
                .
              
              py migrate

            
          

啟動(dòng)redis

            
              sudo redis
              
                -
              
              server 
              
                /
              
              etc
              
                /
              
              redis
              
                /
              
              redis
              
                .
              
              conf

            
          

啟動(dòng)worker

            
              python manage
              
                .
              
              py celery worker 
              
                -
              
              
                -
              
              loglevel
              
                =
              
              info

            
          

定義視圖，調(diào)用task
函數(shù)名.delay([參數(shù)])

            
              
                from
              
               task 
              
                import
              
              
                *
              
              
                def
              
              
                celeryTest
              
              
                (
              
              request
              
                )
              
              
                :
              
              
	show
              
                .
              
              delay
              
                (
              
              
                )
              
              
                return
              
               HttpResponse
              
                (
              
              
                'ok'
              
              
                )
              
            
          

配置url

            
              url
              
                (
              
              r
              
                '^celerytest/$'
              
              
                ,
              
               views
              
                .
              
              celeryTest
              
                )
              
              
                ,
              
            
          

---

總結(jié)：

• 簡(jiǎn)單：易使用和維護(hù)，不需要配置文件
• 高可用性：如果鏈接丟失或者失敗，客戶(hù)端會(huì)自動(dòng)重試，并broker通過(guò)主/主或者主/從方式復(fù)制來(lái)提高可用性。
• 快速：?jiǎn)蝹€(gè)celery進(jìn)程每分鐘可處理數(shù)以百萬(wàn)計(jì)的任務(wù)
• 靈活：celery幾乎所有的部分都可以擴(kuò)展或者單獨(dú)使用。