函数流管理-华为云

函数工作流 FUNCTIONGRAPH-函数流简介:组件说明

组件说明函数流提供多种类型的组件，用户可以通过拖拽组件、配置组件和连接组件进行可视化编排，实现函数任务流的编排。使用函数流功能，请先了解表1。表1 组件说明类型名称说明服务组件函数 FunctionGraph函数，如何创建函数请参见创建函数。 EG 事件网格服务（EventGrid），EG节点会发布已配置的事件至指定的EG事件通道，如何创建EG资源请参见事件网格相关文档。流程控制器回调节点通过人工干预实现对执行中函数流的条件控制，函数流将阻塞在回调节点，直到用户调用回调接口以继续函数流执行，从而达到人工审批的效果。子流程把已创建的“函数流”任务作为“子流程”组合成一个新的函数流任务。并行分支用于创建多个并行分支的控制器，以便同时执行多个分支任务，并可根据分支执行结束后控制下一步流程。开始节点只能加入触发器，用于标识流程的开始，一个流程只能有一个开始节点。异常处理用于控制函数执行失败后的下一步流程。循环节点用于对数组中每个元素进行循环处理。每次循环会执行一次循环内部的子流程。时间等待用于控制当前流程在指定时间延迟后再调用下一个流程。服务节点用于对多个函数构成的复杂操作进行抽象，可以将多个函数操作合并成一个原子节点进行管理。条件分支用于根据条件判断是否执行下一分支。结束节点用于标识流程的结束。

函数工作流 FUNCTIONGRAPH 函数流管理

函数工作流 FUNCTIONGRAPH-函数流简介:编排规则

编排规则设计的函数流必须是一个有向无环图，从开始节点出发，开始节点后续必须且只能连接一个节点（除了异常处理和结束节点）；流程必须在某一个节点结束，结束流程有两种形式：流程中存在的节点没有任何后继节点，且后续节点非条件分支，并行分支或开始节点。流程中存在结束节点，且结束节点后续无其他节点。组件设计规则表2 触发器和函数和EG 参数说明创建函数流时，是否必选触发器当前允许流程中配置0-10个触发器。触发器必须配置在开始节点内。触发器不允许连接其他任何节点，也不允许被其他节点连接。否函数当前允许流程中配置0-99个函数节点。当函数连接异常处理节点时，最多可以再连接一个非开始节点和非异常处理节点。当函数不连接异常处理节点时，只能连接一个非开始节点。否 EG 当前允许流程中配置0-10个EG节点。当EG节点连接异常处理节点时，最多可以再连接一个非开始节点和非异常处理节点。当EG节点不连接异常处理节点时，只能连接一个非开始节点。否表3 流程控制器参数说明创建函数流时，是否必选回调节点回调节点限制规则参考表2中函数参数，但回调节点不可为服务节点的子节点否子流程该节点选择已创建的函数流任务。否并行分支用于标识节点后面的分支会并行执行。后继节点允许连接1-20个节点（除了异常处理，开始节点和结束节点），至少连接一个节点。否开始节点用于标识流程开始，每个流程必须有且只能有一个开始节点。开始节点后面必须接1个节点，后续节点类型不能是结束节点或者异常处理。必选异常处理后面可以接0-10个节点，后继节点不能是开始节点，结束节点和异常处理节点。否循环节点用来对数组中每个元素进行循环处理。每次循环会执行一次循环内部的子流程。循环节点内部子流程需要满足如下规则：只能有一个起始节点（没有前驱节点），起始节点只能使用函数，时间等待节点。循环节点内部只允许编排函数，时间等待，异常处理节点。否时间等待后面可以连接0个或1个节点，节点类型不能是开始节点和异常处理节点。否服务节点服务节点由多个函数节点组成，后续节点可以是结束节点或异常处理节点。否条件分支后面可以连接2-20个后继节点，后继节点类型不能为开始节点，结束节点和异常处理节点。否结束节点后面不能接任何节点。否

函数工作流 FUNCTIONGRAPH 函数流管理

函数工作流 FUNCTIONGRAPH-函数流执行历史管理:标准函数流执行历史查询

标准函数流执行历史查询登录FunctionGraph控制台，在左侧导航栏选择“函数流”，进入“函数流”页面。在“函数流”流程列表页面，单击需要查看执行历史的流程，进入流程详情页面。切换至“运行记录”页签，查看执行历史运行记录。左侧为执行历史记录列表，展示最近100次执行记录，支持根据流程执行ID进行查询。单击左侧的执行记录，中间画布展示流程的执行结果，如果节点执行成功，图标背景为绿色，如果执行失败背景为红色。图1 执行失败画布下方输入输出展示区默认展示流程的输入和输出，单击上方任意节点，展示节点的输入和输出。对于函数流及函数流各个节点，若输出值中有字段的值为null，则该字段会被直接过滤，不予展示。最下方日志展示流程从开始到结束所有节点的执行记录。图2 节点日志

函数工作流 FUNCTIONGRAPH 函数流管理

函数工作流 FUNCTIONGRAPH-流式文件处理:操作步骤

操作步骤创建一个图片压缩的函数，其中代码在处理返回数据通过 ctx.Write() 函数将结果以流式数据的形式返回：目前只支持go函数！ FunctionGraph 通过 ctx.Write() 函数提供了流式返回的能力，对开发者来说，只需要将最终结果通过流的方式返回，而不需要关注网络传输的细节。在 FunctionGraph 的函数流控制台完成工作流编排，举例如下。调用工作流的同步执行接口，获取最终结果的文件流，数据将以 chunked 流式返回的方式返回到客户端。

函数工作流 FUNCTIONGRAPH 函数流管理

函数工作流 FUNCTIONGRAPH-流式文件处理:技术原理

技术原理华为云FunctionGraph 函数工作流提出 Serverless Streaming 的流式可编排的文件处理解决方案，步骤与步骤之间通过数据流驱动，更易于用户理解。本章通过图片处理的例子解释该方案的实现机制。如果需要驱动一个工作流执行，工作流系统需要处理两个部分：控制流：控制工作流的步骤间流转，以及步骤对应的 Serverless 函数的执行。确保步骤与步骤之间有序执行。数据流：控制整个工作流的数据流转，通常来说上一个步骤的输出是下一个步骤的输入，比如上述图片处理工作流中，图片压缩的结果是打水印步骤的输入数据。在普通的服务编排中，由于需要精准控制各个服务的执行顺序，所以控制流是工作流的核心部分。然而在文件处理等流式处理场景中，对控制流的要求并不高，以上述图片处理场景举例，可以对大图片进行分块处理，图片压缩和加水印的任务不需要严格的先后顺序，图片压缩处理完一个分块可以直接流转到下一个步骤，而不需要等待图片压缩把所有分块处理完再开始加水印的任务。基于上述理解，华为云FunctionGraph工作流的 Serverless Streaming 方案架构设计如下图所示：在 Serverless Streaming 的流程中，弱化控制流中步骤之间的先后执行顺序，允许异步同时执行，步骤与步骤之间的交互通过数据流驱动。其中数据流的控制通过 Stream Bridge 组件来实现。同时函数 SDK 增加流式数据返回接口，用户不需要将整个文件内容返回，而是通过 gRPC Stream 的方式将数据写入到 Stream Bridge，Stream Bridge 用来分发数据流到下一个步骤的函数 Pod 中。

函数工作流 FUNCTIONGRAPH 函数流管理

函数工作流 FUNCTIONGRAPH-流式文件处理:背景与价值

背景与价值 Serverless Workflow由于自身可编排、有状态、持久化、可视化监控、异常处理、云服务集成等特性，适用于很多应用场景，比如：复杂度高需要抽象的业务（订单管理，CRM 等）业务需要自动中断 / 恢复能力，如多个任务之间需要人工干预的场景（人工审批，部署流水线等）业务需要手动中断 / 恢复（数据备份 / 恢复等）需要详细监控任务执行状态的场景流式处理（日志分析，图片 / 视频处理等）当前大部分 Serverless Workflow 平台更多关注控制流程的编排，忽视了工作流中数据流的编排和高效传输，上述场景创建函数流触发器中，由于数据流相对简单，所以各大平台支持都比较好，但是对于文件转码等存在超大数据流的场景，当前各大平台没有给出很好的解决方案。华为云FunctionGraph函数工作流针对该场景，提出了 Serverless Streaming 的流式处理方案，支持毫秒级响应文件处理。

函数工作流 FUNCTIONGRAPH 函数流管理

云服务器内容精选

函数流管理

7*24

备案

专业服务

退订

建议反馈

售前咨询热线