首页
学习
活动
专区
圈层
工具
发布
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Kettle构建Hadoop ETL实践(七):定期自动执行ETL作业

    一旦数据仓库开始使用,就需要不断从源系统给数据仓库提供新数据。为了确保数据流的稳定,需要使用所在平台上可用的任务调度器来调度ETL定期执行。...cron从用户所在的主目录,使用shell调用需要执行的命令。...CDH 6.3.1中的Oozie CDH 6.3.1中,Oozie的版本是5.1.0。在安装CDH时,我们配置使用MySQL数据库存储Oozie元数据。...为了避免不必要的混淆,最好使用HDFS的绝对路径。我们的三个Sqoop动作节点使用这两个属性为Sqoop指定Hive的配置文件和MySQL JDBC驱动包的位置。...(5)合并HiveQL脚本 可以将某些步骤合并到同一个HiveQL脚本中,这会降低Oozie轮询YARN的开销。

    8.3K54

    Kettle构建Hadoop ETL实践(三):Kettle对Hadoop的支持

    export 使用Sqoop将HDFS上的数据导出到一个关系数据库中 Sqoop import 使用Sqoop将一个关系数据库中的数据导入到HDFS上 表3-2 Kettle作业中的大数据相关作业项...通过提交适当的参数,Kettle可以连接Hadoop的HDFS、MapReduce、Zookeeper、Oozie、Sqoop和Spark服务。在数据库连接类型中支持Hive和Impala。...HDFS、MapReduce或Zookeeper服务的IP地址和端口号。 如果要使用Oozie,需要知道Oozie服务的URL。...这四个示例是:向HDFS导入数据;向Hive导入数据;从HDFS抽取数据到MySQL;从Hive抽取数据到MySQL。 1....从Hive抽取数据到MySQL 在Spoon中新建一个如图3-10的转换。转换中只包含“表输入”和“表输出” 两个步骤。

    8.5K21

    HAWQ取代传统数仓实践(五)——自动调度工作流(Oozie、Falcon)

    一旦数据仓库开始使用,就需要不断从源系统给数据仓库提供新数据。为了确保数据流的稳定,需要使用所在平台上可用的任务调度器来调度ETL定期执行。...调度模块是ETL系统必不可少的组成部分,它不但是数据仓库的基本需求,也对项目的成功起着举足轻重的作用。本篇说明如何使用HDP中的Oozie和Falcon服务实现ETL执行自动化。...二、建立工作流前的准备         我们的定期ETL需要使用Oozie中的FS、Sqoop和SSH三种动作,其中增量数据抽取要用到Sqoop job。...在本例中我使用hdp2上的MySQL数据库存储Sqoop的元数据。...Available jobs: myjob_incremental_import         关于使用MySQL作为Sqoop元数据存储的配置,可以参考“Using SQOOP with MySQL

    2.7K60

    0818-7.1.1-如何卸载CDP

    作者:刘元强 数据备份 1.1备份HDFS数据 常见的备份HDFS数据有如下办法: 1.使用distcp将数据拷贝到另外一个Hadoop集群。 2.将数据拷贝到其他存储设备。...3.将数据分批导出到各台主机的各个磁盘上 以上三种方法也可以只使用于关键数据,具体使用哪种方法,可以根据自己集群的规模和数据量大小具体选择。...1.3备份MySQL元数据 mkdir mysql_back cd mysql_back/ #-u后面是mysql用户名,-p单引号中是用户对应的密码,metastore为库名,metastore.sql...删除Cloudera Manager和用户数据 4.1 删除Cloudera Manager数据 1.解除挂载cm_processes sh batch_cmd.sh node.list "umount...最后根据实际情况操作是否remove元数据库MySQL,至此,CDP的卸载完毕。

    1.7K30

    大数据技术分享:Hadoop的相关工具

    Flume Flume可以从其他应用程序收集日志数据,然后将这些数据送入到Hadoop。官方网站声称:“它功能强大、具有容错性,还拥有可以调整优化的可靠性机制和许多故障切换及恢复机制。” ? 7....它让用户可以使用HiveQL查询和管理大数据,这是一种类似SQL的语言。 ? 10. Hivemall Hivemall结合了面向Hive的多种机器学习算法。...它最初是由谷歌开发的,但现在也被本文介绍的另外几个大数据工具所使用,包括CouchDB、MongoDB和Riak。 ? 13. Oozie 这种工作流程调度工具是为了管理Hadoop任务而专门设计的。...Sqoop 企业经常需要在关系数据库与Hadoop之间传输数据,而Sqoop就是能完成这项任务的一款工具。...它可以将数据导入到Hive或HBase,并从Hadoop导出到关系数据库管理系统(RDBMS)。 ? 16. Spark 作为MapReduce之外的一种选择,Spark是一种数据处理引擎。

    53930

    基于Hadoop生态圈的数据仓库实践 —— ETL(三)

    基于这样的背景,Oozie提出了Coordinator的概念,它能够将每个工作流作业作为一个动作来运行,相当于工作流定义中的一个执行节点,这样就能够将多个工作流作业组成一个称为Coordinator Job...的作业,并指定触发时间和频率,还可以配置数据集、并发数等。...Oozie是一种Java Web应用程序,它运行在Java servlet容器——即Tomcat——中,并使用数据库来存储以下内容: 工作流定义 当前运行的工作流实例,包括实例的状态和变量...我们会使用hPDL(一种XML流程定义语言)来描述这个图。 hPDL是一种很简洁的语言,只会使用少数流程控制和动作节点。...Oozie为以下类型的动作提供支持: Hadoop map-reduce、Hadoop文件系统、Pig、Java和Oozie的子工作流(SSH动作已经从Oozie schema 0.2之后的版本中移除了

    1.6K20

    大数据技术分享:Hadoop的相关工具

    Flume Flume可以从其他应用程序收集日志数据,然后将这些数据送入到Hadoop。官方网站声称:“它功能强大、具有容错性,还拥有可以调整优化的可靠性机制和许多故障切换及恢复机制。” ? 7....它让用户可以使用HiveQL查询和管理大数据,这是一种类似SQL的语言。 10. Hivemall Hivemall结合了面向Hive的多种机器学习算法。...它最初是由谷歌开发的,但现在也被本文介绍的另外几个大数据工具所使用,包括CouchDB、MongoDB和Riak。 ? 13. Oozie 这种工作流程调度工具是为了管理Hadoop任务而专门设计的。...Sqoop 企业经常需要在关系数据库与Hadoop之间传输数据,而Sqoop就是能完成这项任务的一款工具。...它可以将数据导入到Hive或HBase,并从Hadoop导出到关系数据库管理系统(RDBMS)。 ? 16. Spark 作为MapReduce之外的一种选择,Spark是一种数据处理引擎。

    63810

    0498-Hue Sqoop1的编辑器中执行Sqoop作业失败问题分析

    本篇文章Fayson主要介绍在使用Hue提供的Sqoop1编辑功能执行Sqoop作业异常问题分析。...测试环境 1.RedHat7.2 2.CM和CDH版本为5.15.0 2 Hue Sqoop1界面运行Sqoop作业 1.登录Hue,进入Sqoop1的编辑器页面 ? ?...该Sqoop脚本主要是用于访问MySQL数据库,并列出MySQL下所有的数据库,从上述运行结果可以看到失败了。 3.点击右上角的“Jobs”菜单,查看作业运行日志 ?...4 解决方式二 由于在Hue中运行Sqoop命令,最终是通过Oozie来进行作业的调度,所以这里我们可以通过将MySQL驱动包放在Oozie的共享库中。...2.Hue上执行Sqoop是基于Oozie,那同样可以将MySQL的JDBC驱动包上传到Oozie的共享库来解决该问题,需要注意的是当CDH版本升级后,需要重新更新Oozie的共享库。

    2.3K10

    针对 Hadoop 的 Oozie 工作流管理引擎的实际应用

    该框架(如图 1 所示)使用 Oozie协调器促进了相互依赖的重复工作之间的协调,您可以使用预定的时间或数据可用性来触发 Apache Oozie。...作为本练习的一部分,Oozie 运行了一个 Apache Sqoop 作业,以便在 MySQL数据库中的数据上执行导入操作,并将数据传输到 Hadoop 分布式文件系统 (HDFS) 中。...可以利用导入的数据集执行 Sqoop合并操作,从而更新较旧的数据集。通过利用 UNIX shell 操作,可从 MySQL 数据库中提取用来执行 Sqoop 作业的元数据。...同理,可执行 Java操作来更新 Sqoop 作业所需的 MySQL 数据库中的元数据。 图 1. Oozie 编排架构 ?...Sqoop 作业通过在 Hadoop 集群上启动MapReduce 作业来完成任务。Sqoop 脚本启动的 MapReduce 作业会将数据从 RDBMS 传输到 HDFS。

    1.7K30

    Hadoop数据分析平台实战——160Sqoop介绍离线数据分析平台实战——160Sqoop介绍

    ...)间进行数据的传递,可以将一个关系型数据库中的数据导进到Hadoop的HDFS中,也可以将HDFS的数据导进到关系型数据库中。...一般情况下,是将数据分析的结果导出到关系型数据库中,供其他部门使用。...案例4:将test表中的数据导出到使用','分割字段的hive表中。 案例5:将test表的数据导入到hdfs中。 案例6:在案例4的基础上,增量导出数据到hdfs中。...export命令 export命令的主要作用是将hdfs文件数据导入到关系型数据库中,不支持从hive和hbase中导出数据,但是由于hive的底层就是hdfs的一个基本文件,所以可以将hive导出数据转换为从...export案例 案例1:将hdfs上的文件导出到关系型数据库test2表中。 案例2:将hive表数据导出到关系型数据库test2表中(使用insertOrUpdate方法导入)。

    1.8K50
    领券