2、 Lines_input:从数据库或者文件读取的行数。 3、 Lines_output:输出的行数。
4、 Lines_updated:数据库表更新的行数。 5、 Lines_read:从先前转换步骤读取的行数。 6、 Lines_written:往下一个步骤写入的行数。 7、 Files_retrieved(取回):从FTP找到的文件数。 8、 Exit_status:Shell脚本退出的状态。
9、 Nr(integer):任务条目数。每下一个条目就会自动增长。 10、 Is windows:如果Kettle运行在windows平台上就返回true。 11、 Javascript:需要运行的脚本,脚本最后一句的结果必须是布尔型。
SFTP(Secure[可靠的] FTP Port:22)
你可以使用SFTP任务条目通过安全的FTP协议在FTP服务器上获取一个或者多个文件。
附录1 :
JS函数
1、 String Functions
date2str(var [,var[,var[,var]]])
startsWith(var,var)/endsWith(var,var) indexOf(var,var[,var]) lower(var) upper(var)
lpad(var,var,var)/rpad(var,var,var) ltrim(var)/ rtrim(var)/trim(var) num2str(var[,var[,var]]) replace(var,var,var) str2RegExp(var,var) substr(var,var[,var]) 2、 Numeric Functions
abs(var)
ceil(var)/floor(var) str2num(var[,var]) trunc(var)
3、 Date Functions
36 / 42
dateAdd(var,var,var) dateDiff(var,var,var) getNextWorkingDay(var)
year(var)/month(var)/week(var)/quarter(var) str2date(var[,var,[var[,var]]]) 4、 Logic Functions
isDate(var) isNum(var)
isRegExp(var,var) 5、 Special Functions
Alert(var)
decode(var,var,var) getEnvironmentVar(var)
getVariable(var,var) :获取变量,例如:var dayno=getVariable(“dayno”,-1) print(var) /println(var) setVariable(var,var,var) writeToLog(var[,var]) 6、 File Functions
copyFile(var,var,var) createFolder(var) deleteFile(var) fileExists(var)
getFileExtension(var) getFileSize(var)
getLastModifiedTime(var) getParentFoldername(var) getShortFilename(var) isFile(var)/isFolder(var) moveFile(var,var,var)
37 / 42
附录2:常用的转换(Transformation)和作业(Job)
38 / 42
==================Kettle=====================
SQL中的一些常用操作在kettle中对应的步骤: 1、 查询:“表输入”,直接输入sql语句进行查询。 2、 插入数据:“插入/更新” 3、 修改:“更新” 4、 删除记录:“删除” 5、 连接:“Merge Join” 6、 分组:“分组” 7、 聚合:“分组” 8、 排序:排序记录 9、 过滤:“过滤记录” ? Get Variables
39 / 42
? Set Variables
? Write to log:输出日志到控制台
? Blocking Step(被冻结的步骤)
这是一个非常简单的步骤。它冻结所有的输出,直到从上一步骤来的最后一行数据到达, 最后一行数据将发送到下一步。你可以使用这个步骤触发常用插件、存储过程和Java Script 等等。Kettle中上一个步骤接收到一部分数据后,这些数据就会流向下一个步骤,所以被冻结的步骤用来等待上面所有的操作都完成。
用来等待上面步骤的数据都到达,例如用来等待文件导出完成。
40 / 42