使用kettle处理HDFS上的数据并写回HDFS

简介: 使用kettle处理HDFS上的数据并写回HDFS

申明: 未经许可,禁止以任何形式转载,若要引用,请标注链接地址

全文共计1530字,阅读大概需要3分钟

一、任务描述

本实验任务主要完成基于ubuntu环境的使用kettle处理HDFS上的数据并写回HDFS的工作。通过完成本实验任务,要求学生熟练掌握使用kettle处理HDFS上的数据并写回HDFS的方法,为后续实验的开展奠定ETL平台基础,也为从事大数据平台运维工程师、大数据技术支持工程师等岗位工作奠定夯实的技能基础。


二、任务目标

1、掌握使用kettle处理HDFS上的数据并写回HDFS


三、任务环境

Ubuntu、Java1.8、Kettle7.1


四、任务分析

Kettle 中文名称叫水壶,该项目的主程序员MATT 希望把各种数据放到一个壶里,然后以一种指定的格式流出。

 Kettle这个ETL工具集,它允许你管理来自不同数据库的数据,通过提供一个图形化的用户环境来描述你想做什么,而不是你想怎么做。

 Kettle中有两种脚本文件,transformation和job,transformation完成针对数据的基础转换,job则完成整个工作流的控制。


五、 任务实施

步骤1、环境准备

在节点master上执行命令【start-all.sh】。如图1所示。


3e6a7bc267344d36b5701a389defa3b0.png


图1 启动Hadoop

 启动成功后,出现以下进程信息。如图2-4所示。


d0483f1de9e746a2bf2d83b19c36a08d.png


图2 master节点进程

 启动kettle。如图3所示


a55998c7c35941f2b90dc4306ac24807.png


图3 启动kettle

 修改语言,Tools->Options->Look&Feel设置,设置完重启即可。如图4所示


3e93a1eaf6294db9b34133d285a6879f.jpg


图4 修改语言


步骤2、创建Transformmations

新建一个”Transformmations”(双击Transformmations也可)。如图5所示


ad754378895044d48806a8e58b61fae4.png


图5 创建Transformmations

 配置hadoop集群连接并测试。如图6-7所示。

979f75e61acb4388ad7c35c60d7d72d1.png



图6 创建集群配置


568f488d6749434492eb4b123e5e1efc.png


图7 集群配置及测试

 创建一个hadoop文件输入步骤,并编辑(双击图表即可)。如图8-11所示。

ecfc6cd6fe79440abf5c07845ce3eaf8.png



图8 创建步骤


e9088bfd682a4b28a75b8881aa8a2f3f.png


图9 设置相关内容


3e34141bec3c4058a56d02a12952546a.png


图10 设置相关内容

1531355449f24dfb98aa9dca6593725c.png



图11 设置相关内容

 创建一个字段选择步骤,按住Shift键,鼠标拖拽“Hadoop File Input“图标到“字段选择“图标上,产生连线,注意箭头方向。,并编辑(双击图表即可)。如图12所示。


c47c7a780f1e4daea0d93fe75c60b647.png


图12 创建步骤并设置

 创建一个剪切字符串步骤,按住Shift键,鼠标拖拽“字段选择“图标到“剪切字符串“图标上,产生连线,注意箭头方向,并编辑(双击图表即可)。如图13所示。


c63f4bc6281045c38ddfcb56abfde62e.png


图13 创建步骤并设置相关内容

 创建一个过滤记录步骤,按住Shift键,鼠标拖拽“剪切字符串“图标到“过滤记录“图标上,产生连线,注意箭头方向,并编辑(双击图表即可)。如图14所示。

613c3b46e6ad433cb746d9f5658c2f8a.png



图14 创建步骤并设置相关内容

 创建一个过滤记录步骤,按住Shift键,鼠标拖拽“过滤记录“图标到“Hadoop File Output“图标上,产生连线,注意箭头方向,并编辑(双击图表即可)。如图15-18所示。

3d1d3afb81d245f6b99f6b27076eed02.png



图15 创建步骤


dad56ee6e23744a6a54e783a10fbf746.png


图16 设置相关内容

21c0004d703c4a8b948278f5b62d01d1.png



图17 设置相关内容


e2256cda33684e5da59f409cbc3a2735.png


图18 设置相关内容


步骤3、运行任务

运行,清洗好的数据,批量导入到HDFS系统。如图19-20所示。


3a3a9356cb914f18bbbdb4b20b36237d.png


图19 运行任务


59fcb2c12264462488ee96f9b7188697.png


图20 保存任务

 查看运行结果。如图21所示。


ddd90fbb3edf41c6b0e3651103303286.png


图21 查看运行结果

 重新打开一个终端,检验记录是否导入。如图22所示。


dcda934c7b6743ec9c07710a1aa21e80.png


图22 查看数据


♥ 知识链接

Step

转换的一个步骤,可以是一个Stream或是其他元素。


♥ 温馨提示

Spoon 是一个图形用户界面,它允许你运行转换或者任务,其中转换是用Pan 工具来运行,任务是用Kitchen 来运行。Pan 是一个数据转换引擎,它可以执行很多功能,例如:从不同的数据源读取、操作和写入数据。Kitchen 是一个可以运行利用XML 或数据资源库描述的任务。通常任务是在规定的时间间隔内用批处理的模式自动运行。


相关文章
|
4月前
|
存储 分布式计算 Java
HDFS的数据读取流程是怎样的?请描述数据读取的过程。
HDFS的数据读取流程是怎样的?请描述数据读取的过程。
32 0
|
4月前
|
Java API
HDFS的数据写入流程是怎样的?请描述数据写入的过程。
HDFS的数据写入流程是怎样的?请描述数据写入的过程。
21 0
|
5月前
|
存储 Linux
[hadoop3.x]HDFS之银行海量转账数据分层案例(八)
[hadoop3.x]HDFS之银行海量转账数据分层案例(八)
110 1
|
10月前
|
消息中间件 存储 分布式计算
Flume实现Kafka数据持久化存储到HDFS
Flume实现Kafka数据持久化存储到HDFS
436 0
|
10月前
|
存储 大数据
大数据数据存储的分布式文件系统的HDFS的核心机制理解的数据读/写原理
在 Hdfs 中,数据的读写原理是基于块的分布式存储。
53 0
|
6月前
|
算法 数据中心
HDFS数据的读写流程
HDFS数据的读写流程
45 0
|
7月前
|
SQL 分布式计算 大数据
大数据问题排查系列 - 因HIVE 中元数据与HDFS中实际的数据不一致引起的问题的修复
大数据问题排查系列 - 因HIVE 中元数据与HDFS中实际的数据不一致引起的问题的修复
|
8月前
|
存储 分布式计算 负载均衡
HDFS服役新数据节点和退役旧节点步骤
HDFS服役新数据节点和退役旧节点步骤
198 1
|
8月前
|
缓存 分布式计算 负载均衡
HDFS 的写数据流程分析
HDFS的写数据流程是一道比较常见的面试题,同时梳理了写流程也可以帮助我们更加深入一点的了解 HDFS 的主要原理和各个组件的交互过程
|
9月前
|
JSON 缓存 关系型数据库
5、DataX(DataX简介、DataX架构原理、DataX部署、使用、同步MySQL数据到HDFS、同步HDFS数据到MySQL)(二)
5、DataX(DataX简介、DataX架构原理、DataX部署、使用、同步MySQL数据到HDFS、同步HDFS数据到MySQL)(二)

相关实验场景

更多