Download the PHP package magdv/workflow-orchestrator without Composer
On this page you can find all versions of the php package magdv/workflow-orchestrator. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Download magdv/workflow-orchestrator
More information about magdv/workflow-orchestrator
Files in magdv/workflow-orchestrator
Package workflow-orchestrator
Short Description Workflow orchestrator for symfony/messenger
License MIT
Informations about the package workflow-orchestrator
Абстрактная реализация оркестратора асинхронных задач на основе symfony/messenger
Внимание, библиотека была вынесена в отдельную библиотеку, но в таком варианте еще не была использована. В составе другого проекта, не как пакет код работает. Пока что можно считать, что это альфа версия. Как только подключу этот пакет в таком виде, то отпишусь. Версия станет сразу стабильной.
В любом случае можете пробовать реализовывать или брать за основу код. Очень помогает в работе.
Идея библиотеки родилась после ознакомления с Temporal и LaravelWorkflow. Но у данных решений есть недостаток - это зависимость от конкретной технологии или фреймворка. А мне требовалось решение, которое можно переносить из проекта в проект.
Данная библиотека позволяет разделить выполнение сложных асинхронных задач, следующих друг за другом и отслеживать текущий статус их выполнения. Задачи - это просто задачи из меседжера симфони, которые обрабатываются АСИНХРОННО. Одна за одной, вы просто выстраиваете их в очередь, если у вас надо обработать несколько задачи последовательно. Результат работы каждой предыдущей задачи можно использовать в работе последующей.
Короткий пример организации вашего кода.
При работе Вашей задачи можно использовать все преимущества месенджера от симфони. Например исключения для повторения задачи, или для откладывания задачи на 10 минут. Можно просто сразу завершить, если есть проблемы неразрешимые.
Основная идея была заимствована из Temporal. Но за обработку задач отвечает symfony/workflow.т.е. вы легко можете использовать все его возможности. Для работы пакета создаются 2 асинхронные очереди
- Workflow - вычисляет текущий статус обработки или какую следующую задачу выполнят, или пора завершать работу.
- Activity - берет назначенную задачу из очереди и выполняет ее синхронно.
Все асинхронные задачи объединяются в 1 большой Workflow. Workflow по итогу составляется из большого количества Activity.
Workflow находится в работе, пока выполняются его Activity. Каждая задача выполняется Activity выполняется по отдельности и по порядку, как только задача активити выполнена, то выполнение возвращается в Workflow происходит вычисление следующей задачи и далее ставится задача на выполнение следующей активити.
Данный пакет предоставляет 2 обработчика очереди:
- Workflow
- Activity Интерфейсы для работы с хранилищами данных для Workflow и Activity.
Для работы требуется подготовить хранилища Workflow и Activity в соответствии с интерфейсом. Ниже будет пример использования с примером реализованных репозиториев для хранилищ.
Какие классы необходимо реализовать?
- Миграция для хранилищ - надо уметь сохранять сущности в зависимости от вашей Хранилки. Хоть SQL, хоть NoSql.
- MagDv\Orchestrator\Dto\WorkflowEntity
- MagDv\Orchestrator\Dto\ActivityEntity
- Репозиторий для
Workflow
, который реализует интерфейс (Реализация репозитория зависит от вашей системы хранения)- MagDv\Orchestrator\Interface\WorkflowRepositoryInterface
- Репозиторий для
Activity
, который реализует интерфейс (Реализация репозитория зависит от вашей системы хранения)- MagDv\Orchestrator\Interface\ActivityRepositoryInterface
- Настройка
symfony/messenger
в проекте.- Надо создать 3 очереди для работы оркестратора.
- асинхронная очередь для
workflow
- асинхронная очередь для
activity
- СИНХРОННАЯ очередь для работы ваших задач. Они обрабатываются только в СИХРОННОМ режиме.
Пример реализации. !!!!Местами псевдокод!!!!
Готовим Ваш первый WORKFLOW
Пример настройки под Симфони.
All versions of workflow-orchestrator with dependencies
ext-curl Version *
ext-json Version *
symfony/uid Version ^7.0
symfony/messenger Version ^6.3