PHPackages                             magdv/workflow-orchestrator - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Utility & Helpers](/categories/utility)
4. /
5. magdv/workflow-orchestrator

ActiveLibrary[Utility & Helpers](/categories/utility)

magdv/workflow-orchestrator
===========================

Workflow orchestrator for symfony/messenger

0.0.1(1y ago)11MITPHPPHP >=8.3

Since Mar 18Pushed 1y ago2 watchersCompare

[ Source](https://github.com/magdv/workflow-orchestrator)[ Packagist](https://packagist.org/packages/magdv/workflow-orchestrator)[ RSS](/packages/magdv-workflow-orchestrator/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (1)Dependencies (8)Versions (2)Used By (0)

Абстрактная реализация оркестратора асинхронных задач на основе symfony/messenger
---------------------------------------------------------------------------------

[](#абстрактная-реализация-оркестратора-асинхронных-задач-на-основе-symfonymessenger)

**Внимание**, библиотека была вынесена в отдельную библиотеку, но в таком варианте еще не была использована. В составе другого проекта, не как пакет код работает. Пока что можно считать, что это альфа версия. Как только подключу этот пакет в таком виде, то отпишусь. Версия станет сразу стабильной.

В любом случае можете пробовать реализовывать или брать за основу код. Очень помогает в работе.

Идея библиотеки родилась после ознакомления с Temporal и LaravelWorkflow. Но у данных решений есть недостаток - это зависимость от конкретной технологии или фреймворка. А мне требовалось решение, которое можно переносить из проекта в проект.

Данная библиотека позволяет разделить выполнение сложных асинхронных задач, следующих друг за другом и отслеживать текущий статус их выполнения. Задачи - это просто задачи из меседжера симфони, которые обрабатываются АСИНХРОННО. Одна за одной, вы просто выстраиваете их в очередь, если у вас надо обработать несколько задачи последовательно. Результат работы каждой предыдущей задачи можно использовать в работе последующей.

Короткий пример организации вашего кода.

```
        class SimpleWorkflowForTest extends SimpleWorkflow
        {
            public function getGeneratorFlow(): \Generator
            {
                // Выстраиваем по очереди Ваши задачи. Каждая должна возвращаться через yield
                $result = yield new NotifyToMattermostMessage1('Это переменная первой Activity', '111', []);
                yield new NotifyToMattermostMessage1('Результат первой Activity из всего Workflow: ' . $result . ' + еще текст к переменной', '222', []);
            }
        }

        // пример старта WORKFLOW
        $workflowService = new WorkflowService(
            $workflowRepository,
            $workflowBus
        );

        $workflowService->createWorkflow(new SimpleWorkflowForTest('тест'));
        $workflowService->start();
```

При работе Вашей задачи можно использовать все преимущества месенджера от симфони. Например исключения для повторения задачи, или для откладывания задачи на 10 минут. Можно просто сразу завершить, если есть проблемы неразрешимые.

```
RecoverableExceptionInterface
UnrecoverableExceptionInterface
```

Основная идея была заимствована из Temporal. Но за обработку задач отвечает symfony/workflow.т.е. вы легко можете использовать все его возможности. Для работы пакета создаются 2 асинхронные очереди

- **Workflow** - вычисляет текущий статус обработки или какую следующую задачу выполнят, или пора завершать работу.
- **Activity** - берет назначенную задачу из очереди и выполняет ее **синхронно**.

Все асинхронные задачи объединяются в 1 большой **Workflow**. **Workflow** по итогу составляется из большого количества **Activity**.

**Workflow** находится в работе, пока выполняются его **Activity**. Каждая задача выполняется **Activity** выполняется по отдельности и по порядку, как только задача активити выполнена, то выполнение возвращается в **Workflow** происходит вычисление следующей задачи и далее ставится задача на выполнение следующей активити.

Данный пакет предоставляет 2 обработчика очереди:

- **Workflow**
- **Activity**Интерфейсы для работы с хранилищами данных для Workflow и Activity.

Для работы требуется подготовить хранилища Workflow и Activity в соответствии с интерфейсом. Ниже будет пример использования с примером реализованных репозиториев для хранилищ.

Какие классы необходимо реализовать?

1. Миграция для хранилищ - надо уметь сохранять сущности в зависимости от вашей Хранилки. Хоть SQL, хоть NoSql.
    1. MagDv\\Orchestrator\\Dto\\WorkflowEntity
    2. MagDv\\Orchestrator\\Dto\\ActivityEntity
2. Репозиторий для `Workflow`, который реализует интерфейс (Реализация репозитория зависит от вашей системы хранения)
    1. MagDv\\Orchestrator\\Interface\\WorkflowRepositoryInterface
3. Репозиторий для `Activity`, который реализует интерфейс (Реализация репозитория зависит от вашей системы хранения)
    1. MagDv\\Orchestrator\\Interface\\ActivityRepositoryInterface
4. Настройка `symfony/messenger` в проекте.

- Надо создать 3 очереди для работы оркестратора.
- асинхронная очередь для `workflow`
- асинхронная очередь для `activity`
- СИНХРОННАЯ очередь для работы ваших задач. Они обрабатываются только в СИХРОННОМ режиме.

Пример реализации. !!!!Местами псевдокод!!!!
--------------------------------------------

[](#пример-реализации-местами-псевдокод)

```