本文共 816 字，大约阅读时间需要 2 分钟。

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

2、配置kettle采集转换流程

3、关键代码编写

@SpringBootTestclass 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、运行测试

转载地址：http://dqoji.baihongyu.com/