kettle:mongdb与mysql互传数据

注:部分内容引用了 http://blog.sina.com.cn/s/blog_4ac9f56e0101g881.html
1、mongodb传数据到mysql
1)在kettle中,mongodb input组件。

2)编辑组件
输入连接信息

选择数据库

写查询语句

选择字段。上面的复选框选择是否输入json格式,这时不选。
点击get fileds,获取字段对应关系。
$代表根目录
.代表子目录
[]代表数组中的值,例如:
  1. {"data" :{
  2. "museum":[
  3. {
  4. "country":"italy",
  5. "city": "Vencie",
  6. "id_museum":"109",
  7. "name":"pa"},
  8. {
  9. "country":"Mexico",
  10. "city": "Mexico city",
  11. "id_museum":"36",
  12. "name":"Musre"}
  13. ]
  14. }
  15. }
  16. $..city表明元素city是在根节点下data节点内的museum节点内。
  17. $.data.museum[1].city表明指定的元素,即上述museum数组第二个节点的city
预览数据



3)表输出
选择  “输出-表输出”组件。
连接mongodb输入组件和表输出组件。

编辑表输出



4)执行转换



二、mysql数据迁移到mongodb
1)选择“表输入”组件,编辑表输入



2)选择 ”bigdata-mongodb ouput"组件
把两个组件相连。
编辑mongodb output组件

输入连接信息

输入数据数据和集合(没有集合自动创建)

点击获取字段

3)执行转换











原文地址:https://www.cnblogs.com/skyrim/p/5083168.html