• 微信公众号:美女很有趣。 工作之余,放松一下,关注即送10G+美女照片!

编写后端接口调用Kettle数据仓库

互联网 diligentman 3小时前 3次浏览

编写后端接口调用Kettle数据仓库

前言

在报表查询统计中我们会用到kettle数据仓库工具,采用定时任务执行kettle转换弹性较小,有时无法满足业务需求,因此需要后端开发人员提供给前端人员一个调用kettle转换的接口。

环境准备

1、jdk

2、kettle(版本采用8.0+,9.0版本缺少配置文件)

步骤

  • kettle安装目录不要太深,并且不要有中文路径。

  • 修改配置文件数据库地址,配置文件为pdi-ce-8.2.0.0-342data-integrationsimple-jndijdbc.properties。要注意连接数据库的方式,在这里我们采用jndi的方式连接数据库
    编写后端接口调用Kettle数据仓库

  • 将pdi-ce-8.2.0.0-342data-integrationsystemkarafsystempentaho文件下的pentaho-mongodb-plugin、pentaho-mongo-utils文件夹复制到pdi-ce-8.2.0.0-342data-integrationplugins下。
    编写后端接口调用Kettle数据仓库
    编写后端接口调用Kettle数据仓库

  • 上面我们就已经将环境准备完成,下面我们进行代码的编写。

		File jndiFile = FileUtil.file("改为你自己simple-jndi文件夹的路径");
        String jndiFilePath = jndiFile.getPath();
        Const.JNDI_DIRECTORY = jndiFilePath;
        File ktrFile = FileUtil.file("要执行的kettle转换文件的具体路径,后缀名也要加上。");
        String ktrFilePath = ktrFile.getPath();
        StepPluginType.getInstance().getPluginFolders().add(new PluginFolder("改为你自己plugins文件夹的具体路径",false,true));//加载插件
        KettleEnvironment.init();//初始化
        TransMeta transMeta = new TransMeta(ktrFilePath);//加载文件
        Trans trans = new Trans(transMeta);
        trans.setVariable("参数名","参数值");//设置参数,如果kettle有需要传入的参数就设置,没有就去掉这行代码。
        trans.execute(null);
        trans.waitUntilFinished();//等待执行完毕

总结

以上就是我们编写调用kettle转换接口的过程,主要就是注意采用kettle8.0版本,配置好上述的环境,代码部分可以让前端动态的传入执行转换的名称以及参数值,增加灵活性。


程序员灯塔
转载请注明原文链接:编写后端接口调用Kettle数据仓库
喜欢 (0)