celery動態任務組件Demo以及原理

celery是一個基於Python的分佈式調度系統，文檔在這 ,最近有個需求,想要動態的添加任務而不用重啓celery服務,找了一圈沒找到什麼好辦法(也有多是文檔沒看仔細)，因此只能本身實現囉python 爲celery動態添加任務，首先我想到的是傳遞一個函數進去，讓某個特定任務去執行這個傳遞過去的函數，就像這樣sql @app.task def execute(func, *args, **kw

>>阅读原文<<