-
实施步骤 - 数据工坊 DWR
(event) obsClient = ObsClient( access_key_id=context.getAccessKey(), secret_access_key=context.getSecretKey(), server
-
案例概述 - 数据工坊 DWR
案例概述 场景介绍 DWR平台除了提供面向使用者的平台功能,同时也支持合作伙伴将自有功能包装成算子发布到DWR平台上,帮助伙伴快速搭建用户的数据处理工厂。 算子发布流程 图1 算子发布流程图 部署服务:算子提供方需要将自身服务部署在华为云,同时对外提供API,方便用户进行调用。
-
开发算子代码 - 数据工坊 DWR
创建成功后FunctionGraph平台会自动生成一个python代码。 图1 创建函数界面 编辑python代码。 如图2所示,默认代码中只有一个handler函数,入参为两个: event :触发事件信息,OBS事件触发的函数(DWR中称为算子)中event包含桶名,对象名。
-
产品优势 - 数据工坊 DWR
一站式运维:可视化统一运维平台,降低管理难度。 开放:算子库能力无上限 丰富算子生态:可调用海量华为云自有算子及第三方算子,免开发。 开放式自助注册:第三方算子轻松上架,引流增收。
-
创建视频转码工作流 - 数据工坊 DWR
if user_data is not None: self.user_data = user_data if watermarks is not None: self.watermarks = watermarks
-
“无限循环”触发工作流如何处理? - 数据工坊 DWR
说明:triggerA和triggerB都不指定前后缀 图5 工作流配置workflowA 图6 工作流配置workflowB 图7 触发器triggerA配置 图8 触发器triggerB配置
-
自定义函数开发规范 - 数据工坊 DWR
*ImageWatermark `json:"image_watermark,omitempty"` TextWatermark *TextWatermark `json:"text_watermark,omitempty"` } type TextWatermark struct
-
发布算子 - 数据工坊 DWR
Inputs参数: [ { //算子所在工作流输入列表 "parameter_name": "bucketname", "parameter_value": "", "value_type": "", "default": "", "type": "string
-
与其他服务的关系 - 数据工坊 DWR
数据处理服务 媒体处理(Media Processing Center,MPC) DWR提供的视频解析、抽帧截图、媒资转码等算子,依赖MPC提供的相应能力。
-
发布算子 - 数据工坊 DWR
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 [ { //算子所在工作流输入列表 "parameter_name": "bucket", "parameter_value": "", "value_type": "",
-
发布算子 - 数据工坊 DWR
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 [ { //算子所在工作流输入列表 "parameter_name": "bucket", "parameter_value": "", "value_type": "",
-
DWR自定义策略 - 数据工坊 DWR
DWR自定义策略样例 示例1:授权用户创建、删除、执行工作流 1 2 3 4 5 6 7 8 9 10 11 12 13 { "Version": "1.1", "Statement": [{ "Effect": "Allow", "Action":
-
通过事件触发器异步启动工作流 - 数据工坊 DWR
同理如果选择了ObjectRemoved,则不能再选择Delete或DeleteMarkerCreated。 前缀 使事件触发器生效的对象前缀。 说明: 当前缀和后缀都不配置时,事件触发器将作用于桶中所有对象。 后缀 使事件触发器生效的对象后缀。
-
官方算子一览 - 数据工坊 DWR
serviceVersion 功能版本,目前仅支持“1.2”。 事件延迟 模板作用:可用于控制工作流两个相邻任务间的等待时长,例如执行任务A后,规定等待一段时间再继续执行任务B。
-
数据工坊 DWR - 数据工坊 DWR
发布区域:北京四、上海一、上海二、广州、新加坡 通过事件触发器异步启动工作流 通过API异步启动工作流 通过API同步启动工作流 OBS 2.0支持API DWR提供了REST(Representational State Transfer)风格API,支持您通过HTTP/HTTPS