您可以编写自定义函数并在MaxCompute SQL中使用它们。
基本操作
list_functions()
:获取项目空间下的所有函数。exist_function()
:用于判断是否存在某个函数。get_function()
:用于获取函数对象。create_function()
:创建函数。delete_function()
:删除函数。
创建函数
使用入口对象的create_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])
删除函数
使用入口对象的delete_function()
方法即可删除函数,也可以使用函数对象调用drop
方法删除函数。举例如下。
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() # 更新函数。
内容没看懂? 不太想学习?想快速解决? 有偿解决: 联系专家
阿里云企业补贴进行中: 马上申请
腾讯云限时活动1折起,即将结束: 马上收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折,更有现金返利:同意关联,立享优惠
转转请注明出处:https://www.yunxiaoer.com/159581.html