<>大数据的概念

大数据(big data),指无法在一定时间范围内
用常规软件工具进行捕捉、管理和处理的数据集合,是需要新处理模式才能具有更强的决策力、洞察发现力和流程优化能力的海量、高增长率和多样化的信息资产。

主要解决:海量数据存储和海量数据的分析计算问题

<>大数据的特点

大数据特性,谨记四字箴言:「大、快、杂、疑」

<>1、Volume(大)


资料量非常大,以前人们「手动」在表格中记录、累积出数据;现在数据是由机器、网路、人与人之间的社群互动来生成。你现在正在点击的滑鼠、来电、简讯、网路搜寻、线上交易…
都正在生成累积成庞大的数据。截止目前人类生产的所有印刷材料是200PB(Peta
Bytes,千兆位元组),历史上人类总共说过的话数据量约5EB(Exabytes,百万兆位元组)。

<>2、Velocity(快)

响应的时效性至关重要,据IDC“数字宇宙”报告,预计到2020年,全球数据使用量将达到35.2ZB(Zetta
Bytes,十万亿亿字节),如此海量数据,处理效率至关重要。

<>3、Variety(杂)


大数据的来源种类包罗万象,十分多样化,如果一定要把资料分类的话,最简单的方法是分两类,结构化与非结构化。早期的非结构化资料主要是文字,随着网路的发展,又扩展到电子邮件、网页、社交媒体、视讯,音乐、图片等等,这些非结构化的资料造成储存(storage)、探勘(mining)、分析(analyzing)上的困难。

<>4、Value(疑)


价值密度的高低与数据总量的大小成反比。以视频为例,一部1小时的视频,在连续不间断的监控中,有用数据可能仅有一二秒。如何通过强大的机器算法更迅速地完成数据的价值“提纯”成为目前大数据背景下亟待解决的难题。

<>大数据能干啥?

例1: o2o–百度大数据+平台,通过先进的线上线下打通技术和客流分析能力,助力商家精细化运营,提升销量。

例2: 美国折扣零售商能够通过用户购买商品的历史,判断出是否怀孕。
例3: 日本通过研究驾驶员的坐姿数据,用来作为汽车防盗系统中。

例4:
电子商务领域–购物行为与销量预测分析;商品关联分析;全网产品信息采集,产品素材获取;通过分析产品价格和销量,指导新品上架策略;云评论系统的搭建和维护;电子商务渠道分销


例5: 金融领域–金融行业的主要业务应用包括企业内外部的风险管理、信用评估、借 贷、保 险、理 财、证
券分析等,都可以通过获取、关联和分析更多维度、更深层次的数据,并通过不断发展的大数据处理技术得以更好、更快、更准确的实现,从而使得原来不可担保的信
贷可以担保,不可保 险的风险可以保 险,不可预测的证 券行情可以预测。

例6:
电信领域–采集基站等硬件设备的数据,分析设备负荷状况,生成设备的扩容、优化、质量排查、扩建等建议,达到均衡网络流量的目的;分析用户的话单数据,界定用户属性,分析手机终端的特征,从而形成套餐推荐、终端推荐等决策;根据用户使用的app软件、访问的网页进行更为全面的用户行为分析、用户喜好分析;采集微博等社交网络数据,了解用户对运营商的评价和意见,舆情分析。

例7:
新闻媒体–快速准确地自动跟踪、采集数千家网络媒体信息,扩大新闻线索,提高采集速度;支持每天对数万条新闻进行有效抓取。监控范围的深度、广度可以自行设定;支持对所需内容的智能提取、审核;实现互联网信息内容采集、浏览、编辑、管理、发布的一体化。

例8:
政府机关–大数据必将成为宏观调控、国家治理、社会管理的信息基础。实时跟踪、采集与业务工作相关的信息;全面满足内部工作人员对互联网信息的全局观测需求;及时解决政务外网、政务内网的信息源问题,实现动态发布;快速解决政府主网站对各地级子网站的信息获取需求;全面整合信息,实现政府内部跨地区、跨部门的信息资源共享与有效沟通;节约信息采集的人力、物力、时间,提高办公效率。

例9:
企业制造–实时准确地监控、追踪竞争对手动态,是企业获取竞争情报的利器;及时获取竞争对手的公开信息以便研究同行业的发展与市场需求;为企业决策部门和管理层提供便捷、多途径的企业战略决策工具;大幅度地提高企业获取、利用情报的效率,节省情报信息收集、存储、挖掘的相关费用,是提高企业核心竞争力的关键;提高企业整体分析研究能力、市场快速反应能力,建立起以知识管理为核心的“竞争情报数据仓库”,提高核心竞争力。

<>大数据前景


1、国际数据公司IDC预测,到2020年,企业基于大数据计算分析平台的指出将突破5000亿美元。目前,我国大数据人才只有46万,未来3到5年人才缺口达到150万之多。

2、2017年北京大学,北京邮电大学等25所高校成功申请开设大数据课程。


3、大数据属于高新技术,大牛少,升职竞争小;

<>大数据技术生态体系

总共分为六层:数据来源层–>数据来源层–>数据存储层–>资源管理层–>数据计算层–>任务调度层
具体如下图:

下面我们来讲一下上面的架构图:
首先我们第一步当然是获取数据【数据来源层】,包括(结构化,半结构化,非架构话数据),然后我们需要去接收数据【数据来源层】。
不同的数据类型有不同的接收工具:


* Sqoop
(发音:skup)主要用于在Hadoop(Hive)与传统的数据库(mysql、postgresql…)间进行数据的传递,可以将一个关系型数据库(例如 :
MySQL ,Oracle ,Postgres等)中的数据导进到Hadoop的HDFS中,也可以将HDFS的数据导进到关系型数据库中。
* Flume
是Cloudera提供的一个高可用的,高可靠的,分布式的海量日志采集、聚合和传输的系统,Flume支持在日志系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可定制)的能力。
接收过后,当然是存储起来,可以存储在HDFS上也可以存储在Hbase。Hbase是按列存储,检索起来特别快。Hadoop
HDFS为HBase提供了高可靠性的底层存储支持。

* Hadoop分布式文件系统(HDFS)被设计成适合运行在通用硬件(commodity
hardware)上的分布式文件系统。它和现有的分布式文件系统有很多共同点。但同时,它和其他的分布式文件系统的区别也是很明显的。HDFS是一个高度容错性的系统,适合部署在廉价的机器上。HDFS能提供高吞吐量的数据访问,非常适合大规模数据集上的应用。HDFS放宽了一部分POSIX约束,来实现流式读取文件系统数据的目的。HDFS在最开始是作为Apache
Nutch搜索引擎项目的基础架构而开发的。HDFS是Apache Hadoop Core项目的一部分。
* HBase是一个分布式的、面向列的开源数据库,该技术来源于 Fay Chang
所撰写的Google论文“Bigtable:一个结构化数据的分布式存储系统”。就像Bigtable利用了Google文件系统(File
System)所提供的分布式数据存储一样,HBase在Hadoop之上提供了类似于Bigtable的能力。HBase是Apache的Hadoop项目的子项目。HBase不同于一般的关系数据库,它是一个适合于非结构化数据存储的数据库。另一个不同的是HBase基于列的而不是基于行的模式。
数据存储完毕,到了我们YARN资源管理层,YARN资源管理层相当于我们电脑的操作系统,调度这些资源,HDFS相当于磁盘。

* Apache Hadoop YARN (Yet Another Resource Negotiator,另一种资源协调者)是一种新的 Hadoop
资源管理器,它是一个通用资源管理系统,可为上层应用提供统一的资源管理和调度,它的引入为集群在利用率、资源统一管理和数据共享等方面带来了巨大好处。
再往上到了我们数据计算层,

从图中可以看出左侧是处理离线的数据,右侧是处理实时数据。
离线又分为两类:
MapReduce是基于磁盘计算,Spark Core是基于内存计算。
MapReduce断电后数据还在,Spark Core断电后数据不存在。
Spark Core比MapReduce速度快。

* MapReduce
是一种编程模型,用于大规模数据集(大于1TB)的并行运算。概念"Map(映射)“和"Reduce(归约)”,是它们的主要思想,都是从函数式编程语言里借来的,还有从矢量编程语言里借来的特性。它极大地方便了编程人员在不会分布式并行编程的情况下,将自己的程序运行在分布式系统上。
当前的软件实现是指定一个Map(映射)函数,用来把一组键值对映射成一组新的键值对,指定并发的Reduce(归约)函数,用来保证所有映射的键值对中的每一个共享相同的键组。
到最后一步就是调度层,说白了就是安排什么时间做什么事。

* azkaban
主要是应用于hadoop生态圈的任务调度的。我们在实际使用过程中,也主要是用来做hadoop相关任务的调度,其他任务的调度暂时还没有进行相关实践。
* ozie
是管理Hadoop作业的工作流调度系统,工作流是一系列的操作图。Oozie协调作业是通过时间(频率)以及有效数据触发当前的Oozie工作流程。Oozie是针对Hadoop开发的开源工作流引擎,专门针对大规模复杂工作流程和数据管道设计。
<>推荐系统项目框架

接下来来个实战框架:
例如我们在淘宝买了个键盘,那么你会发现当你买完键盘的时候,会给你推荐鼠标,显示器等相关商品,那么这个就是通过上面我们讲到的数据框架实现的。


购买完键盘通过Nginx来让Tomcat收集日志,然后通过我们的数据系统将日志存储到HDFS或Hbase,由于我们这个是实时的,所以我们走Storm实时计算。然后通过计算我们可以得出结论买过键盘的人同时还买过鼠标,显示器等物品。然后我们将分析得到的文件/数据库再给到Tomcat推荐业务服务器,将结果再推送给客户。

结束啦!!欢迎微信扫码二维码关注公众号,更多精彩干货。

扫码关注公众号“伟大程序猿的诞生“,更多干货新鲜文章等着你~

公众号回复“资料获取”,获取更多干货哦~

有问题添加本人微信号“fenghuokeji996” 或扫描博客导航栏本人二维码

友情链接
KaDraw流程图
API参考文档
OK工具箱
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱:ixiaoyang8@qq.com
QQ群:637538335
关注微信