标签:sts 注册 设置 网络服务 color 控制台 相关 部署 标记
原文:https://blog.51cto.com/yuanhuan/1246666
Sample Workflow是亚马逊AWS提供的一种公共网络服务。
Sample Workflow(SWF)是亚马逊提供的一种云计算服务,它通过一个提供给协调分布式组件的程序设计模式和框架,以及以一种可靠地方式维护他们的执行状态,简化了部署异步和分布式应用程序的复杂度。
亚马逊SWF的架构如下图所示:
工作流是一种分布式应用程序,它由在不同设备上分布式运行的协调逻辑和任务组成。在设计工作流的过程中,需要对应用程序进行分析,将组件的任务标示出来。在亚马逊SWF中,这些任务被称为activities。工作流的协调逻辑模块来决定哪些activities被执行。
在协调逻辑和activities被设计完成之后,就可以将它们注册为工作流和activities 类型。在注册过程中,需要为每一个类型指定一个名字、一个版本号以及一些默认的配置项。
每一个工作流执行过程都被记录到了工作流历史中,亚马逊SWF负责维护这个工作流历史。工作流历史是一个对工作流启动之后每一个执行的事件的详细、完整、一致的记录。
一个事件是工作流执行状态的间歇性改变,例如:当一个新的activity被计划,或者一个运行的activity执行完成的时候。
不改变工作流执行状态的操作是不会记录到工作流历史中去的。
工作流历史有下面主要的好处:
1.它使应用程序是无状态的,这是因为工作流执行的所有信息都保存到工作流历史中去了;
2.对于每一个工作流执行而言,工作流历史提供了哪些activities被安排了、它们当前的状态是什么以及它们的执行结果。
3.工作流历史提供了一种详细的审计追踪记录,可以用来监控工作流的执行情况,以及验证已经完成的工作流执行。
Actor可以是工作流的启动者,也可以是deciders,又可以是workers。这些actors通过API与亚马逊SWF交互。
每一个工作流都是运行在一个domain中的,domain限制了工作流的范围。一个亚马逊AWS账号可以同时拥有多个domain,而每一个domain也可以包含多个工作流,但是不同domain中的工作流是不能够交互的。
下面这些概念描述了亚马逊SWF中一些对象如何被唯一标示的:
1.WorkflowType:一个注册的工作流类型由其domain、name、version来标示,字段名为RegisterWorkflowType;
2.ActivityType:一个注册的activity类型由其domain、name、version来标示,字段名为RegisterActivityType;
3.DecisionTask and Activity Task:每一个decision task和activity task都是由一个task token来标示的,这个task token是由亚马逊SWF来生成的。
4.WorkflowExecution:Workflow execution由domain、工作流ID和runID来标示;前两个是启动工作流执行(StartWorkflowExecution)的输入参数,run ID是启动工作流执行之后返回的。
Task lists提供了一种管理工作流中的tasks的方式,可以简单理解为动态队列。
Task Lists还提供了一种分发task的机制,它是动态存在的,不需要注册也不需要显式的创建,当计划了一个task的时候就会自动创建一个task list(如果这个task list以前不存在的话)。
下面有几种不同类型的Task List。
1.DecisionTask Lists:每个工作流执行都被关联到了一个指定的decision task list。当注册一个工作流类型的时候,可以为这个工作流类型的执行指定一个默认的task list。
2.ActivityTask Lists:一个单独的activity task list可以包含不同activity类型的task。任务列表中的任务按照顺序计划和分配。
3.TaskRouting:当worker要取一个task的时候,它可以指定一个task list去取任务。如果它这样做了的话,这个worker就只能接收该task list中的任务了。这样一来,就可以确保特定的任务只能分配给特定的workers。
为了保证工作流执行能够正确运行,亚马逊SWF提供了一些超时时间类型供设置。一些类型指定工作流全部完成的超时时间,一些指定了任务分配给worker之后要多久才执行,另外一些指定了task被分配到之后要多久能够执行完成。需要注意的是,在SWF中超时时间的单位都是秒。
1.WorkflowStart to Close(类型:START_TO_CLOSE):指定了一个工作流执行的最长时间。工作流注册的时候为这个指定一个默认值,工作流启动之后还可以修改这个值。当达到这个超时时间之后,SWF将会关闭这个工作流执行,并且在工作流历史中增加一个WorkflowExecutionTimedOut类型的事件;
2.DecisionTask Start to Close(类型:START_TO_CLOSE):指定了decider完成一次decision task的最长时间。它是在工作流类型注册时指定的。如果这个超时时间达到的时候,这个task将会在工作流历史中标记为超时(DecisionTaskTimedOut)。
3.ActivityTask Start to Close(类型:START_TO_CLOSE):指定了worker接收到任务之后完成该任务所需要的最大时间。
4.ActivityTask Heartbeat(类型:HEARTBEAT):指定了通过RecordActivityTaskHeartbeat操作提供的进程
5.ActivityTask Schedule to Start(类型:SCHEDULE_TO_START):指定了activity task在没有worker可用来执行的情况下,SWF等待的最大时间。当时间达到的时候,过期的task将不会再分配给另外的worker;
6.ActivityTask Schedule to Close(类型:SCHEDULE_TO_CLOSE):指定了activity task在计划之后最长将过多久执行完成。为了最佳实践,这个值不应该大于Activity Task Scheduleto Start和Activity Task Start toClose之和。
在设计亚马逊SWF之前,需要首先定义需要的activities,然后将每一个activity注册到SWF中成为一个activity类型。当注册activity的时候,需要提供一些信息,例如:名字和版本,以及activity的过期时间。
需要注意的是,在一个工作流中,同一个activity可能会执行多次,输入也可能是不一样。例如:对于一个客户订单的工作流,处理订购产品的activity就可能会执行多次,这是因为客户可能会同时购买多个产品,此时对于该activity而言只是输入(产品信息)不一样而已。
亚马逊SWF中有两种不同的task:
1.Activitytask:对一个activity的一次调用,告诉worker去执行它的功能,例如:检查库存、信用卡支付等。activity task包含了worker所需要的执行其功能的所有信息。
2.Decisiontask:Decision task告诉一个decider工作流执行状态已经被改变了,因此decider可以决定下一次需要执行的activity。
下图展示了工作流和decider之间的关系:
下图展示了与activity相关的组件之间的关系:
Activity Worker是一个接受、处理activity task的进程或者线程,并且会在处理完成之后返回结果。
对于Activity task以及Activity worker而言,它们都可以同步或者异步运行。它们也可以通过不同地理位置的计算机进行分布执行,或者在同一台计算机上执行。不同的activity worker可以用不同的计算机语言来编写,也可以运行在不同的操作系统之上。
Decider是对工作流中的协调逻辑模块的软件程序实现。Decider负责分配task并提供输入信息给worker,处理工作流启动之后接收到的事件,并在目标完成之后关闭工作流。
SWF的执行步骤如下:
1.编写activity workers来实现工作流中的执行步骤;
2.编写decider来实现工作流中的协调逻辑;
3.在亚马逊SWF中注册activities和workflow,这个步骤可以通过编程或者亚马逊控制台来完成;
4.启动activities workers和deciders;
5.启动工作流的一个或者多个执行。每一个执行都是独立的,你可以为每一个执行提供不同的输入数据;
6.在亚马逊的控制台上查看工作流的执行情况。你可以过滤或者查看正在运行的以及已完成的execution。
标签:sts 注册 设置 网络服务 color 控制台 相关 部署 标记
原文地址:https://www.cnblogs.com/panpanwelcome/p/14487732.html