Temporal¶

В этой статье

• Temporal. Основные возможности
• Особенности сборки
• Начало работы после развертывания Temporal
• Начальный экран и навигация
• Тестирование Temporal с использованием Go (опционально)
• Заказ Temporal с помощью API

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

• Оркестрация рабочих процессов: обеспечивает надежное выполнение длительных бизнес-процессов. Автоматически обрабатывает сбои и повторы, гарантируя выполнение задач;
• Распределенные транзакции: обеспечивает согласованное выполнение операций между различными сервисами без использования распределенных блокировок;
• Таймауты и планирование: позволяет устанавливать таймеры и планировать выполнение задач с высокой точностью даже для длительных процессов;
• Масштабируемость: поддерживает горизонтальное масштабирование для обработки высоких нагрузок. Компоненты можно масштабировать независимо;
• Историческая отладка: сохраняет историю выполнения процессов, что позволяет анализировать и отлаживать рабочие процессы;
• Версионирование: поддерживает безопасное обновление рабочих процессов без прерывания выполняющихся задач;
• Наблюдаемость: интеграция с системами мониторинга и трассировки для контроля работы приложений;
• Multi-tenancy: обеспечивает изоляцию и управление ресурсами для нескольких команд или приложений.

Особенности сборки¶

• Предустановленные зависимости:
  • Docker;
  • docker-compose;
  • Git (для клонирования репозитория).
• Дополнительные компоненты:
  • Nginx (для обратного прокси);
  • Postgresql (база данных);
  • Elasticsearch (для хранения истории рабочих процессов);
  • Grafana (для мониторинга);
  • Prometheus (для сбора метрик);
  • Jaeger (для распределенной трассировки);
  • OpenTelemetry Collector (для сбора телеметрии);
• Рабочий каталог проекта: /root/docker-compose;
• Файл для кастомизации: /root/docker-compose/docker-compose-multirole_edited.yaml

Основные компоненты, имеющие веб-интерфейс:

Начало работы после развертывания Temporal¶

После оплаты заказа на указанную при регистрации электронную почту придет уведомление о готовности сервера к работе. В нем будет указан IP-адрес VPS, а также логин и пароль для подключения. Управление оборудованием клиенты нашей компании осуществляют в панели управления серверами и API — Invapi.

После перехода по ссылке из тега webpanel будет открыто окно авторизации.

Данные для авторизации, которые можно найти или во вкладке Информация >> Тэги панели управления сервером или в присланном e-mail:

• Ссылка для доступа к панели управления Temporal с веб-интерфейсом: в теге webpanel;
• Логин и Пароль для управления сервером: приходят в письме на вашу электронную почту при сдаче сервера.

Начальный экран и навигация¶

После перехода из тега webpanel будет открыт веб-интерфейс Temporal:

Главный экран отображает список рабочих процессов (Workflows) в выбранном пространстве имен. Сообщение "No Workflows running in this Namespace" означает отсутствие активных процессов в текущий момент.

Основные элементы интерфейса:

• Боковая панель слева предоставляет доступ к различным секциям системы;
• Верхняя панель показывает текущее пространство имен (по умолчанию "default");
• Кнопка Start Workflow в правом верхнем углу для запуска новых процессов;
• Таблица процессов с колонками Status, Workflow ID, Run ID, Type, Start, End.

Функциональные возможности

1. Запуск нового рабочего процесса:

   • Нажатие на кнопку Start Workflow в правом верхнем углу;
   • Заполнение необходимых параметров в появившейся форме;
   • Подтверждение создания процесса.

2. Просмотр и фильтрация процессов:

   • Использование кнопки Filter для отбора процессов по различным критериям;
   • Выбор любого процесса в таблице для просмотра подробной информации.

3. Примеры кода:

   • Доступны примеры интеграции через ссылки на репозитории GitHub:
     • samples-go - примеры на Go;
     • samples-java - примеры на Java;
     • samples-typescript - примеры на TypeScript;
     • samples-python - примеры на Python;
     • samples-dotnet - примеры на .NET;
     • samples-php - примеры на PHP.

4. Изменение настроек:

   • Селектор UTC в верхнем правом углу для изменения часового пояса;
   • Кнопка предназначена для доступа к дополнительным настройкам интерфейса.

Типичные сценарии использования:

• Мониторинг процессов: регулярная проверка статуса выполняемых задач;
• Отладка: детальный анализ ошибок в случае сбоев;
• Управление рабочими нагрузками: запуск, приостановка и отмена процессов;
• Разработка новых процессов: использование примеров кода для создания собственных рабочих процессов.

Тестирование Temporal с использованием Go (опционально)¶

1. Установка Go¶

Перед началом тестирования необходимо установить Go на сервер:

Обновите списки пакетов

apt update

apt install -y wget git curl

wget https://golang.org/dl/go1.22.1.linux-amd64.tar.gz

tar -C /usr/local -xzf go1.22.1.linux-amd64.tar.gz

echo 'export PATH=$PATH:/usr/local/go/bin' >> ~/.bashrc

echo 'export GOPATH=$HOME/go' >> ~/.bashrc

echo 'export PATH=$PATH:$GOPATH/bin' >> ~/.bashrc

source ~/.bashrc

go version

2. Клонирование репозитория с примерами Temporal¶

Перейдите в домашнюю директорию

cd ~

git clone https://github.com/temporalio/samples-go.git

cd samples-go

3. Тестирование с использованием примера Saga¶

Saga-паттерн используется для управления распределенными транзакциями, обеспечивая возможность отката (компенсации) при ошибках.

Структура примера Saga

saga/
├── worker/main.go     # Рабочий процесс, обрабатывающий задачи
├── start/main.go      # Инициализирует рабочий процесс
├── activity.go        # Определение действий (снятие/внесение средств)
├── workflow.go        # Определение последовательности действий
└── shared.go          # Общие определения

Запуск теста:

1. Запустите воркер (выполняйте в первом терминале):

   cd ~/samples-go
   

   go run saga/worker/main.go
   

   Воркер зарегистрируется в Temporal и будет ожидать задачи. При этом в логах будут появляться сообщения о попытках получить задачи.

2. Запустите стартер (выполняйте во втором терминале):

   cd ~/samples-go
   

   go run saga/start/main.go
   

   Стартер инициирует рабочий процесс перевода денег с одного счета на другой.

Ожидаемый результат:

В логах воркера вы увидите:

1. Снятие денег со счета 001-001;
2. Внесение денег на счет 002-002;
3. Специально созданную ошибку в активности StepWithError;
4. Три попытки выполнить активность с ошибкой;
5. Запуск компенсирующих действий:
   • Возврат средств на первоначальный счет;
   • Отмена снятия средств.

4. Проверка результатов через веб-интерфейс Temporal¶

1. Откройте в браузере веб-интерфейс Temporal (по ссылке из тега webpanel);
2. В интерфейсе найдите рабочий процесс с ID transfer-money-workflow;
3. Вы увидите полную историю выполнения рабочего процесса, включая все активности и компенсирующие действия:

Заказ сервера с Temporal с помощью API¶

Для установки данного ПО с использованием API следуйте этой инструкции.