目录摘要一、自定义函数概述1.1 什么是自定义函数1.2 自定义函数优势二、函数定义2.1 基本语法2.2 无返回值函数2.3 多返回值函数三、参数传递3.1 位置参数3.2 默认参数3.3 可变参数3.4 字典参数四、作用域4.1 局部变量4.2 全局变量4.3 变量优先级五、递归函数5.1 递归基础5.2 斐波那契数列5.3 尾递归优化六、高阶函数6.1 函数作为参数6.2 匿名函数6.3 内置高阶函数七、函数进阶7.1 闭包7.2 函数缓存7.3 函数组合八、实战案例8.1 数据处理工具函数8.2 工业计算函数九、总结参考资料摘要本文深入讲解DolphinDB自定义函数开发。从函数定义到参数传递从返回值到作用域从递归函数到高阶函数全面介绍UDF开发的核心方法。通过丰富的代码示例帮助读者掌握自定义函数开发的核心技能。一、自定义函数概述1.1 什么是自定义函数自定义函数UDF是用户根据业务需求编写的函数自定义函数函数定义参数传递函数体执行返回结果函数类型标量函数聚合函数高阶函数1.2 自定义函数优势优势说明代码复用避免重复代码模块化逻辑清晰易维护可扩展灵活扩展功能性能优化向量化计算二、函数定义2.1 基本语法//基本函数定义deffunctionName(param1,param2,...){//函数体returnresult}//示例计算两数之和defadd(a,b){returnab}//调用函数 add(1,2)//返回32.2 无返回值函数//无返回值函数defprintInfo(name,value){print(名称: name, 值: string(value))}//调用 printInfo(温度,25.5)//输出:名称:温度,值:25.52.3 多返回值函数//多返回值函数defgetStats(data){returnavg(data),max(data),min(data)}//调用 avgVal,maxVal,minValgetStats([1,2,3,4,5])print(平均值: string(avgVal))//3print(最大值: string(maxVal))//5print(最小值: string(minVal))//1三、参数传递3.1 位置参数//位置参数按顺序传递defcreatePoint(x,y,z){return[x,y,z]}createPoint(1,2,3)//[1,2,3]3.2 默认参数//默认参数defgreet(name,greeting你好){returngreeting, name!}greet(张三)//你好, 张三!greet(张三,欢迎)//欢迎, 张三!3.3 可变参数//可变参数defsumAll(nums...){total0for(ninnums){totaln}returntotal}sumAll(1,2,3)//6sumAll(1,2,3,4,5)//153.4 字典参数//字典参数defprocessConfig(config){returnconfig}processConfig(dict(STRING,ANY,[[host,localhost],[port,8848],[debug,true]]))四、作用域4.1 局部变量//局部变量函数内部定义defcalculate(x){localVarx*2//局部变量returnlocalVar}calculate(5)//10//localVar//错误外部无法访问4.2 全局变量//全局变量 globalVar100defuseGlobal(){returnglobalVar//可以访问全局变量}useGlobal()//1004.3 变量优先级//变量优先级局部全局 value10//全局变量deftest(){value20//局部变量returnvalue}test()//20局部变量 value//10全局变量五、递归函数5.1 递归基础//递归阶乘deffactorial(n){if(n1)return1returnn*factorial(n-1)}factorial(5)//120factorial(10)//36288005.2 斐波那契数列//斐波那契数列deffibonacci(n){if(n0)return0if(n1)return1returnfibonacci(n-1)fibonacci(n-2)}fibonacci(10)//555.3 尾递归优化//尾递归优化deffactorialTail(n,acc1){if(n1)returnaccreturnfactorialTail(n-1,n*acc)}factorialTail(100)//支持大数计算六、高阶函数6.1 函数作为参数//函数作为参数defapply(func,x){returnfunc(x)}defdouble(x){returnx*2}defsquare(x){returnx*x}apply(double,5)//10apply(square,5)//256.2 匿名函数//匿名函数LambdadefapplyLambda(func,x){returnfunc(x)}applyLambda(def(x){returnx*3},5)//156.3 内置高阶函数//each对每个元素应用函数 each(def(x){returnx*2},[1,2,3,4,5])//[2,4,6,8,10]//map映射map(def(x){returnx*x},[1,2,3,4,5])//[1,4,9,16,25]//filter过滤filter(def(x){returnx2},[1,2,3,4,5])//[3,4,5]//reduce归约reduce(def(x,y){returnxy},[1,2,3,4,5])//15七、函数进阶7.1 闭包//闭包defmakeCounter(){count0returndef(){count1returncount}}countermakeCounter()counter()//1counter()//2counter()//37.2 函数缓存//函数缓存记忆化defmemoize(func){cachedict()returndef(x){if(cache.has(x)){returncache[x]}resultfunc(x)cache[x]resultreturnresult}}//缓存斐波那契 fibMemomemoize(def(n){if(n0)return0if(n1)return1returnfibMemo(n-1)fibMemo(n-2)})fibMemo(50)//快速计算7.3 函数组合//函数组合defcompose(f,g){returndef(x){returnf(g(x))}}doubledef(x){returnx*2}squaredef(x){returnx*x}doubleThenSquarecompose(square,double)doubleThenSquare(3)//(3*2)^236八、实战案例8.1 数据处理工具函数//数据处理工具函数库//数据标准化defnormalize(data){minValmin(data)maxValmax(data)return(data-minVal)/(maxVal-minVal)}//Z-Score标准化defzscore(data){meanValavg(data)stdValstd(data)return(data-meanVal)/stdVal}//滑动平均defmovingAverage(data,window){resultarray(DOUBLE,data.size())for(iin0..data.size()){if(iwindow-1){result[i]NULL}else{result[i]avg(data[(i-window1):(i1)])}}returnresult}//异常值检测defdetectOutliers(data,threshold3){meanValavg(data)stdValstd(data)returnabs(data-meanVal)threshold*stdVal}//测试 data[1,2,3,4,5,100,6,7,8,9]normalize(data)zscore(data)detectOutliers(data)8.2 工业计算函数//工业计算函数库//温度单位转换defcelsiusToFahrenheit(celsius){returncelsius*1.832}deffahrenheitToCelsius(fahrenheit){return(fahrenheit-32)/1.8}//压力单位转换defbarToPsi(bar){returnbar*14.5038}defpsiToBar(psi){returnpsi/14.5038}//流量计算defcalculateFlow(velocity,area){returnvelocity*area}//能耗计算defcalculateEnergy(power,hours){returnpower*hours//kWh}//OEE计算defcalculateOEE(availability,performance,quality){returnavailability*performance*quality*100}//测试 celsiusToFahrenheit(25)//77calculateOEE(0.9,0.85,0.95)//72.675九、总结本文详细介绍了DolphinDB自定义函数开发函数定义基本语法、返回值参数传递位置参数、默认参数、可变参数作用域局部变量、全局变量递归函数阶乘、斐波那契、尾递归高阶函数函数参数、匿名函数、内置高阶函数函数进阶闭包、缓存、组合思考题如何设计可复用的函数递归和循环如何选择高阶函数有什么应用场景参考资料DolphinDB自定义函数DolphinDB编程指南
DolphinDB自定义函数：UDF开发指南
发布时间：2026/6/3 1:52:25
目录摘要一、自定义函数概述1.1 什么是自定义函数1.2 自定义函数优势二、函数定义2.1 基本语法2.2 无返回值函数2.3 多返回值函数三、参数传递3.1 位置参数3.2 默认参数3.3 可变参数3.4 字典参数四、作用域4.1 局部变量4.2 全局变量4.3 变量优先级五、递归函数5.1 递归基础5.2 斐波那契数列5.3 尾递归优化六、高阶函数6.1 函数作为参数6.2 匿名函数6.3 内置高阶函数七、函数进阶7.1 闭包7.2 函数缓存7.3 函数组合八、实战案例8.1 数据处理工具函数8.2 工业计算函数九、总结参考资料摘要本文深入讲解DolphinDB自定义函数开发。从函数定义到参数传递从返回值到作用域从递归函数到高阶函数全面介绍UDF开发的核心方法。通过丰富的代码示例帮助读者掌握自定义函数开发的核心技能。一、自定义函数概述1.1 什么是自定义函数自定义函数UDF是用户根据业务需求编写的函数自定义函数函数定义参数传递函数体执行返回结果函数类型标量函数聚合函数高阶函数1.2 自定义函数优势优势说明代码复用避免重复代码模块化逻辑清晰易维护可扩展灵活扩展功能性能优化向量化计算二、函数定义2.1 基本语法//基本函数定义deffunctionName(param1,param2,...){//函数体returnresult}//示例计算两数之和defadd(a,b){returnab}//调用函数 add(1,2)//返回32.2 无返回值函数//无返回值函数defprintInfo(name,value){print(名称: name, 值: string(value))}//调用 printInfo(温度,25.5)//输出:名称:温度,值:25.52.3 多返回值函数//多返回值函数defgetStats(data){returnavg(data),max(data),min(data)}//调用 avgVal,maxVal,minValgetStats([1,2,3,4,5])print(平均值: string(avgVal))//3print(最大值: string(maxVal))//5print(最小值: string(minVal))//1三、参数传递3.1 位置参数//位置参数按顺序传递defcreatePoint(x,y,z){return[x,y,z]}createPoint(1,2,3)//[1,2,3]3.2 默认参数//默认参数defgreet(name,greeting你好){returngreeting, name!}greet(张三)//你好, 张三!greet(张三,欢迎)//欢迎, 张三!3.3 可变参数//可变参数defsumAll(nums...){total0for(ninnums){totaln}returntotal}sumAll(1,2,3)//6sumAll(1,2,3,4,5)//153.4 字典参数//字典参数defprocessConfig(config){returnconfig}processConfig(dict(STRING,ANY,[[host,localhost],[port,8848],[debug,true]]))四、作用域4.1 局部变量//局部变量函数内部定义defcalculate(x){localVarx*2//局部变量returnlocalVar}calculate(5)//10//localVar//错误外部无法访问4.2 全局变量//全局变量 globalVar100defuseGlobal(){returnglobalVar//可以访问全局变量}useGlobal()//1004.3 变量优先级//变量优先级局部全局 value10//全局变量deftest(){value20//局部变量returnvalue}test()//20局部变量 value//10全局变量五、递归函数5.1 递归基础//递归阶乘deffactorial(n){if(n1)return1returnn*factorial(n-1)}factorial(5)//120factorial(10)//36288005.2 斐波那契数列//斐波那契数列deffibonacci(n){if(n0)return0if(n1)return1returnfibonacci(n-1)fibonacci(n-2)}fibonacci(10)//555.3 尾递归优化//尾递归优化deffactorialTail(n,acc1){if(n1)returnaccreturnfactorialTail(n-1,n*acc)}factorialTail(100)//支持大数计算六、高阶函数6.1 函数作为参数//函数作为参数defapply(func,x){returnfunc(x)}defdouble(x){returnx*2}defsquare(x){returnx*x}apply(double,5)//10apply(square,5)//256.2 匿名函数//匿名函数LambdadefapplyLambda(func,x){returnfunc(x)}applyLambda(def(x){returnx*3},5)//156.3 内置高阶函数//each对每个元素应用函数 each(def(x){returnx*2},[1,2,3,4,5])//[2,4,6,8,10]//map映射map(def(x){returnx*x},[1,2,3,4,5])//[1,4,9,16,25]//filter过滤filter(def(x){returnx2},[1,2,3,4,5])//[3,4,5]//reduce归约reduce(def(x,y){returnxy},[1,2,3,4,5])//15七、函数进阶7.1 闭包//闭包defmakeCounter(){count0returndef(){count1returncount}}countermakeCounter()counter()//1counter()//2counter()//37.2 函数缓存//函数缓存记忆化defmemoize(func){cachedict()returndef(x){if(cache.has(x)){returncache[x]}resultfunc(x)cache[x]resultreturnresult}}//缓存斐波那契 fibMemomemoize(def(n){if(n0)return0if(n1)return1returnfibMemo(n-1)fibMemo(n-2)})fibMemo(50)//快速计算7.3 函数组合//函数组合defcompose(f,g){returndef(x){returnf(g(x))}}doubledef(x){returnx*2}squaredef(x){returnx*x}doubleThenSquarecompose(square,double)doubleThenSquare(3)//(3*2)^236八、实战案例8.1 数据处理工具函数//数据处理工具函数库//数据标准化defnormalize(data){minValmin(data)maxValmax(data)return(data-minVal)/(maxVal-minVal)}//Z-Score标准化defzscore(data){meanValavg(data)stdValstd(data)return(data-meanVal)/stdVal}//滑动平均defmovingAverage(data,window){resultarray(DOUBLE,data.size())for(iin0..data.size()){if(iwindow-1){result[i]NULL}else{result[i]avg(data[(i-window1):(i1)])}}returnresult}//异常值检测defdetectOutliers(data,threshold3){meanValavg(data)stdValstd(data)returnabs(data-meanVal)threshold*stdVal}//测试 data[1,2,3,4,5,100,6,7,8,9]normalize(data)zscore(data)detectOutliers(data)8.2 工业计算函数//工业计算函数库//温度单位转换defcelsiusToFahrenheit(celsius){returncelsius*1.832}deffahrenheitToCelsius(fahrenheit){return(fahrenheit-32)/1.8}//压力单位转换defbarToPsi(bar){returnbar*14.5038}defpsiToBar(psi){returnpsi/14.5038}//流量计算defcalculateFlow(velocity,area){returnvelocity*area}//能耗计算defcalculateEnergy(power,hours){returnpower*hours//kWh}//OEE计算defcalculateOEE(availability,performance,quality){returnavailability*performance*quality*100}//测试 celsiusToFahrenheit(25)//77calculateOEE(0.9,0.85,0.95)//72.675九、总结本文详细介绍了DolphinDB自定义函数开发函数定义基本语法、返回值参数传递位置参数、默认参数、可变参数作用域局部变量、全局变量递归函数阶乘、斐波那契、尾递归高阶函数函数参数、匿名函数、内置高阶函数函数进阶闭包、缓存、组合思考题如何设计可复用的函数递归和循环如何选择高阶函数有什么应用场景参考资料DolphinDB自定义函数DolphinDB编程指南
