第1章 数据仓库建设1.1 数据仓库总体架构专家系统接收增购项目车辆 TCMS 或其他子系统通过车地通信传输的实时或离线数据，经过一系列综合诊断分析，以各种报表图形或信息推送的形式向用户展示分析结果。针对诊断出的车辆故障将给出专家建议处理措施，为车辆的故障根因修复提供必要的支持。根据专家系统数据仓库建设目标，结合系统数据业务规，包括数据采集频率 、数据采集量等相关因素，设计专家系统数据仓库架构如下：数据仓库架构从层次结构上分为数据采集、数据存、数据分析、数据服务等几个方面的容：数 据 采 集 ： 负 责 从 各 业 务 自 系 统 中 汇 合 信 息 数 据 ， 系 统 支 撑Kafka、Storm、Flume 与传统的 ETL 采集工具。数据存储：本系统提供 Hdfs、Hbase 与 RDBMS 相结合的存储模式，支持海量数据的分布式存储。数据分析：数据仓库体系支持传统的 OLAP 分析与基于 Spark 常规机器学习算法。数据服务总线：数据系统提供数据服务总线服务，实现对数据资源的统一管理和调度，并对外提供数据服务。1.2 数据采集专家系统数据仓库数据采集包括两个部分容：外部数据汇合、部各层数据的提取与加载。外部数据汇合是指从 TCMS、车载子系统等外部信息系统汇合数据到专家数据仓库的操作型存储层（ODS）；部各层数据的提取与加载是指数据仓库各存储层间的数据提取、转换与加载。1.2.1外部数据汇合专家数据仓库数据源包括列车监控与检测系统（TCMS）、车载子系统等相关子系统，数据采集的容分为实时数据采集和定时数据采集两大类，实时数据采集主要对于各项检测指标数据；非实时采集包括日检修数据等。根据项目信息汇合要求，列车指标信息采集具有采集数据量大，采集频率高的特点，考虑到系统后期的扩展，因此在数据数据采集方面，要求采集体系支持高吞吐量、高频率、海量数据采集，同时系统应该灵活可配置，可根据业务的需要进行灵活配置横向扩展。本方案在数据采集架构采纳 Flume+Kafka+Storm 的组合架构，采纳Flume 和 ETL 工 具 作 为 Kafka 的 Producer ， 采 纳 Storm 作 为 Kafka 的Consumer，Storm 可实现对海量数据的实时处理，与时对问题指标进行预警。具体采集系统技术结构图如下:1.2.1.1 数据汇合架构功能Flume 提 供 了 从 console( 控 制 台 ) 、 RPC(Thrift-RPC) 、 text( 文 件 ) 、tail(UNIX tail) 、 syslog(syslog 日 志 系 统 ， ...
