阿里云免实名注册，阿里云服务器购买，免费注册

本篇文章1599字，读完约4分钟

阿里云国际站经销商，主营阿里云，腾讯云，华为云，亚马逊aws，谷歌云gcp,微软云az，免费开户，代充值优惠大，联系客服飞机@jkkddd

使用MNS服务集成及回调编排任意任务类型

Serverless工作流的服务集成功能可以简化用户与云服务的交互。本文示例中，我们使用MNS队列集成的功能，结合回调（callback）完成更多非函数计算的计算任务的编排。
简介
Serverless工作流的使用场景不仅限于编排函数计算FC（Function Compute）的FaaS函数，也包括广义上任意的计算任务。在上一篇最佳实践文档异步任务回调中介绍了利用函数计算的函数向MNS队列中发送消息，自定义环境中的任务执行者 （worker） 接收到消息，结合回调（callback）通知Serverless工作流任务执行结果。在下文中，将介绍如何使用Serverless工作流的新功能MNS队列。MNS队列进一步简化编排自定义任务类型。Serverless工作流可以直接向MNS的队列发送消息，省去了发送消息的函数计算的函数的开发、测试和维护，提高了可用性，降低了延迟。使用MNS集成相比通过函数计算的函数发送消息到MNS的做法有以下好处：
无需为发送消息做函数计算的函数的开发，降低了开发、测试和维护成本。
降低了消息传递的延时、少了一次远程访问、避免了函数计算的冷启动。
去除了一个服务依赖、提高了容错性。
Serverless工作流未来会推出更多的云服务集成，让不同类型任务组成的工作流编排变得更加容易。
服务集成功能
下图中3个串行的任务由Serverless工作流负责依次发送至用户指定的MNS队列中。消息发送成功之后Serverless工作流将会在该步骤暂定等待回调。用户在自定义环境中的worker（例如ECS VM、容器、自建机房内的机器）调用MNS ReceiveMessage接口拉取消息。收到消息后，worker根据消息内容执行相应的任务。任务结束后，调用Serverless工作流ReportTaskSucceeded/Failed接口，Serverless工作流收到任务结果后继续该步骤执行。worker在汇报任务结果成功后删除MNS队列消息。
步骤详解
下文将详细介绍使用该功能的步骤。
准备工作
填写流程（Flow）
编写worker
执行并查看结果
步骤一：准备工作
通过MNS控制台创建MNS队列，详细步骤请参见创建队列。
Serverless工作流需要扮演用户在Flow中指定的执行角色 （RAM role）向用户账号下的MNS队列发送消息，因此需要为该RAM role添加MNS SendMessage相关的权限策略 (policy)，细粒度的策略示例如下。如没有细粒度权限控制的需求，可以通过Serverless工作流控制台向Flow RAM role添加系统策略AliyunMNSFullAccess。
步骤二：编写流程 (Flow)
下面的FDL是一个可以向fnf-demo这个MNS队列发送消息并且等待回调的任务（Task）步骤。
步骤三：编写worker
下面的Python 2.7代码模拟一个执行任务的worker，它可以运行在任何可以访问到Serverless工作流和MNS服务的环境中。该worker长轮询调用MNS ReceiveMessage，当一个带有MNS配置的任务步骤进入时，Serverless工作流会向fnf-demo这个队列中发送一个消息。该worker执行相应任务结束后回调（callback）Serverless工作流ReportTaskSucceeded/Failed接口，在任务结果汇报完成后Serverless工作流会继续当前任务步骤执行，worker可以删除消息。
在虚拟环境中，安装fnf、mns、Python SDK