IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 数据清洗第三章(kettle工具的使用)转换和作业实例 -> 正文阅读

[大数据]数据清洗第三章(kettle工具的使用)转换和作业实例

一.转换实例

1、数据准备

在SQLyog中创建一个数据库,并在该数据库中导入两张数据表,即数据表personal_a和数据表personal_b。

导入过程如下图

?数据表personal_a和personal_b如下图所示。

表personal_a

表personal_b

2、打开kettle工具,创建转换

创建转换LCT,并添加“表输入”控件、“JavaScript代码”控件、“插入/更新”控件以及跳连接线,如下图。

3、配置“表输入”控件?

点击表输入控件,进入表输入界面,点击新建按钮,配置数据库连接,并正确连接上数据库LCT

?单击“获取SQL查询语句”按钮,弹出“数据库浏览器”窗口,展开LCT,并选中“表”菜单下的数据表personal_a,如下图所示。

点击下图的“确定”按钮。

点击确定按钮完成“表输入”控件的配置。

4、配置“JavaScript"控件

双击进入“JavaScript代码"控件界面,在下图代码窗口编写JavaScript脚本代码,然后单击“获取变量”按钮,在字段窗口的“改名为”字段处添加新的字段名称username。

?点击确定按钮,完成JavaScript控件的配置。

5、配置“插入/更新”控件

双击进入“插入/更新”控件界面,点击“新建”按钮,配置数据库连接。

点击目标表右侧的“浏览按钮”,弹出“数据库浏览器”窗口,展开LCT1,并选中“表”菜单下的数据表personal_b。

?单击确定,完成目标表的选择。如下图所示。

?

点击“获取字段”按钮,用来指定查询数据需要的关键字,这里选择的是数据表personal_b中的id_b字段和输入流里的id字段,如下图。

?点击“编辑映射”按钮,弹出“映射匹配”窗口,点击“猜一猜”按钮,让Kettle自动实现映射。

点击确定按钮,完成原字段与目标字段的映射匹配。

6、运行转换LCT

点击转换工作区顶部的执行按钮,运行创建的转换LCT,实现将数据表personal_a中的surname字段和name字段进行拼接,并将结果数据插入到表personal_b中。

从下图的执行结果一栏的“步骤变量”选项卡中可以看出,?表输入控件执行7行数据的写入和输入操作。

7、查看数据表personal_b中的数据

?通过SQLyog工具,查看数据表personal_b是否已经插入7条数据。

二、作业实例

1、打开kettle工具,创建作业

创建作业send_email,添加Start控件,“发送邮件”控件 、“成功”控件以及作业跳连接线

2、配置Start控件

双击Start控件,进入“作业定时调度”界面

单击“类型”后的下拉列表框,选择“时间间隔”定时,并设置以秒计算的时间间隔是10。

?点击“确定”按钮,完成Start控件的配置。

3、配置“发送邮件”控件

双击“发送邮件”控件,进入“发送邮件”界面。

添加收件人和发件人的相关信息

点击“服务器”选项卡,添加邮件服务器的相关参数和验证发件人的信息。

?ps:这里的密码是qq关于IMAP/SMTP服务的授权码,需要短信验证。如下图

点击邮件消息选项卡,“勾选信息里带日期?”和“使用HTML邮件格式?”并添加主题和注释,如图?

4、运行send_email作业

单击作业工作区顶部的运行按钮,运行send_email作业,实现邮件的发送功能

5、查看邮箱的收件箱

?到此结束。

?

?

?

?

?

?

?

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-09-28 00:10:17  更:2021-09-28 00:10:40 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/27 14:44:58-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码