Kettle——大数据ETL工具

news2024/11/23 23:19:56

文章目录

  • ETL
  • 一、Kettle
  • 二、安装和运行Kettle
  • 三、Kettle使用
  • 四、Kettle核心概念
    • 可视化
    • 转换
    • 步骤

ETL

ETL(Extract-Transform-Load,即数据抽取、转换、转载),对于企业或行业应用来说,我们经常会遇到各种数据的处理,转换,迁移,所以了解并掌握一种ETL工具的使用,必不可少。
市面上常用的ETL工具有很多,比如Sqoop,DataX,Kettle,Talend等,作为一个大数据工程师,我们最好要掌握其中的两到三种。

一、Kettle

Kettle是一款国外开源的ETL工具,用纯Java语言编写,可以在Windows、Linux、UNIX上运行,数据抽取高效稳定。它支持图形化的GUI设计界面,而且可以以工作流的形式流转,在数据抽取、质量检测、数据清洗、数据转换、数据过滤等方面有着比较稳定的表现。此外,Kettle中有两种脚本文件——转换和作业,转换完成针对数据的基础转换,作业则完成整个工作流的控制。
Kettle中有两种脚本文件,transformation和job,transformation完成针对数据的基础转换,job则完成整个工作流的控制。
Kettle的特点:开源免费,可维护性好,便于调试,开发简单。
核心组件
Spoon.bat/spoon.sh:是一个图形化界面,可以让我们的图形化的方式转换和作业(Windows选择Spoon.bat;Linux选择Spoon.sh)
Pan.bat/pan.sh:利用Pan可以用命令行的形式执行由Spoon编辑的转换和作业
Kitchen.bat/kitchen.sh:利用Kitchen可以使用命令行调用由Spoon编辑好的job
Carte.bat/Carte.sh:Carte是一个轻量级的Web容器,用于建立专用、远程的ETL Server

二、安装和运行Kettle

Kettle是基于Java开发的,因此需要Java环境,也就是要先安装JDK工具包。
 下载Kettle,解压到任意目录。
 启动Kettle。安装完成之后,双击spoon.bat批处理程序即可启动Kettle。
在这里插入图片描述
kettle启动界面。
在这里插入图片描述
根据数据库,将数据库的驱动jar包放到xxxx\pdi-ce-7.1.0.0-12\data-integration\lib目录下,重启spoon即可。

三、Kettle使用

配置资源库与数据库
重新双击spoon.bat,运行Kettle工具。
点击右上角connect标志,点击Other Repositories。如下图:

在这里插入图片描述
在弹窗中选择Database Repository选项,点击Get Started
在这里插入图片描述
输入资源库名称(自定义),点击Database Connection创建数据库连接。
在这里插入图片描述
点击创建新的数据库连接,根据需求选择连接方式,默认选一般;数据库连接名称(自定义);连接类型,什么数据库就选择什么;连接方式,默认选第一个;最后再将数据库连接信息,信息填好后,点击测试,连接成功后点击确定即可。
在这里插入图片描述
数据库连接成功,在database Connection中即可选择刚才建立的数据源。点击Finish,选择Conncect Now,进入登录页面,默认是admin用户,密码也是admin。
在这里插入图片描述
将CSV文件转换为Excel,选择CSV文件输入、Excel输出拖入操作面板,连接后点击左上角三角运行。
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

四、Kettle核心概念

可视化

Kettle可以被归类为可视化编程语言,因为kettle可以使图形化的方式定义复杂的ETL程序和工作流。
可视化编程一直是kettle里的核心概念,它可以让你快速构建复杂的ETL作业和减低维护工作kettle里的代码就是转换和作业。

转换

转换负责数据的输入、转换、校验和输出等工作。kettle中使用转换完成数据ETL全部工作。转换由多个步骤组成,如文本文件输入,过滤输出行,执行SQL脚本等。各个步骤使用跳(Hop)(连接箭头)来链接。跳定义了一个数据流通道,即数据由一个步骤流跳向下一个步骤。在kettle中数据的最小单位是数据行(row),数据流中流动其实是缓存的行集(RowSet)

步骤

步骤(控件)是转换里的基本的组成部分,‘CSV文件输入’和‘Excel输出’。
一个步骤有几个关键特性:
步骤需要有一个名字,这个名字在同一个转换范围内唯一
每个步骤都会读、写数据行(唯一例外是“生成记录”步骤,该步骤只写数据)
步骤将数据写到与之相连的一个或多个输出跳(hop)再传送到跳的另一端的步骤。
大多数的步骤都可以有多个输出跳。一个步骤的数据发送可以被设置为分发和复制,分发是目标步骤轮流接收记录,复制是所有的记录被同时发送到所有的目标步骤。

跳就是步骤之间带箭头的连线,跳定义了步骤之间的数据通路
跳实际上时两个步骤之间的被称为行集的数据行缓存,行集的大小可以在转换的设置里定义。当行集满了,向行集写数据的步骤将停止写入,直到行集里又有了空间。当行集空了,丛行集读取数据的步骤停止读取,直到行集又有可读的数据行。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1006559.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【操作系统】进程的概念、组成、特征

概念组成 程序:静态的放在磁盘(外存)里的可执行文件(代码) 作业:代码+数据+申请(JCB)(外存) 进程:程序的一次执行过程。 …

5. 自动求导

5.1 向量链式法则 ① 例子1是一个线性回归的例子,如下图所示。 5.2 自动求导 5.3 计算图 5.4 两种模型 ① b是之前计算的结果,是一个已知的值。 5.5 复杂度 5.6 自动求导 import torch x torch.arange(4.0) x 结果: ② 在外面计算y关于x的…

linux 用户、组操作

一、创建用户并设置密码 #创建用户 duoergun useradd duoergun #设置用户 duoergun 密码 passwd duoergun二、创建组 #创建组 qingdynasty groupadd qingdynasty三、用户添加到组,用户从组删除 #添加用户duoergun到组qingdynasty usermod -aG qingdynasty duoer…

【CSS】React项目如何在CSS样式文件中使用变量

需求 在修改样式时候,需要根据不同条件,使用不同的样式,使用动态类需要多重判断,是否考虑使用变量传入的方式呢 应该怎么做 tsx import ./App.css; import ./test.cssfunction App() {const styles {--var: white,};return (…

20230912java面经整理

1.gc算法有哪些 引用计数(循环引用)和可达性分析找到无用的对象 标记-清除:简单,内存碎片,大对象找不到空间 标记-复制:分成两半,清理一半,没有碎片,如果存活多效率低&a…

Bigemap 在土地图利用环境生态行业中的应用

工具 Bigemap gis office地图软件 BIGEMAP GIS Office-全能版 Bigemap APP_卫星地图APP_高清卫星地图APP Bigemap 在土地图利用环境生态行业中的应用  使用场景 : 1. 土地利用占地管理: 核对数据,查看企业的实际占地是否超出宗地&…

电商运营管理——广告系统

广告位对于电商平台而言,具有非常重要的作用。如何设计一个广告位是本篇文章重点讲述的内容,作者从六个方面出发,系统地介绍该如何去搭建一个广告位,能为产品设计的同学提供一些思路。 对于电商平台,广告位无论是对产品…

制造业企业使用哪种ERP系统好?金蝶还是用友?

制造业企业使用哪种ERP系统好?金蝶还是用友? 综合来看,这几位都算是是典型的ERP软件,它有着ERP软件应该有的基础功能,并且做的也比较成熟。下面是本文对这几个软件的总结 金蝶: 优势:1.产品丰…

mysql逻辑备份和恢复

备份恢复指令 1 全备 (变量为密码、端口号、输出路径。 --compress支持压缩) mysqldump -uroot -p*** -P*** --single-transaction --master-data2 --flush-logs --hex-blob --flush-privileges --triggers --routines --events --all-databases > …

【100天精通Python】Day61:Python 数据分析_Pandas可视化功能:绘制饼图,箱线图,散点图,散点图矩阵,热力图,面积图等(示例+代码)

目录 1 Pandas 可视化功能 2 Pandas绘图实例 2.1 绘制线图 2.2 绘制柱状图 2.3 绘制随机散点图 2.4 绘制饼图 2.5 绘制箱线图A 2.6 绘制箱线图B 2.7 绘制散点图矩阵 2.8 绘制面积图 2.9 绘制热力图 2.10 绘制核密度估计图 1 Pandas 可视化功能 pandas是一个强大的数…

在 Python 中实现 DBSCAN

一、说明 DBSCAN(Density-Based Spatial Clustering of Applications with Noise)聚类是一种基于密度的聚类算法。它能够根据数据点的密度来将数据划分为不同的类别,并可以自动识别离群点。DBSCAN聚类算法的核心思想是将密度高的数据点划分为…

MacVim for Mac:强大的文本编辑器,提升你的编程体验

在Mac上,有这样一款独特的文本编辑器——MacVim for Mac,它以其强大的功能和出色的性能,吸引了广大的程序员和编程爱好者。这款编辑器不仅继承了Unix编辑器Vi的强大功能,更通过创新的设计和功能拓展,提供了一款更完整、…

批量上传文件,以input上传文件,后端以List<MultipartFile>类型接收

批量上传文件,以input上传文件,后端以List类型接收 一、后端接口二、前端对接三、测试 最近公司要求要做一个批量上传文件的功能,以往做的导入Excel表格、上传图片都是上传一个文件的,此次在开发的过程中着实让我犯了难&#xff0…

vue Echarts饼图指定颜色与数据对应

需求:一般自定义颜色是按照数据的顺序依次对应,现在想要指定字段对应某个颜色 因为是直接在返回数据中做操作,所以直接写这部分的代码 数据格式 cdata: {xData: ["水文", "森林", "气象", "地质",…

学习笔记|外部中断|INT0|中断列表|STC32G单片机视频开发教程(冲哥)|第十五集:中断系统和外部中断

文章目录 1.中断和中断系统1.1什么是中断?1.2什么是中断系统1.3中断系统的优点1.4 中断系统包含哪些中断源1.5.中断次序 2.什么是外部中断3.外部中断的用法4.外部中断的用法完整代码 总结课后练习: 上节课我们学完了GPIO的矩阵按键,已经把这个GPIO的一个外设全都已…

最小二乘法的实现与线性回归的应用

1. 简介 简单线性回归中,您有一个因变量y和一个自变量X。该模型可以表示为: y m x b ymxb ymxb 其中 x x x: 自变量 y y y: 因变量 m m m: 斜率 b b b: 截距 最小二乘法是回归分析中用于估计线性回归模型参数的标准方法。它可以最小化误差的平方和&…

SpringBoot课堂笔记20230913

本篇文章为SpringBoot学习笔记,方便自己再复习。 Maven:jar包管理工具 注解: Controller:处理http请求,返回的视图 RestController: 相当于ResponseBody和Controller一起用,返回的是json ResponseBody:返回响应内容 …

客户关系管理的定义及三种常见的CRM系统

CRM旨在加强企业与客户的关系,建立以客户为中心的经营策略。随着技术的迅速发展,CRM的实施变得更加普遍,不仅能帮助企业与客户建立紧密联系,还能实现客户细分开展个性化的营销活动。客户关系管理是什么,CRM怎么分&…

【MySQL】数据库的操作

目录 前言 创建数据库 编码集和校验集 不同校验集的区别 删除数据库 确认当前数据库 查看数据库属性 修改数据库属性 备份与还原 数据库和表的备份 还原 创建表 查看列结构 查看表属性 修改表的列 修改表名称 修改列名称 删除表 前言 在上一篇文章中&#…

什么是生成对抗网络 (GAN)?

什么是生成对抗网络 (GAN)? 钦吉兹赛义德贝利 一、说明 GAN(Generative Adversarial Network)网络是一种深度学习模型,由两个神经网络——生成器和判别器组成。生成器负责生成虚假的数据,而判别…