创建工作流

操作场景

工作流主要是对算子进行编排，这样DWR就可以按照用户编排的工作流对OBS中的数据进行自动化处理（如视频解析、图片转码、视频截图等）。

操作步骤

1. 登录管理控制台。在左侧导航栏上方，单击，选择“存储 > 数据工坊DWR”。

   进入DWR页面。

2. 在左侧导航栏选中“工作流”，进入“工作流”页面。第一次进入时需要进行“统一授权”。
3. 单击界面右上角的“创建工作流”，进入“工作流编排”页面。
4. 将左侧预置的模板或自定义的函数拖拽至编排区域，同时在右侧属性面板配置基本属性和动态参数，配置完成后图标将由白色填充变为蓝色填充。

   各预置模板及自定义函数的参数配置说明，请参见官方算子一览。

   

   使用视频解析、抽帧截图、媒资转码等模板需要先在MPC中开启桶授权，详情请参见权限说明。

5. 鼠标单击各流程图标下方的小圆圈并长按拖拽，将工作流完整串联起来。
   

   当前仅支持串行工作流。

   图1 串联后的完整工作流
   

6. 单击右上角的“保存”，填写工作流基本信息，如表1所示。
   创建完成的所有同区域工作流，都将在工作流列表展示。工作流创建完成后，还需要创建事件触发器，或通过API触发，工作流才能工作。

   表1 工作流基本信息

   参数	说明
   工作流名称	-
   工作流类型	DWR支持同步和异步两种数据处理方式
   匿名	对同步工作流设置是否可匿名访问

   

   • 同步工作流支持异步启动。
   • 支持同步工作流的自营算子参见官方算子一览。
   • 同步工作流最后一个算子当前仅支持以下两种返回方式：
     • 返回方式1：字符串数据

       {
           "execution_name":"84a3dd2bd67f43aa9b98cdd74604ca68", //工作流实例名称
           "graph_name":"test_workflow", //工作流名称
           "Records":[  // 处理对象
       
           ],
            "dynamic_source": {//执行算子的输出结果
            "tasks": [
       	    {body},  // 直接返回body字符串
           ]
         }
       }
       

     • 返回方式2：文件流数据

       {
           "execution_name":"84a3dd2bd67f43aa9b98cdd74604ca68", //工作流实例名称
           "graph_name":"test_workflow", //工作流名称
           "Records":[  // 处理对象
       
           ],
           "dynamic_source":{ //执行算子的输出结果
           "tasks":[
                   {   
                           "output":{  // 同步返回的输出文件地址：桶名、对象名、区域
                           "bucket":"bucketname",
                           "object":"objectname",
                           "location":"cn-north-4"
                       }
                   }
               ]
           }
       }

   图2 创建工作流