celery

 

celery是一個基於Python實現的模塊,模塊能夠幫助咱們實現"任務管理".
當一個請求的處理時間特別長,可使用celery.

快速使用celery

    a.建立s1.py 
        import time
        from celery import Celery
        
        app = Celery('tasks', broker='redis://123@123.207.56.67:6380', backend='redis://123@192.168.19.123:6379')
        
        @app.task
        def xxxxxx(x, y):
            time.sleep(10)
            return x + y
    b.啓動worker
        進入當前目錄
        celery worker -A s1 -l info 
        celery worker -A s1 -l info -P eventlet (在windows下使用,不推薦在windows下使用celery)
        
    c.建立任務
        import s1
    
        result = s1.xxxxxx.delay(88,671)
        print(result.id)
    d. 檢查任務
        import s1
        from celery.result import AsyncResult
        
        ret = AsyncResult(id='90a2a6e8-299a-41a5-9aab-4c989f45d303',app=s1.app)
        
        if ret.successful():
            data = ret.get()
            print(data)


 注意事項

    - 解釋器版本和celery版本
    - windows和linux
    - broker:
        - redis
        - rabbitMQ