1、新建 转换t_baidu_citycongestion
2、新建 DB连接:yuanshujuku
主机名称:10.2.111.235
数据库名称:orcl
用户名:ehl_tfm
密码:ehl1234
3、新建 DB连接:mubiaoshujuku
主机名称:10.2.111.236
数据库名称:ehl
用户名:ehl_tfm
密码:ehl1234
4、新建 获取系统信息1
名称:data
类型 选择 系统日期(可变)
5、新建 表输入(在核心对象的输入子项)
6、用连接线连接“获取系统信息1”和“表输入”
7、打开 表输入
步骤名称:表输入
数据库连接:yuanshujuku
SQL:SELECT * FROM t_baidu_citycongestion WHERE datetime>?-10/1440
替换SQL语句里的变量 √
从步骤插入数据:获取系统信息1
执行每一行? √
8、新建 表输出(在核心对象的输出子项)
9、用连接线连接“表输入”和“表输出”
10、打开 表输出
步骤名称:表输出
数据库连接:mubiaoshujuku
目标表:t_baidu_citycongestion
11、新建 获取系统信息2
名称:data1
12、新建 执行SQL脚本(在核心对象的脚本子项)
13、用连接线连接“获取系统信息2”和“执行SQL脚本”,选择“主输出步骤”
14、打开 执行SQL脚本
步骤名称:执行SQL脚本
数据库连接:mubiaoshujuku
SQL:delete from t_baidu_citycongestion where datetime>to_timestamp('?','yyyy-MM-dd HH24:MI:SS:ff9')-10/1440
点击“获取字段”
变量替换 √
执行每一行? √
15、用连接线连接“表输出”和“执行SQL脚本”,选择“主输出步骤”
1、新建 转换t_baidu_roadrank
2、新建 DB连接:yuanshujuku
主机名称:10.2.111.235
数据库名称:orcl
用户名:ehl_tfm
密码:ehl1234
3、新建 DB连接:mubiaoshujuku
主机名称:10.2.111.236
数据库名称:ehl
用户名:ehl_tfm
密码:ehl1234
4、新建 获取系统信息1
名称:data
类型 选择 系统日期(可变)
5、新建 表输入(在核心对象的输入子项)
6、用连接线连接“获取系统信息1”和“表输入”
7、打开 表输入
步骤名称:表输入
数据库连接:yuanshujuku
SQL:SELECT * FROM t_baidu_roadrank WHERE datetime>?-10/1440
替换SQL语句里的变量 √
从步骤插入数据:获取系统信息1
执行每一行? √
8、新建 表输出(在核心对象的输出子项)
9、用连接线连接“表输入”和“表输出”
10、打开 表输出
步骤名称:表输出
数据库连接:mubiaoshujuku
目标表:t_baidu_roadrank
11、新建 获取系统信息2
名称:data1
12、新建 执行SQL脚本(在核心对象的脚本子项)
13、用连接线连接“获取系统信息2”和“执行SQL脚本”,选择“主输出步骤”
14、打开 执行SQL脚本
步骤名称:执行SQL脚本
数据库连接:mubiaoshujuku
SQL:delete from t_baidu_roadrank where datetime>to_timestamp('?','yyyy-MM-dd HH24:MI:SS:ff9')-10/1440
点击“获取字段”
变量替换 √
执行每一行? √
15、用连接线连接“表输出”和“执行SQL脚本”,选择“主输出步骤”
1、新建 作业baidu
2、新建 DB连接:yuanshujuku
主机名称:10.2.111.235
数据库名称:orcl
用户名:ehl_tfm
密码:ehl1234
3、新建 DB连接:mubiaoshujuku
主机名称:10.2.111.236
数据库名称:ehl
用户名:ehl_tfm
密码:ehl1234
4、新建 START(在核心对象的通用子项)
名称:data
类型 选择 系统日期(可变)
5、新建 DUMMY(在核心对象的通用子项)---支持循环作用
6、用连接线连接“START”和“DUMMY”
7、新建 转换t_baidu_roadrank(在核心对象的通用子项)---对应t_baidu_roadrank.ktr
转换文件名:C:\Users\Administrator\Desktop\t_baidu_roadrank.ktr
8、新建 转换t_baidu_citycongestion(在核心对象的通用子项)---对应t_baidu_citycongestion.ktr
转换文件名:C:\Users\Administrator\Desktop\t_baidu_citycongestion.ktr
9、用连接线连接“DUMMY”和“转换t_baidu_roadrank”
10、用连接线连接“DUMMY”和“转换t_baidu_citycongestion”
标签:baidu,连接线,新建,kettle,spoon,名称,SQL,看板,连接 From: https://www.cnblogs.com/dabao150114/p/16716687.html