Hardcelery
Что такое Celery?
1Постановка
Разберём, что от вас хотят в этом вопросе и как к нему подступиться на собеседовании.
2Решение
Celery — distributed task queue для Python. Background jobs, scheduled tasks, parallel processing. Архитектура: producer → broker (Redis/RabbitMQ) → workers → result backend.
from celery import Celery
app = Celery('tasks', broker='redis://localhost')
@app.task(bind=True, autoretry_for=(Exception,),
retry_backoff=True, max_retries=3)
def add(self, a, b):
return a + b
result = add.delay(2, 3) # async выполнение
result.get(timeout=10) # 5
add.apply_async(args=(2, 3), countdown=10) # с задержкой
# Pipeline
from celery import chain
chain(add.s(2, 3) | mul.s(4)).apply_async()- celery beat — periodic tasks через crontab;
- Worker pools: prefork (processes), eventlet/gevent, threads;
- Monitoring: Flower;
- Не для real-time, latency в ms-секундах;
- Альтернативы: RQ (проще), Dramatiq, Huey, Arq (asyncio-native).
3Как отвечать
- Сначала уточните условия и ограничения, покажите аналитическое мышление.
- Рассуждайте вслух — интервьюеру важен ход мысли, а не только финальный ответ.
- Оцените сложность по времени и памяти (Big-O), если это алгоритмический вопрос.
💡
На реальном собеседовании Alffert подскажет развёрнутый ответ в реальном времени.