Kettle实现从mysql中取2张表数据关联的数据,并写入到mongodb中

Posted on Posted in kettle示例

1 建立转换,并设置DB连接到mysql

选中DB连接:连接类型选择MySQL,输入主机名称,数据库名称,端口号,用户名,密码

输入连接名称,点击确定。(可以先点击测试,测试一下是否连接成功)

如下图:

 

 2 选择输入》表输入,拖动到主面板中,双击进行设置

(1)输入步骤名称;选择数据库连接

如下图:

(2)点击获取SQL查询语句按钮,选择对应的表t_bulo_storage_collect_201808

如下图:

(3)根据实际情况增加where之后的查询条件,然后点击确定,完成此表输入的全部设置。如下图:

 

3 按照步骤2的方法,再建立一个表输入,名称为t_bulo_storage_info

具体sql如图:

 4 分别将两个表进行排序

使用转换》排序记录 组件,如果不使用该组件,就在步骤2 3中的sql语句中使用order by进行排序。

关于排序的使用具体可以参考另外一篇文章:https://www.cnblogs.com/kxm87/p/9600098.html

排序如图:

 

 5 将两个排序结果集进行连接

使用连接》记录集连接 组件

选择第一个步骤,第二个步骤,连接类型,和连接字段

具体设置如下图:

6 将步骤5中的连接结果写入到mongodb中

使用Big Data》MongoDB Oupt 组件

具体设置如下:

https://www.cnblogs.com/kxm87/p/9674209.html