在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后缀。切记，不要忘记提交函数。

使用函数 SELECT Upper2lower2('AA');

至此为止，pyudf就可以使用了。

关于DataWorks V2.0版本还有啥使用上的疑惑，就加入我们的钉钉群吧，有专业的技术支持同学接客。

DataWorks数加交流0群
群号：11718465

也可以扫码加群：