DataWorks V2使用PyUdf
在DataWorks上新建一个Python资源,命名为 test_udf.py
编辑pyudf的脚本代码,实现方法请参考Python实现MaxCompute UDF
# -*- coding:utf-8 -*-
from odps.udf import annotate #函数签名,SQL执行前所有函数的参数类型和返回值类型必须确定;
@annotate("string->string")#参数为string,返回值为string;
class Upper2Lower(object):
def evaluate(self, arg):#实现 evaluate 方法;
return arg.lower()
保存,并上传资源。
新建函数 Upper2lower2
注册函数
python资源输入类名的时候,不需要加上py后




