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)执行转换

来自为知笔记(Wiz)

时间: 2024-10-05 04:58:30

KETTLE:mongdb与mysql互传数据的相关文章

springmvc和easyui使用ajax前台后台互传数据,假删除提示警告问题。

前台 //删除 多/单条数据 function del(cid){ var id=''; if(cid=='-1'){ if(getSelections().length > 0){ id=getSelections(); }else{ $.messager.alert("提示", "请选择要删除的行", "error"); return; } }else{ id=cid; } var arr =id.split(":"

jquery下php与ajax的互传数据自我总结

研究了一整天的json数据与ajax的数据传输,现在进行一个小的自我总结,仅供参考 1.关于ajax的认识 $.ajax(),是jquery下包装好的一个函数.http://www.w3school.com.cn/jquery/ajax_ajax.asp 使用其跟php段进行通信. <script type="text/javascript">  //jquery直接进行ajax的包装调用       $(function(){                       

Docker跨主机容器互传数据问题及解决方法

目前我这里docker主要使用1.5版本,用途是给研发.运维做测试环境,给游戏与平台业务做生产应用,昨天接到某游戏研发反馈,2个不同宿主机进行数据同步的时候,出现以下错误 orrupted MAC on input. Disconnecting: Packet corrupt lost connection 经过谷歌搜索发现问题原因是 "Corrupted MAC on input" This situation happens when the packet is decrypted

共享内存——如何在本地没有句柄的两个地方互传数据

一直对匿名管道这个名字有着相当的兴趣,然而至今没有完全弄明白匿名管道的原理,可能本人的记忆属于感觉型的,没有经历过的东西印象始终不深,以至于一些技术虽然当时理解了,一段时间之后使大抵的都忘了. 现在有一种更简单,且觉得相当实用的数据传递方法,记录下来以加深记忆. 共享内存 其实微软件的sendmessage.postmessage内部实现也使用了内存共享技术,该技术初衷是用于解决大文件的频繁读写操作,通过创建一个内核对象的方式,将文件直接映射在内存中,并且提交物理内存到该内存空间,如此一来省去了

Jquery AJAX 简单实现前台后台互传数据

AJAX是一个很强大的东西,之前写过一篇 AJAX Servlet异步交互 ,是放在请求的url上进行实现的,放在Url上长度有限,如果想保存很长的东西,例如博客这样的就不行了! 导包: 主要是json.jar这个包,其他的是ueditor的包! 前台代码:(这是部分主要的代码,省略了ueditor的代码) //引入easyui的一些插件 <link rel="stylesheet" type="text/css" href="jquery-easy

MultCloud – 支持数据互传的网盘管理

MultCloud https://www.multcloud.com/ 是一款在线服务,可以在一个地方管理众多网盘,支持国产百度盘, 最具有特色的地方是你可以直接在 MultCloud 里操作将 Dropbox 的文件传输到百度盘中. MultCloud 支持的国外网盘较多, Dropbox.Google Drive.Skydrive.Amazon S3.SugarSync. Box.Copy,CloudMe.Cubby.MyDriver.WEB.DE.Yandex. HiDrive 以及 W

Linux字符设备-内核态数据与用户态数据互传

_IO,_IOR,_IOW和_IORW的含义 对于系统支持设备的ioctl号,你可以在/usr/include下面的头文件中找到,对于你自己的设备,如果需要使用ioctl接口,则需要定义自己 的ioctl号.以前的2.4中有个问题是,大家都随便定义自己的ioctl号,造成很大可能性的重复性.一个坏处是难以管理,另外一个是容易造成错误, 例如如果用户本来希望打开一个串口设备,结果通过open打开了网口,如果串口的某个ioctl号正好是网口的关闭操作,这样就会造成错误.在2.6里 面,你定义自己的i

Struts , Jsp 上传数据乱码问题

今天拿出以前的代码,想重构.却发现运行起来都是乱码,原来都是好好的.心里一着急,就上网去搜索答案. 看了一大堆的Struts中文乱码解决办法. 我总结一下,(1)Jsp方面,最好写上<%@ page pageEncoding="UTF-8" contentType="text/html;charset=UTF-8"%> (2) Struts.xml配置上,配置i18n.encoding 属性,值也为UTF-8(最好!) (3) 如果还是不行,则就要自己写

一步一步跟我学习hadoop(7)----hadoop连接mysql数据库运行数据读写数据库操作

为了方便 MapReduce 直接訪问关系型数据库(Mysql,Oracle).Hadoop提供了DBInputFormat和DBOutputFormat两个类.通过DBInputFormat类把数据库表数据读入到HDFS,依据DBOutputFormat类把MapReduce产生的结果集导入到数据库表中. 执行MapReduce时候报错:java.io.IOException: com.mysql.jdbc.Driver,通常是因为程序找不到mysql驱动包.解决方法是让每一个tasktrac