使用 Springboot 对 Kettle 进行调度开发

1、新建boot项目，导入所需的kettle jar包（在kettle /lib目录下可找到）

2、配置kettle采集转换流程

3、关键代码编写

@SpringBootTest
class MyKettleTests {

    private String filename = "D://Dev//kettle//kettle-workspace//from-to-table.ktr";

    @Test
    public void testTransEtl(){
        try {
            KettleEnvironment.init();
            TransMeta transMeta = new TransMeta(filename);
            Trans trans = new Trans(transMeta);

            // 设置变量(这些变量可以在.ktl中通过${variableName}来引用)
            /*String beginTime = "2019-11-18 17:30:00";
            String endTime = "2019-11-18 23:59:59";
            trans.setVariable("beginTime", beginTime);
            trans.setVariable("endTime", endTime);*/

            trans.execute(null);
            trans.waitUntilFinished();
        } catch (KettleException e) {
            e.printStackTrace();
        }
    }

}

4、运行测试