美文网首页
java大数据之引言

java大数据之引言

作者: 这一刻_776b | 来源:发表于2020-01-17 13:24 被阅读0次

    一、大数据概述

    1.1大数据有哪些项目

    尚硅谷大数据线下班全套视频(2019年6月毕业班)

    |____040_面试题讲解.rar

    |____039_面试视频.rar

    |____038_在线教育项目实战.rar

    |____037_Flink项目.rar

    |____036_Flink.rar

    |____035_实时项目.rar

    |____034_电商分析平台项目.rar

    |____033_Spark调优.rar

    |____032_Spark.rar

    |____031_Scala数据结构和算法.rar

    |____030_Scala.rar

    |____029_阶段考试.rar

    |____028_ELK.rar

    |____026_Ambari.rar

    |____025_Kettle.rar

    |____024_ClickHouse.rar

    |____023_Hue.rar

    |____022_Impala.rar

    |____021_CDH安装.rar

    |____020_Kylin.rar

    |____019_azkaban.rar

    |____018_Oozie.rar

    |____017_Sqoop.rar

    |____016_HBase.rar

    |____015_Kafka.rar

    |____014_Flume.rar

    |____013_Hive.rar

    |____012_Zookeeper.rar

    |____011_Hadoop.rar

    |____010_Shell.rar

    |____009_JVM&JUC.rar

    |____008_Git.rar

    |____007_MySQL高级.rar

    |____006_Redis.rar

    |____005_Linux.rar

    |____004_SpringBoot.rar

    |____003_Spring.rar

    |____002_Maven.rar

    |____001_WEB.rar

    |____000JavaSe

    1.2大数据可视化

    1.3大数据概览图

    1.4大数据学习路线图

    1.5大数据尚硅谷视频

    链接地址:https://pan.baidu.com/s/101G6ADMm2oWeDo3FHw0fWw提取密码:s8db

    二、大数据的作用

    2.1数据仓库、数据平台的用途:

    整合公司所有业务数据,建立统一的数据中心

    提供各种报表,有给高层的,有给各个业务的

    为网站运营提供运营上的数据支持,就是通过数据,让运营及时了解网站和产品的运营效果

    为各个业务提供线上或线下的数据支持,成为公司统一的数据交换与提供平台

    分析用户行为数据,通过数据挖掘来降低投入成本,提高投入效果,比如广告定向精准投放、用户个性化推荐等

    开发数据产品,直接或间接为公司盈利

    建设开放数据平台,开放公司数据

    建设敏捷数据仓库,除了对架构技术上的要求之外,还有一个很重要的方面,就是数据建模,如果一上来就想着建立一套能兼容所有数据和业务的数据模型,那就又回到传统数据仓库的建设上了,很难满足对业务变化的快速响应。

    2.2数据采集

    数据采集层的任务就是把数据从各种数据源中采集和存储到数据存储上,期间有可能会做一些简单的清洗。

    数据源的种类比较多:

    网站日志:

    作为互联网行业,网站日志占的份额最大,网站日志存储在多台网站日志服务器上,

    一般是在每台网站日志服务器上部署flume agent,实时的收集网站日志并存储到HDFS上;

    业务数据库:

    业务数据库的种类也是多种多样,有Mysql、Oracle、SqlServer等,这时候,我们迫切的需要一种能从各种数据库中将数据同步到HDFS上的工具,Sqoop是一种,但是Sqoop太过繁重,而且不管数据量大小,都需要启动MapReduce来执行,而且需要Hadoop集群的每台机器都能访问业务数据库;应对此场景,淘宝开源的DataX,是一个很好的解决方案,有资源的话,可以基于DataX之上做二次开发,就能非常好的解决。

    当然,Flume通过配置与开发,也可以实时的从数据库中同步数据到HDFS。

    来自于Ftp/Http的数据源:

    有可能一些合作伙伴提供的数据,需要通过Ftp/Http等定时获取,DataX也可以满足该需求;

    其他数据源:

    比如一些手工录入的数据,只需要提供一个接口或小程序,即可完成;

    2.3、数据存储与分析

    毋庸置疑,HDFS是大数据环境下数据仓库/数据平台最完美的数据存储解决方案。

    离线数据分析与计算,也就是对实时性要求不高的部分,在笔者看来,Hive还是首当其冲的选择,丰富的数据类型、内置函数;压缩比非常高的ORC文件存储格式;非常方便的SQL支持,使得Hive在基于结构化数据上的统计分析远远比MapReduce要高效的多,一句SQL可以完成的需求,开发MR可能需要上百行代码;

    当然,使用Hadoop框架自然而然也提供了MapReduce接口,如果真的很乐意开发Java,或者对SQL不熟,那么也可以使用MapReduce来做分析与计算;

    Spark是这两年非常火的,经过实践,它的性能的确比MapReduce要好很多,而且和Hive、Yarn结合的越来越好,因此,必须支持使用Spark和SparkSQL来做分析和计算。因为已经有Hadoop Yarn,使用Spark其实是非常容易的,不用单独部署Spark集群。

    2.4、数据共享

    这里的数据共享,其实指的是前面数据分析与计算后的结果存放的地方,其实就是关系型数据库和NOSQL数据库;

    前面使用Hive、MR、Spark、SparkSQL分析和计算的结果,还是在HDFS上,但大多业务和应用不可能直接从HDFS上获取数据,那么就需要一个数据共享的地方,使得各业务和产品能方便的获取数据;和数据采集层到HDFS刚好相反,这里需要一个从HDFS将数据同步至其他目标数据源的工具,同样,DataX也可以满足。另外,一些实时计算的结果数据可能由实时计算模块直接写入数据共享。

    2.5、数据应用

    业务产品(CRM、ERP等)

    业务产品所使用的数据,已经存在于数据共享层,直接从数据共享层访问即可;

    报表(FineReport、业务报表)

    同业务产品,报表所使用的数据,一般也是已经统计汇总好的,存放于数据共享层;

    即席查询

    即席查询的用户有很多,有可能是数据开发人员、网站和产品运营人员、数据分析人员、甚至是部门老大,他们都有即席查询数据的需求;

    这种即席查询通常是现有的报表和数据共享层的数据并不能满足他们的需求,需要从数据存储层直接查询。

    即席查询一般是通过SQL完成,最大的难度在于响应速度上,使用Hive有点慢,可以用SparkSQL,它的响应速度较Hive快很多,而且能很好的与Hive兼容。

    当然,你也可以使用Impala,如果不在乎平台中再多一个框架的话。

    OLAP

    目前,很多的OLAP工具不能很好的支持从HDFS上直接获取数据,都是通过将需要的数据同步到关系型数据库中做OLAP,但如果数据量巨大的话,关系型数据库显然不行;

    这时候,需要做相应的开发,从HDFS或者HBase中获取数据,完成OLAP的功能;比如:根据用户在界面上选择的不定的维度和指标,通过开发接口,从HBase中获取数据来展示。

    其它数据接口

    这种接口有通用的,有定制的。比如:一个从Redis中获取用户属性的接口是通用的,所有的业务都可以调用这个接口来获取用户属性。

    2.6、实时计算

    现在业务对数据仓库实时性的需求越来越多,比如:实时的了解网站的整体流量;实时的获取一个广告的曝光和点击;在海量数据下,依靠传统数据库和传统实现方法基本完成不了,需要的是一种分布式的、高吞吐量的、延时低的、高可靠的实时计算框架;Storm在这块是比较成熟了,但我选择Spark Streaming,原因很简单,不想多引入一个框架到平台中,另外,Spark Streaming比Storm延时性高那么一点点,那对于我们的需要可以忽略。

    我们目前使用Spark Streaming实现了实时的网站流量统计、实时的广告效果统计两块功能。

    做法也很简单,由Flume在前端日志服务器上收集网站日志和广告日志,实时的发送给Spark Streaming,由Spark Streaming完成统计,将数据存储至Redis,业务通过访问Redis实时获取。

    2.7、任务调度与监控

    在数据仓库/数据平台中,有各种各样非常多的程序和任务,比如:数据采集任务、数据同步任务、数据分析任务等;

    这些任务除了定时调度,还存在非常复杂的任务依赖关系,比如:数据分析任务必须等相应的数据采集任务完成后才能开始;数据同步任务需要等数据分析任务完成后才能开始;

    这就需要一个非常完善的任务调度与监控系统,它作为数据仓库/数据平台的中枢,负责调度和监控所有任务的分配与运行。

    2.8、元数据管理

    这块想要做好,非常复杂,我觉得是且价值小于成本,因此我们暂不考虑这块。目前只有每天任务运行的元数据。

    2.9、总结

    在笔者看来,架构,并不是技术越多越新越好,而是在可以满足需求的情况下,越简单越稳定越好。目前在我们的数据平台中,开发更多的是关注业务,而不是技术,他们把业务和需求搞清楚了,基本上只需要做简单的SQL开发,然后配置到调度系统就可以了,如果任务异常,会收到告警。这样,可以使更多的资源专注于业务之上。

    相关文章

      网友评论

          本文标题:java大数据之引言

          本文链接:https://www.haomeiwen.com/subject/ictbactx.html