
Celery 分散式工作佇列排程系統入門教學(二)
介紹 Celery 分散式工作佇列排程系統細部功能的使用方式與範例。 模組檔案結構 建立一個 proj 模組,檔案結構如下: proj/__init__.py /celery.py /tasks.py 其中 celery.py 的內容如下: from celery import Celery # 建立 Celery Application app = Celery( 'proj', # 以 __main__ 執行時的名稱 broker='redis://localhost/', # Broker 位址 backend='redis://localhost/', # Backend 位址 include=['proj.tasks'] # 自動引入的模組 ) # Celery 設定(可自行調整) app.conf.update( result_expires=3600, # 計算結果保存時間 ) if __name__ == '__main__': app.start() broker 參數可設定 broker 的位置,backend 參數可設定儲存計算結果的位置,可用的 broker 與 backend 可參考 Celery 的 Backends and Brokers 文件。 ...



