تنزيل workflow core - تنزيل رمز المصدر workflow core

workflow core

شفرة المصدر الأخرى

v3.11.0

تنزيل

Coreflow Core

Coreflow Core هو محرك عمل خفيفة الوزن قابلة للتضمين يستهدف. NET Standard. فكر: عمليات طويلة المدى مع مهام متعددة تحتاج إلى تتبع الحالة. وهو يدعم مثابرة وتوافق مع مقدمي التزامن للسماح بمجموعات متعددة العقدة.

الإعلانات

مشروع جديد ذات صلة: موصل

الموصل هو خادم سير عمل مستقل بدلاً من المكتبة التي تستخدم سير العمل الأساسية داخليًا. إنه يعرض واجهة برمجة تطبيقات تتيح لك تخزين تعريفات سير العمل وتتبع تشغيل سير العمل وإدارة الأحداث وتحديد الخطوات المخصصة والبرامج النصية للاستخدام في سير العمل الخاص بك.

https://github.com/danielgerlag/conductor

الوثائق

انظر البرنامج التعليمي هنا.

API بطلاقة

حدد سير العمل الخاص بك باستخدام واجهة برمجة تطبيقات بطلاقة.

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

تعريفات سير عمل JSON / YAML

حدد سير العمل في JSON أو YAML ، تحتاج إلى تثبيت 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

حالات استخدام العينة

سير عمل مستخدم جديد

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

معاملات الملحمة

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