黑马Hive+Spark离线数仓工业项目--项目总结

时间：2024-09-29 16:16:57

Grafana集成MySQL监控

目标：实现Grafana集成MySQL监控

实施

选择模板

导入报表

 

 

项目总结：背景需求

目标：掌握一站制造的项目背景及项目需求
路径
  - step1：行业背景
  - step2：项目需求
实施
项目行业：工业互联网大数据：物联网
项目名称：加油站服务商数据运营管理平台 
    - 参考别的项目：商业化大数据分析平台：神策
公司产品：加油机设备服务
公司客户：中石化，中石油，中海油、壳牌，道达尔……
整体需求
需求一：通过数据分析提高公司产品的服务质量**
      - 基于加油站的设备安装、维修、巡检、改造等数据进行统计分析
      - 支撑加油站站点的设备维护需求以及售后服务的呼叫中心数据分析
需求二：通过数据分析支撑公司的成本运营核算**
      - 保障零部件的仓储物流及供应链的需求
      - 实现服务过程中的所有成本运营核算

 需求三：为未来自动化加油机设备做数据准备
      - 获取所有用户和车辆的信息来实现自动化加油的管理
具体需求
  - 运营分析：呼叫中心服务单数、设备工单数、参与服务工程师个数、零部件消耗与供应指标等
    - 设备分析：设备油量监控、设备运行状态监控、安装个数、巡检次数、维修次数、改造次数
    - 呼叫中心：呼叫次数、工单总数、派单总数、完工总数、核单次数
    - 员工分析：人员个数、接单次数、评价次数、出差次数
    - 费用分析：仓库物料管理分析、用户分析

项目总结：数据来源

目标：掌握一站制造的项目的业务流程和数据来源

路径

  - step1：业务流程
  - step2：数据来源

实施

业务流程

  step1：加油站服务商联系呼叫中心，**申请服务**：安装/巡检/维修/改造加油机
      - 呼叫中心会记录这个申请信息：来电受理事务事实表
    - step2：呼叫中心联系对应服务站点，**分派工单**：联系站点主管，站点主管分配服务人员
      - 工单信息记录在：服务单信息表、工单信息表
    - step3：服务人员**确认工单**和加油站点信息
      - 具体工单信息表：安装单、维修单
    - step4：服务人员在指定日期到达加油站，进行**设备检修**
    - step5：如果为安装或者巡检服务，安装或者巡检成功，则服务完成
    - step6：如果为维修或者改造服务，需要向服务站点**申请物料**，物料到达，实施结束，则**服务完成
    - step7：服务完成，与加油站站点服务商确认服务结束，完成**订单核验**
    - step8：工程师**报销**过程中产生的费用
      - 所有报销费用记录：差旅费用信息表，费用明细表
    - step9：呼叫中心会定期对该工单中的工程师的服务做**回访**
      - 回访信息表

数据来源

 

ERP系统：企业资源管理系统，存储整个公司所有资源的信息

      - 所有的工程师、物品、设备产品供应链、生产、销售、财务的信息都在ERP系统中

CISS系统：客户服务管理系统，存储所有用户、运营数据

      - 工单信息、用户信息

呼叫中心系统：负责实现所有客户的需求申请、调度、回访等

      - 呼叫信息、分配信息、回访信息

核心数据表

      - 运营分析
        - 工单分析、安装分析、维修分析、巡检分析、改造分析、来电受理分析
      - 提高服务质量
        - 回访分析
      - 运营成本核算
        - 收入、支持分析

项目总结：主题划分

目标：掌握一站制造的项目的主题划分

实施

  - 服务域
    - 安装主题：安装方式、支付费用、安装类型
    - 工单主题：派工方式、工单总数、派工类型、完工总数、
    - 维修主题：支付费用、零部件费用、故障类型
    - 派单主题：派单数、派单平均值、派单响应时间
    - 费用主题：差旅费、安装费、报销人员统计
    - 回访主题：回访人员数、回访工单状态
    - 油站主题：油站总数量、油站新增数量
  - 客户域
    - 客户主题：安装数量、维修数量、巡检数量、回访数量
  - 仓储域
    - 保内良品核销主题：核销数量、配件金额
    - 保内不良品核销主题：核销配件数、核销配件金额
    - 送修主题：送修申请、送修物料数量、送修类型
    - 调拨主题：调拨状态、调拨数量、调拨设备类型
    - 消耗品核销：核销总数、核销设备类型
  - 服务商域
    - 工单主题：派工方式、工单总数、工单类型、客户类型
    - 服务商油站主题：油站数量、油站新增数量
  - 运营域
    - 运营主题：服务人员工时、维修站分析、平均工单、网点分布
  - 市场域
    - 市场主题：工单统计、完工明细、订单统计

项目总结：技术架构

目标：掌握一站制造的项目的技术架构

实施

  -数据生成：业务数据库系统

    - Oracle：工单数据、物料数据、服务商数据、报销数据等

数据采集

    - Sqoop：离线数据库采集
     ==Sqoop怎么采集Oracle数据==

数据存储

    - Hive【HDFS】：离线数据仓库【表】

数据计算

    - SparkSQL：类HiveSQL开发方式：对数据仓库中的结构化数据做处理分析
      - Python | Java ：SparkSQLDSL开发：使用spark-submit来提交运行
      - SparkSQL SQL + ThriftServer：提交SQL开发

数据应用

    - MySQL：结果存储
    - FineBI / Tableau：可视化工具

监控工具

    - Prometheus：服务器性能指标监控工具
    - Grafana：监控可视化工具

调度工具

    - AirFlow：任务流调度工具

技术架构

项目总结：数仓设计

目标：掌握一站制造的项目的分层设计与建模设计

路径

  - step1：分层设计
  - step2：建模设计

实施

分层设计

ODS：原始数据层：最接近于原始数据的层次，直接采集写入层次：**原始事务事实表**
      - 数据内容：存储所有原始业务数据，基本与Oracle数据库中的业务数据保持一致
      - 数据来源：使用Sqoop从Oracle中同步采集
      - 存储设计：Hive分区表，avro文件格式存储，保留3个月
DWD：明细数据层：对ODS层的数据根据业务需求实现ETL以后的结果：ETL以后事务事实表
      - 数据内容：存储所有业务数据的明细数据
      - 数据来源：对ODS层的数据进行ETL扁平化处理得到
      - 存储设计：Hive分区表，orc文件格式存储，保留所有数据
DWB：基础数据层：类似于以前讲解的DWM，轻度聚合
      - 关联：将主题事实的表进行关联，所有与这个主题相关的字段合并到一张表
      - 聚合：基于主题的事务事实构建基础指标
主题事务事实表
      - 数据内容：存储所有事实与维度的基本关联、基本事实指标等数据
      - 数据来源：对DWD层的数据进行清洗过滤、轻度聚合以后的数据
      - 存储设计：Hive分区表，orc文件格式存储，保留所有数据
ST：数据应用层：类似于以前讲解的APP，存储每个主题基于维度分析聚合的结果：**周期快照事实表**
      - 供数据分析的报表
      - 数据内容：存储所有报表分析的事实数据
      - 数据来源：基于DWB和DWS层，通过对不同维度的统计聚合得到所有报表事实的指标
DM：数据集市：按照不同部门的数据需求，将暂时没有实际主题需求的数据存储
      - 做部门数据归档，方便以后新的业务需求的迭代开发
      - 数据内容：存储不同部门所需要的不同主题的数据
      - 数据来源：对DW层的数据进行聚合统计按照不同部门划分
DWS：维度数据层：类似于以前讲解的DIM：存储**维度数据表**
      - 数据内容：存储所有业务的维度数据：日期、地区、油站、呼叫中心、仓库等维度表
      - 数据来源：对DWD的明细数据中抽取维度数据
      - 存储设计：Hive普通表，orc文件 + Snappy压缩
      - 特点：数量小、很少发生变化、全量采集
    - 数据仓库设计方案
      - 从上到下：在线教育：先明确需求和主题，然后基于主题的需求采集数据，处理数据
        - 场景：数据应用比较少，需求比较简单
      - **从下到上**：一站制造：将整个公司所有数据统一化在数据仓库中存储准备，根据以后的需求，动态直接获取数据
        - 场景：数据应用比较多，业务比较复杂

建模设计

    - 建模方法：维度建模

    - 维度设计：星型模型

常用维度

      - 日期时间维度
        - 年维度、季度维度、月维度、周维度、日维度
        - 日环比、周环比、月环比、日同比、周同比、月同比
        - 环比：同一个周期内的比较
        - 同比：上个个周期的比较
      - 行政地区维度
        - 地区级别：国家维度、省份维度、城市维度、县区维度、乡镇维度
      - 服务网点维度
        - 网点名称、网点编号、省份、城市、县区、所属机构
      - 油站维度
        - 油站类型、油站名称、油站编号、客户编号、客户名称、省份、城市、县区、油站状态、所属公司
      - 组织机构维度
        - 人员编号、人员名称、岗位编号、岗位名称、部门编号、部门名称
      - 服务类型维度
        - 类型编号、类型名称
      - 设备维度
        - 设备类型、设备编号、设备名称、油枪数量、泵类型、软件类型
      - 故障类型维度
        - 一级故障编号、一级故障名称、二级故障编号、二级故障名称
      - 物流公司维度
        - 物流公司编号、物流公司名称

主题维度矩阵

项目总结：优化及新特性

目标：掌握一站制造项目中的优化方案

实施

优化：参考FTP中：《就业面试》中的优化文档

    - 资源优化：开启属性分配更多的资源，内存合理分配

    - 开发优化：谓词下推：尽量将不需要的数据提前过滤掉【join】

      - 尽量选用有Map端聚合的算子：先分区内聚合，再分区间聚合
      - 尽量将不需要join的数据过滤，或者实现Broadcast Join

    - 结构优化：文件存储类型、分区结构化

      - 分区表：静态分区裁剪

  

select count(*) from table1 where daystr = '2021-10-15'; --走分区裁剪过滤查询

--spark2中先join后过滤

   from table1 join table2 on table1.id = table2.id and table1.daystr = '2021-10-15' and table2.daystr='2021-10-15';

新特性：Spark3.0

动态分区裁剪（Dynamic Partition Pruning）

      - 默认的分区裁剪只有在单表查询过滤时才有效

      - 开启动态分区裁剪：自动在Join时对两边表的数据根据条件进行查询过滤，将过滤后的结果再进行join

 =true

自适应查询执行（Adaptive Query Execution）

      - 基于CBO优化器引擎：实现最小代价的数据处理

      - 自动根据统计信息设置Reducer【ShuffleRead】的数量来避免内存和I/O资源的浪费

      - 自动选择更优的join策略来提高连接查询性能

      - 自动优化join数据来避免不平衡查询造成的数据倾斜，将数据倾斜的数据自动重分区

        =true

加速器感知调度（Accelerator-aware Scheduling）

      - 添加原生的 GPU 调度支持，该方案填补了 Spark 在 GPU 资源的任务调度方面的空白
      - 有机地融合了大数据处理和 AI 应用，扩展了 Spark 在深度学习、信号处理和各大数据应用的应用场景

项目总结：问题

目标：掌握一站制造的项目中遇到的问题及解决方案
实施

  - 问题1：数据采集不一致问题

    - 现象：Hive表中的记录数与Oracle中的记录数不一致
    - 原因：Oracle的数据字段中包含了特殊字段，Sqoop采集时，以特殊字符作为换行符生成普通文本
    - 解决
      - 方案一：替换或者删除特殊字段【不影响数据业务】
      - 方案二：更换Avro格式

  - 问题2：数据倾斜问题

    - 重分区：将数据重新分配到更多的分区中
    - 自定义分区方式：默认Hash分区【reduceByKey】、Range分区【sortBy】
    - 先过滤再join，或者用广播join

  - 问题3：小文件问题

    - 每个Task会产生一个结果文件
    - Task个数根据分区个数来决定
    - 分区多，每个分区的数据少
    - 调整分区个数：repartion

  - 问题4：ThriftServer资源不足，GC问题

    

  1. 

    

     start- \
    

    2. 

  2. 

    

        --name sparksql-thrift-server \

    

    3. 

  3. 

    

        --master yarn \

    

    4. 

  4. 

    

        --deploy-mode client \

    

    5. 

  5. 

    

        --driver-memory 1g \

    

    6. 

  6. 

    

        --hiveconf hive.=10001 \

    

    7. 

  7. 

    

        --num-executors 3 \

    

    8. 

  8. 

    

        --executor-memory 1g \

    

    9. 

  9. 

    

        --conf =2

    

    10.

    - 本质：Spark程序运行YARN上
    - 进程：Driver  + Executor
    - 问题：这个程序的资源如果给的少了，会导致GC【内存垃圾回收】停顿以及内存溢出
      - Driver进程故障，程序运行缓慢，内存溢出
    - 解决
      - Driver资源要给定多一些：Driver持久运行，不断解析调度分配，负责与客户端交互
        - --driver-core：4core
        - --driver-mem：12GB
      - Executor的个数给定的多一些

  - 问题5：ThriftServer单点故障问题

    - 类似于HiveServer2的单点故障问题
    - 解决：HA高可用结构，构建两个ThriftServer
      - 方案一：两台机器分别启动两个ThriftServer
        - 问题：beeline只能连接某一个，连接谁？如果随便选一个，这个如果故障了怎么办呢？
        - 解决：HAproxy工具，运维配置
      - 方案二：利用ZK来实现辅助选举，一个Active，一个Standby
        - 原生的HiveServer2可以直接修改配置来实现
        - 修改源码

项目总结：数据规模

目标：掌握一站制造项目中的数据规模
实施
  - 每天数据增量是多少？
    - 项目中总数据表的个数：300多张表
    - 核心业务的事务事实表：100张表
    - 每张核心事务事实增量：17万条/天
    - 每条数据量的平均大小：1KB
    - 每天的总数据增量范围：16GB
  - 集群大概有多少台机器？
    - 每台机器存储容量：20TB
    - 每台机器可用比例：80%
    - 每台机器可用容量：16TB
    - 整体数据存储五年：16 * 3 * 365 * 5 = 6 台DataNode/NodeManager
  - 项目团队规模？
    - 以12人举例：项目经理：1，产品经理：1，离线：5人，web系统：2人，测试：2人，运维：1人

项目总结：简历模板

    

  1. 

    

    项目名称：一站制造大数据项目（2021年1月-2021年9月）
    

    2. 

  2. 

    

    项目架构：
    

    3. 

  3. 

    

    spark2.4+hive2.1+hadoop2.7+sqoop1.4+oracle11g+mysql5.7+airflow2.0

    

    4. 

  4. 

    

    项目简介：
    

    5. 

  5. 

    

        一站制造项目基于工业互联网行业，为解决基于传统数据存储架构无法解决的问题而开发的大数据项目。在石油制造行业存在大量运营、仓储物料数据，通过大数据技术架构解决这种复制业务情况下的数据存储和分析以及数据可视化问题。主要基于hive数据分层构建存储各个业务指标数据，基于sparksql做数据分析。核心业务涉及运营商、呼叫中心、工单、油站、仓储物料等业务。
    

    6. 

  6. 

    

    个人职责：
    

    7. 

  7. 

    

        1.负责将存储在关系型数据库中的业务系统数据导入hdfs上。
    

    8. 

  8. 

    

        2.根据原始数据表，批量创建hive表，设置分区、存储格式。
    

    9. 

  9. 

    

        3.根据业务关联关系以及分析指标，建立数仓模型。
    

    10. 

  10. 

    

        4.实现数据模型中的各个数仓分层的数据建模，建表。
    

    11. 

  11. 

    

        5.负责实现每个分层的数据抽取、转换、加载。
    

    12. 

  12. 

    

        6.负责编写shell实现sqoop脚本批量导入数据。
    

    13. 

  13. 

    

        7.负责编排sqoop导入数据的任务调度。
    

    14. 

  14. 

    

        8.负责使用sparksql进行数据应用层指标进行分析。
    

    15.

- 工业大数据的应用：/p/166300187
- 石油能源行业公司：/hangye/index_qiye_shihua.html
- 商业数据分析平台：友盟，talkingdata，神策

相关文章