Task routing позволяет направлять задачи в разные очереди для разных worker-ов. Конфиг: task_routes = {"app.email.*": {"queue": "email"}, "app.heavy.*": {"queue": "heavy"}}. Worker подписывается на очередь: celery worker -Q heavy. Зачем: разделение нагрузки (лёгкие/тяжёлые задачи), приоритизация, разные ресурсы (GPU worker для ML). Можно указать очередь при отправке: task.apply_async(queue="priority"). Default queue — "celery". Для сложного роутинга — кастомный Router класс.
Как работает task routing в Celery?
Senior
146 просмотровAFK Offer AI
Что такое msgspec?