您可以编写自定义函数并在MaxCompute SQL中使用它们。

基本操作

您可以调用MaxCompute入口对象的list_functions来获取项目空间下的所有函数。exist_function用于判断是否存在函数;get_function用于获取函数对象。

创建函数

# 引用当前project中的资源。
resource = o.get_resource('my_udf.py')
function = o.create_function('test_function', class_type='my_udf.Test', resources=[resource])
# 引用其他project中的资源。
resource2 = o.get_resource('my_udf.py', project='another_project')
function2 = o.create_function('test_function2', class_type='my_udf.Test', resources=[resource2])

删除函数

o.delete_function('test_function')
function.drop()  # Function对象存在时直接调用drop方法。

更新函数

只需对函数调用update方法即可。

function = o.get_function('test_function')
new_resource = o.get_resource('my_udf2.py')
function.class_type = 'my_udf2.Test'
function.resources = [new_resource, ]
function.update()  # 更新函数。