溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹了celery怎么實現為不同異步任務分配不同worker的相關知識，內容詳細易懂，操作簡單快捷，具有一定借鑒價值，相信大家閱讀完這篇celery怎么實現為不同異步任務分配不同worker文章都會有所收獲，下面我們一起來看看吧。
1、配置celery，按正則匹配異步任務名，分配到指定消費隊列
這里創建4個消費隊列，release，job，sync，celery（默認）
匹配到sync_release的任務，會調度到release隊列消費，以此類推，支持正則匹配
import re
# specify worker queue
# https://docs.celeryq.dev/en/latest/userguide/routing.html
app.conf.task_routes = ([
('cmapp.tasks.sync_release', {'queue': 'release'}),
(re.compile(r'.*(job*|Cdd*)'), {'queue': 'job'}),
(re.compile(r'.*(delay*|owncloud*)'), {'queue': 'sync'}),
(re.compile(r'.*(clean*|keycloak*)'), {'queue': 'celery'}),
],)2、啟動消費隊列
-Q指定消費隊列名稱
--hostname配置worker名
--concurrency配置最大并發
[program:q_release] environment=ENV=production directory=/opt/mmback command=/opt/envs/env-mmweb/bin/celery -A mmback worker -l info --concurrency=20 -Q release --hostname=release@%%h autorestart=true autostart=true
supervisorctl update
可以看到已經有release任務在消費。
關于“celery怎么實現為不同異步任務分配不同worker”這篇文章的內容就介紹到這里，感謝各位的閱讀！相信大家對“celery怎么實現為不同異步任務分配不同worker”知識都有一定的了解，大家如果還想學習更多知識，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
