数据工坊 DWR-发布算子:前提条件

时间:2025-02-12 14:54:13

前提条件

算子已开发完成,开发规范参考自定义函数开发规范,建议使用Go、Python开发(算子的冷启动效果更好)。

算子已在华为云云商店上架,上架指导参考发布API类商品操作指导

开发的新算子如果要支持同步工作流,需要保证同步工作流最后一个算子返回方式为以下的一种:

  • 返回方式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"                }            }        ]    }}
support.huaweicloud.com/usermanual-dwr/dwr_03_0003.html