Téléchargement workflow core - Téléchargement du code source workflow core

workflow core

Autre code source

v3.11.0

Télécharger

Noyau de workflow

Le noyau du flux de travail est un moteur de workflow de travail intégré léger ciblant la norme .NET. Pensez: des processus de longue durée avec plusieurs tâches qui doivent suivre l'état. Il soutient les fournisseurs de persistance et de concurrence enfichables pour permettre des clusters multi-nœuds.

Annonces

Nouveau projet connexe: chef d'orchestre

Le conducteur est un serveur de flux de travail autonome par opposition à une bibliothèque qui utilise le noyau de workflow en interne. Il expose une API qui vous permet de stocker des définitions de workflow, de suivre les workflows en cours d'exécution, de gérer les événements et de définir des étapes et des scripts personnalisés pour l'utilisation dans vos workflows.

https://github.com/danielgerlag/conductor

Documentation

Voir le tutoriel ici.

API courante

Définissez vos flux de travail avec l'API courante.

 public class MyWorkflow : IWorkflow
{
    public void Build ( IWorkflowBuilder < MyData > builder )
    {    
        builder
           . StartWith < Task1 > ( )
           . Then < Task2 > ( )
           . Then < Task3 > ( ) ;
    }
}

Définitions de workflow JSON / YAML

Définissez vos workflows dans JSON ou YAML, devez installer WorkflowCore.dsl

{
  "Id" : " HelloWorld " ,
  "Version" : 1 ,
  "Steps" : [
    {
      "Id" : " Hello " ,
      "StepType" : " MyApp.HelloWorld, MyApp " ,
      "NextStepId" : " Bye "
    },        
    {
      "Id" : " Bye " ,
      "StepType" : " MyApp.GoodbyeWorld, MyApp "
    }
  ]
}

 Id : HelloWorld
Version : 1
Steps :
- Id : Hello
  StepType : MyApp.HelloWorld, MyApp
  NextStepId : Bye
- Id : Bye
  StepType : MyApp.GoodbyeWorld, MyApp

Échantillons de cas d'utilisation

Nouveau flux de travail utilisateur

 public class MyData
{
	public string Email { get ; set ; }
	public string Password { get ; set ; }
	public string UserId { get ; set ; }
}

public class MyWorkflow : IWorkflow
{
    public void Build ( IWorkflowBuilder < MyData > builder )
    {    
        builder
            . StartWith < CreateUser > ( )
                . Input ( step => step . Email , data => data . Email )
                . Input ( step => step . Password , data => data . Password )
                . Output ( data => data . UserId , step => step . UserId )
           . Then < SendConfirmationEmail > ( )
               . WaitFor ( "confirmation" , data => data . UserId )
           . Then < UpdateUser > ( )
               . Input ( step => step . UserId , data => data . UserId ) ;
    }
}

Transactions de saga

 public class MyWorkflow : IWorkflow
{
    public void Build ( IWorkflowBuilder < MyData > builder )
    {    
        builder
            . StartWith < CreateCustomer > ( )
            . Then < PushToSalesforce > ( )
                . OnError ( WorkflowErrorHandling . Retry , TimeSpan . FromMinutes ( 10 ) )
            . Then < PushToERP > ( )
                . OnError ( WorkflowErrorHandling . Retry , TimeSpan . FromMinutes ( 10 ) ) ;
    }
}

 builder
    . StartWith < LogStart > ( )
    . Saga ( saga => saga
        . StartWith < Task1 > ( )
            . CompensateWith < UndoTask1 > ( )
        . Then < Task2 > ( )
            . CompensateWith < UndoTask2 > ( )
        . Then < Task3 > ( )
            . CompensateWith < UndoTask3 > ( )
    )
    . OnError ( Models . WorkflowErrorHandling . Retry , TimeSpan . FromMinutes ( 10 ) )
    . Then < LogEnd > ( ) ;

Persistance

Étant donné que les workflows sont généralement des processus en cours d'exécution, ils devront être persistés pour le stockage entre les étapes. Il existe plusieurs fournisseurs de persistance disponibles en tant que forfaits NuGet distincts.

MemoryPersistenceProvider (fournisseur par défaut, à des fins de démo et de test)
Mongodb
Cosmos DB
Amazon DynamoDB
Serveur SQL
Postgresql
Sqlite
Mysql
Redis

Recherche

Un fournisseur d'index de recherche peut être branché sur Workflow Core, vous permettant d'indexer vos workflows et de rechercher par rapport aux données et à leur état. Ceux-ci sont également disponibles sous forme de packages NuGet séparés.