python-celery專注于實作分布式異步任務處理、任務調度的插件！-有解無憂

celery是一個基于分布式訊息傳輸的異步任務佇列，它專注于實時處理，同時也支持任務調度，它的執行單元為任務（task），利用多執行緒，如Eventlet，gevent等，它們能被并發地執行在單個或多個職程服務器（worker servers）上，任務能異步執行（后臺運行）或同步執行（等待任務成），

file

【閱讀全文】

Celery的三個主要模塊

'''
worker：用于執行佇列中的作業任務
beat：用于定時分配作業任務
task：作業任務，可以是在代碼里的呼叫、也可以是被beat分配定時任務
'''

Celery的使用條件

'''
1、安裝訊息中間件的支持，一般是redis，
pip install redis
2、安裝Celery的支持
pip install celery
3、安裝本地redis服務端并啟動
'''

做一個Celery定時任務

'''
匯入相關依賴包
'''
import celery  # celery 定時任務包
import time  # 時間記錄
from datetime import timedelta  # 時間處理

'''
創建一個worker用來執行定時任務
'''

# 創建worker、連接到redis訊息中間件
worker = celery.Celery("work_test", backend="redis://localhost:6379/", broker="redis://localhost:6379/")

# 創建任務配置類TaskConfig

class TaskConfig:
    beat_suhedule = {
        'update_info': {
            'task': 'test013.test3.test_task',  # 任務所在的模塊.函式
            "schedule": timedelta(seconds=5),  # 定時任務間隔時間
        }
    }

# worker配置生效

worker.config_from_object(TaskConfig)


@worker.task
def test_task():
    '''
    任務
    :return:
    '''
    return "當前任務執行狀態：success,{}".format(time.time())

'''
啟動 beat 分配定時任務
celery -A test3.worker beat
'''

# C:\work-code\base-python3\test013>celery -A test3.worker beat

'''
啟動 beat 分配定時任務
celery -A test3.worker worker
'''

# C:\work-code\base-python3\test013>celery -A test3.worker worker

file