案例概述

场景介绍

DWR平台除了提供面向使用者的平台功能，同时也支持合作伙伴将自有功能包装成算子发布到DWR平台上，帮助伙伴快速搭建用户的数据处理工厂。

算子发布流程

图1 算子发布流程图

1. 部署服务：算子提供方需要将自身服务部署在华为云，同时对外提供API，方便用户进行调用。
2. API上线云市场：云市场提供API调用权限的购买入口，算子提供方将步骤1中开放的API注册到云市场中即可获取便捷的收费管理，上线指导参见API上线云市场。
3. 开发算子：DWR的算子执行依赖FunctionGraph服务提供执行引擎，算子提供方在发布算子前需按照函数开发规范开发算子。
4. 测试算子：算子提供方在发布前可通过自定义算子方式完成DWR的alpha调试，可有效降低发布后的故障率，测试结果也是算子发布时的重要审核项。
5. 发布算子等待审核：算子提供方完成步骤4中的测试后，进入到DWR控制台界面，根据提示信息提供必要的资料提交审核。

本次实践将重点描述步骤3、4、5完成算子的开发、测试、发布。

算子执行原理

图2 算子执行原理

• 动态参数：算子提供方定义的用户输入，最终由Event传递真实值。例如，云市场 appkey，算子回调函数地址。
• Event ：算子的触发事件信息，例如OBS对象信息，桶名，动态参数。