Implementeren met een workflow-engine

Orkestratiesaga's kunnen complex worden, vooral wanneer er veel stappen, pogingen en compensatielogica zijn.

Deze status handmatig beheren over meerdere services heen kan een enorme uitdaging zijn. Daar komen workflow-engines of gespecialiseerde bibliotheken goed van pas!

Een workflow-engine is een softwareonderdeel dat helpt bij het definiëren, uitvoeren en bewaken van langlopende processen of 'workflows'.

• De engine beheert de status van een proces.
• De engine zorgt ervoor dat taken in de juiste volgorde worden uitgevoerd.
• De engine verwerkt fouten en nieuwe pogingen automatisch.

Voor orkestratiesaga's fungeert een workflow-engine als de speciale orkestrator. De implementatie wordt vereenvoudigd door:

• De sagastatus persistent op te slaan: Je hoeft de voortgang van de saga niet handmatig op te slaan en te laden.
• Nieuwe pogingen te automatiseren: Configureerbaar beleid voor nieuwe pogingen bij mislukte stappen.
• Compensatie te vereenvoudigen: Bij een mislukking worden automatisch terugdraaistappen gestart.
• Zichtbaarheid te bieden: Dashboards om de uitvoering van de saga te bewaken.

Workflow-engines bieden doorgaans robuuste functies die essentieel zijn voor gedistribueerde transacties:

• Taakplanning: Voert stappen uit in een vastgelegde volgorde.
• Statusbeheer: Houdt de huidige status van elke saga-instantie bij.
• Foutafhandeling: Vangt uitzonderingen op en past vooraf gedefinieerde herstel logica toe.
• Timers: Ondersteunt het wachten op externe gebeurtenissen of time-outs.

Wanneer je een engine gebruikt, definieer je je saga als een workflow. Dit houdt het volgende in:

1. Elke stap van de bedrijfstransactie identificeren.
2. De uitvoeringsvolgorde definiëren.
3. Compensatieacties voor elke stap specificeren.
4. Voorwaarden voor succes of mislukking vastleggen.

Met workflow-engines kun je de volgorde van stappen en de bijbehorende compensatieacties definiëren. Hier is een vereenvoudigd idee van hoe je een saga met twee stappen zou kunnen definiëren:

Nadat de workflow is gedefinieerd, neemt de workflow-engine het over. De engine:

1. Start de eerste stap van de saga.
2. Roept de bijbehorende microservice aan.
3. Wacht op het antwoord van de service (succes of mislukking).
4. Gaat op basis van het antwoord verder met de volgende stap, start compensatie of probeert de stap opnieuw.

Een van de grootste voordelen is geautomatiseerde foutafhandeling. Als een aanroep van een service mislukt, kan de engine:

• Opnieuw proberen: De bewerking opnieuw uitvoeren (bijvoorbeeld drie keer met exponentiële wachttijd).
• Compenseren: De vooraf gedefinieerde compensatiestappen uitvoeren voor al voltooide acties.
• Melden: Beheerders waarschuwen als de saga niet kan worden voltooid of gecompenseerd.

Workflow-engines worden vaak geleverd met hulpmiddelen of API's voor monitoring. Hiermee krijg je in realtime inzicht in:

• De status van elke actieve saga-instantie.
• Welke stap momenteel wordt uitgevoerd.
• Eventuele fouten of vertragingen.

Dit verbetert het opsporen van fouten en het operationele inzicht aanzienlijk.

We hebben onderzocht hoe workflow-engines en gespecialiseerde bibliotheken de implementatie van complexe georkestreerde saga's aanzienlijk kunnen vereenvoudigen.

Ze regelen het persistent opslaan van de status, foutafhandeling, nieuwe pogingen en compensatie, zodat ontwikkelaars zich kunnen richten op bedrijfslogica in plaats van op de complexiteit van gedistribueerde transacties. Hierdoor wordt het veel eenvoudiger om robuuste microservices te bouwen.