Download workflow core - Download do código fonte workflow core

workflow core

Outro código-fonte

v3.11.0

Baixar

Núcleo do fluxo de trabalho

O núcleo do fluxo de trabalho é um direcionamento do motor de fluxo de trabalho incorporado em peso leve .NET padrão. Pense: processos de longa execução com várias tarefas que precisam rastrear o estado. Ele suporta provedores de persistência e simultaneidade de persistência para permitir clusters de vários nós.

Anúncios

Novo projeto relacionado: condutor

O condutor é um servidor de fluxo de trabalho independente, em oposição a uma biblioteca que usa o núcleo do fluxo de trabalho internamente. Ele expõe uma API que permite armazenar definições de fluxo de trabalho, rastrear fluxos de trabalho em execução, gerenciar eventos e definir etapas e scripts personalizados para uso em seus fluxos de trabalho.

https://github.com/danielgerlag/conductor

Documentação

Veja o tutorial aqui.

API fluente

Defina seus fluxos de trabalho com a API fluente.

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

Definições de fluxo de trabalho JSON / YAML

Defina seus fluxos de trabalho em JSON ou YAML, precisa instalar o 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

Casos de uso de amostra

Novo fluxo de trabalho do usuário

 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 ) ;
    }
}

Transações da 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 > ( ) ;

Persistência

Como os fluxos de trabalho são normalmente processos de execução longa, eles precisam persistir para o armazenamento entre as etapas. Existem vários provedores de persistência disponíveis como pacotes NUGET separados.

MemoryPersistenceProvider (provedor padrão, para fins de demonstração e teste)
MongoDB
Cosmos db
Amazon DynamoDB
SQL Server
PostGresql
Sqlite
Mysql
Redis

Procurar

Um provedor de índice de pesquisa pode ser conectado ao núcleo do fluxo de trabalho, permitindo indexar seus fluxos de trabalho e pesquisar contra os dados e o estado deles. Estes também estão disponíveis como pacotes NUGET separados.