kettle从sftp下载多个文件并进行转换后输出

2018-09-12 本文已影响617人 GuangHui

一. 主流程梳理

主流程

1 获取sftp上对应文件的存放路径;
2 从sftp下载指定的文件到指定的目录;
3 从下载后的指定目录,获取数据进行转换操作;

二. 获取ftp路径

获取ftp路径

1. 生成记录

生成记录
此处要注意: 限制为1;

2. JavaScript代码

JavaScript代码

可通过点击测试脚本按钮测试脚本执行是否正确.

//Script here
Date.prototype.Format = function (fmt) { 
    var o = {  
        "M+": this.getMonth() + 1, //月份   
        "d+": this.getDate(), //日   
        "h+": this.getHours(), //小时   
        "m+": this.getMinutes(), //分   
        "s+": this.getSeconds(), //秒   
        "q+": Math.floor((this.getMonth() + 3) / 3), //季度   
        "S": this.getMilliseconds() //毫秒   
    };  
    if (/(y+)/.test(fmt)) fmt = fmt.replace(RegExp.$1, (this.getFullYear() + "").substr(4 - RegExp.$1.length));  
    for (var k in o)  
    if (new RegExp("(" + k + ")").test(fmt)) fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ? (o[k]) : (("00" + o[k]).substr(("" + o[k]).length)));  
    return fmt;  
}  
  
var url=new Date(new Date().getTime()).Format("yyyyMMdd");