0.新建转换的常用组件
0. Generate rows 定义一个字符串 name value就是字符串的值
0.1 String operations 字段转大写 去空格
1. Json input 来源于一个json文件 1.json 或mq接收到的data内容是json字符串
2. Json output 定义Jsonbloc值为 data, 左侧Fieldname是数据库查询的值, Element name是驼峰,即json的key
3. Get data from XML Content的LoopXPath选择 /MSG 或 /users/user
4. Database join 写一个select name as username from user where user_card=?; 那么后面就可以直接用username
4.1 Database lookup 查询数据库的某一张表, 返回字段供后续使用, 没有 Database join 灵活
5. Select values 将几步的变量选择出来,并rename
6. insert / update 插入或更新表
7. Filter rows 选择Condition, 即AirStandList != null
8. Get rows 比如mq输出的字段是data,这里Field name就是data String类型
9. Modified JavaScript value 对入参的值进行修改,赋值给另一个变量 如 var name=username.substr(0,2);
10. Dummy (donothing) 什么也不做
注意事项: 转换调用转换, 那么相对路径是: ${Internal.Entry.Current.Directory}/my_transfer1. Get data from XML 组件为列
1. 新建资源库(推荐使用文件资源库)
D盘新建一个名为kettle文件夹 作为 文件资源库, 存放 .kdb文件(即数据库连接信息 账号 密码 url等) .ktr文件(即我们的转换脚本)
2. 新建转换 并 创建 数据库连接(数据库连接信息即存到了本地资源库D盘下)
3.打开本地资源库下的转换脚本
4.kettle.properties文件
如配置rabbitUrl的值, 并使用${rabbitUrl}来取值. 生产环境服务器也有一个 kettle.properties文件. 编辑为生产的值 即可.
下图是windows电脑的kettle.properties
