Сервер с Temporal

Что такое Temporal и зачем он нужен?

Когда распределенное приложение запускает многошаговый процесс — оформление заказа, онбординг пользователя, финансовая транзакция — что-то обязательно пойдет не так. Сеть зависнет, сервис упадёт, внешний API вернёт ошибку. Написать логику, которая корректно обрабатывает все эти сбои, повторяет нужные шаги и не теряет состояние — сложно и дорого.

Temporal решает именно эту проблему. Это платформа оркестрации воркфлоу (workflow orchestration engine) с открытым исходным кодом: она берёт на себя ответственность за надежное выполнение вашего кода, гарантируя, что процесс завершится корректно, даже если по дороге несколько раз упадут серверы или API. Разработчику не нужно писать кастомную логику повторов, управлять состоянием или хранить промежуточные результаты — Temporal делает это автоматически.

Temporal создан командой, которая ранее построила AWS SQS, AWS SWF и Cadence в Uber. В production его используют Stripe, Netflix, Datadog, Snap, NVIDIA. Лицензия MIT.

Как работает Temporal: Workflows, Activities, Workers?

Три ключевых понятия, которые нужно понимать.

Workflow (Рабочий процесс) — это код, описывающий бизнес-логику. Вы пишете его как обычную функцию или метод на Go, Python, Java, TypeScript или .NET. Workflow описывает последовательность шагов: «зарядить карту → зарезервировать товар → отправить подтверждение → инициировать доставку». Главное свойство: если в процессе что-то упадёт, Workflow возобновится с того места, где остановился. Не с начала — именно с того шага, где произошел сбой.

Activity (Активность) — это отдельная операция внутри Workflow: запрос к API, запись в базу данных, отправка письма. Активности — то, что может падать. Temporal автоматически повторяет их при ошибках с настраиваемой политикой: количество попыток, таймаут, интервал между попытками.

Worker (Воркер) — это ваш код, запущенный на вашей инфраструктуре. Воркер опрашивает очередь задач Temporal Server, получает задания на выполнение Workflows и Activities, выполняет их и возвращает результат. Temporal Server при этом хранит полную историю выполнения — именно она позволяет восстановить состояние после любого сбоя.

Для каких задач подходит Temporal?

Оркестрация микросервисов

Когда бизнес-операция требует последовательного обращения к нескольким сервисам (платежи, склад, доставка, уведомления), Temporal координирует весь процесс. Если на шаге «доставка» что-то упало — Temporal автоматически повторит запрос, а не потеряет заказ. При необходимости откат (компенсация) тоже прописывается в коде Workflow.

Длительные бизнес-процессы

Онбординг пользователя с подтверждением email, затем документов, затем платежного метода может растянуться на дни. Workflow в Temporal может «спать» неделями и месяцами, не потребляя ресурсов — пока не придёт нужное событие. Это невозможно реализовать с обычными очередями задач без дополнительного хранилища состояния.

Финансовые транзакции и платежи

Для транзакций критична гарантия выполнения: деньги не должны списаться дважды и не должны зависнуть нигде посередине. Temporal гарантирует идемпотентность и сохраняет историю каждого шага — это упрощает аудит и позволяет воспроизвести выполнение при разборе инцидентов.

AI/ML пайплайны

Обучение модели, обработка датасетов, вызовы LLM — всё это может занимать часы. Temporal позволяет запускать такие пайплайны с гарантией завершения: если воркер упал в середине обработки батча, следующий воркер продолжит с той же точки.

CI/CD и деплой инфраструктуры

Сложный деплой с pre-check, smoke-тестами, постепенным rollout и автоматическим rollback — это типичный длительный Workflow. Temporal даёт инструменты для управления такими процессами с полной наблюдаемостью.

Основные возможности Temporal

Durable Execution — код, переживающий сбои

Основная идея Temporal. Состояние Workflow сохраняется после каждого шага. Если сервер упал, Worker перезапустился или пришло обновление — Workflow продолжит выполнение ровно с того момента, где остановился. Разработчик пишет обычный код, Temporal берёт на себя управление надежностью.

Автоматические повторы и политики ретраев

Для каждой Activity настраивается политика: максимальное число попыток, таймаут на выполнение, интервал ожидания между попытками (с exponential backoff). Не нужно писать try-catch обёртки с логикой повторов вручную.

Сохранение состояния и история выполнения

Temporal хранит полную историю каждого Workflow Execution. Это решает несколько задач: отладка (можно воспроизвести выполнение шаг за шагом), аудит (полная трассировка всех операций), восстановление (после сбоя Worker поднимается с правильного состояния).

Сигналы и запросы к рабочим процессам

Внешние системы могут отправить сигнал в работающий Workflow — например, «пользователь подтвердил платёж» или «менеджер одобрил заявку». Workflow реагирует на сигнал и продолжает выполнение. Queries позволяют запросить текущее состояние Workflow без остановки.

Планировщик (Schedules) вместо cron

Temporal Schedules заменяют хрупкие cron-задачи: повторяющиеся Workflows запускаются по расписанию с гарантией запуска, backfill для пропущенных выполнений и контролем перекрытия запусков.

Мультиязыковые SDK

Go, Python, Java, TypeScript, .NET. Команда выбирает тот язык, на котором уже пишет бэкенд — SDK предоставляет нативный API без необходимости изучать новый DSL.

Web UI и наблюдаемость

Встроенный Web UI показывает все Workflow Executions: текущий статус, историю событий, стек ошибок, время выполнения каждой Activity. Это значительно упрощает отладку по сравнению с ручным анализом логов.

Temporal vs Airflow vs AWS Step Functions

Все три — инструменты оркестрации, но для разных задач.

Apache Airflow — стандарт для batch-пайплайнов и ETL: DAG-модель, Python, богатая экосистема коннекторов к данным. Задачи в Airflow stateless — каждая задача независима и не знает о состоянии других. Airflow не создан для длительных транзакционных воркфлоу или event-driven систем.

AWS Step Functions — управляемый сервис для оркестрации в экосистеме AWS. Без операционной нагрузки, но привязка к AWS, ограниченная гибкость и стоимость на высоких нагрузках. Определение воркфлоу в JSON/YAML, не в коде.

Temporal — выбор, когда важны надежность выполнения, поддержка сбоев, длительные процессы и code-first подход. Более сложная операционная составляющая при self-hosted развертывании, но полная свобода от облачного провайдера и контроль над данными.

Если задача — ночной ETL по расписанию: Airflow. Если AWS-стек и нужна быстрая интеграция с Lambda: Step Functions. Если нужна надёжная оркестрация сложных distributed workflows с гарантией завершения: Temporal.

Self-hosted vs Temporal Cloud

Temporal Cloud — управляемый сервис от разработчиков. Без операционной нагрузки, но минимальная стоимость от $100/месяц и данные обрабатываются на их инфраструктуре.

Self-hosted на VPS — вы разворачиваете Temporal Server самостоятельно: стек из самого сервера, PostgreSQL для хранения истории и Web UI. Полный контроль над данными, стоимость только аренды сервера — заметно дешевле при средней нагрузке. Актуально для компаний с требованиями к локализации данных или регуляторными ограничениями.

Temporal на сервере HOSTKEY: как начать

При заказе VPS или выделенного сервера выберите Temporal во вкладке «Маркетплейс приложений». Temporal Server, PostgreSQL и Web UI устанавливаются автоматически — данные для доступа придут на почту после готовности сервера, обычно в течение 15 минут.

Для базовой установки достаточно VPS с 4 ГБ RAM и 2 ядрами CPU. Elasticsearch, который Temporal использует для расширенного поиска по истории воркфлоу, потребует дополнительно 2–4 ГБ RAM. При большом числе параллельных Workflow Executions потребуется масштабирование.

Серверы доступны в России, Нидерландах, Финляндии, Германии, Исландии, США, Турции, Великобритании и Франции. Базовая защита от DDoS включена. Техподдержка — круглосуточно, время ответа до 15 минут.