目前由于数据分散在不同的存储环境或数据库中，对于新业务需求的开发需要人工先从不同的数据库中同步、集中、合并等处理，造成资源和人力的浪费。同时，目前的系统架构，无法为未来数据驱动业务创新的理念提供友好的支撑。需要建设新一代数据管理平台来解决数据利用率效率跟不上，以及不能支撑业务发展的问题。以此建设背景，建设新一代数据管理平台需要能够支持数据汇集、数据分析、数据应用、数据计算、数据管理、数据资源管理。02 建设目标
解决不同的业务部门之间的项目、组件、数据很难复用，同时带来繁重的运维成本的环境对业务团队的同事来讲不友好（除了要熟悉业务以外还需要对底层框架有比较深入的了解）重复的开发工作（例如导表、调度等本来可以复用的模块，却需要在多个项目中重复实现）频繁的跨部门需求沟通和讨论，平台将会统一数据、数据共享、服务组件来提高业务产品研发的效率。经常遇到业务需求变更和新的需求，传统的开发模式从“找数据”、“对接数据”、“编码开发”等过程，开发周期较长，影响业务需求的快速服务。数据平台提供可视化的API开发接口、组件服务库，能够快速响应业务需求的开发。比如开发一个新的业务需要用户的完整信息，则需要在平台上可视化调用各数据拼装新的数据单元，形成数据服务接口，快速支撑开发人员，从而减少业务上线的时间，提升业务的响应速度。深度挖掘数据价值，面向数据分析场景构建数据模型，支撑业务决策和产品智能。平台数据需按照规范的建模方法论将数据形成主题域模型、形成标签模型或者指标模型。这些数据模型是数据平台的核心资产，数据平台的各业务系统通过大数据计算平台这座数据加工厂统一加工后产生数据模型，再将这些数据资产通过可视化的界面管理起来，并使用标准化的数据服务接口对数据应用端提供数据应用服务，如快速建立新业务指标模型。03 应用平台“四化”建设
以往数据同步需要对不同的数据源单独编写数据同步工具，耗时耗力，但是所有的行为抽象是同类，可以建设可视化管理系统来对数据汇集管理、调度。打通不同业务口子的数据融合，快速形成新的数据服务单元，将传统的、手动的方式改为线上可视化任务方式，比如要查询会员的信息，可能分布在不同的数据源中，在线可以实现打通宽表，实现会员信息的再次编排，形成用户完整的数据单元。群策群力，构建模型应用市场。（1）数据模型市场
建立模型市场，类似于应用市场，对数据管理人员、分析人员或者其他授权人员提供数据模型共享。模型市场有系统预置以及有其他创建模型的组织来提供，市场包含多种风控模型、预测模型、营销模型等。数据模型市场不仅仅支持模型在线分析，同时数据模型可以作为能力对业务过程助力，如一个用户来需要办理一个新业务需要对其购买意愿做评估，则可以用模型市场中营销模型对其做出分析。（2）简单分析模型建模
在线选择数据源，将数据源通到控制面板中，然后建立数据源直接的关系后，提交计算，形成一个新的数据单元。（3）复杂分析模型建模
数据工程师登录平台，创建新的项目，申请数据资源。
数据工程师通过元数据查找选出表，选择数据集或者数据接口，填写相关信息。
申请这些需要用到的表。比如需要用到100 张表，其中70 张是通过 T+1 的方式使用，30 张是通过实时方式使用。
默认会做标准化脱敏加密策略，收到这些申请之后，数据管理员会按策略依次进行审批。
审批通过后，会自动准备和输出所申请的数据资源，数据工程师可以运用拿到的数据资源进行自助查询、开发、配置、SQL 编排生成等。
数据平台具备“只要能够获取到数据表/视图的权限，便支持封装为API接口发布”的能力。而标准的API接口能够充分实现各业务单位按需申请使用，现有成果的可复用性大大减少了重复建设的成本，也极大降低了信息中心的工作压力，实现易上手、低成本、稳定的数据开放共享服务，帮助前台业务快速接入，创建数据服务API的两种方式：（1）构建简单数据服务接口
- 以【向导模式】新建API，填入接口的基本信息，含API名称、API路径、协议等。
- 选择数据源，库名称、表名称后，系统会自动展示表结构的Schema信息。
- 基于表结构勾选出需要的入参及出参字段，并设置好查询条件、是否分页及使用过滤器等选项。
- 对新API进行验证，结果符合预期后点击发布，新API就正式上线提供服务了。
（2）构建复杂数据服务接口
对目前各个系统中重合度高的业务形成组件化，构建一个领域服务层组件或微服务模块，来提供整合后的领域服务能力，这个组件如果需要提供一个关联多个业务对象的数据集合，那么就需要调用API接口返回多个独立数据集合，然后在组件业务逻辑实现中来完成多个数据集的整合工作，开放给前台使用，方便前台业务场景和功能的实现。04 基础平台建设
首先，要明确企业的实际需求，确保数仓建设符合企业战略目标和业务需求。其次，在技术路径上，要选择合适的选型产品和技术架构，确保数仓的稳定性和可扩展性。最后，在数据路径上，要注重维度模型的设计和数据处理工程的设计，确保数据的准确性和高效性。同时，BI应用路径也是数仓建设中不可忽视的一环，它关系到数据仓库建成后如何有效应用于企业的实际业务中，是衡量数仓成功落地的重要标准。那么，从这几个角度来考虑的话，在构建数据仓库的过程中，我们首先要做的是梳理业务，明确核心业务链路与数据表，并据此划分管理主题。接着，从这些主题中识别出对应的事实表、维度表，并进行指标的梳理、收集和建模。值得一提的是，在建设数据仓库时，我们通常会采用一个分级的架构模型。尽管并非所有数据仓库都严格遵循同一分层标准，但大多数情况下，可以将其划分为ODS（Operational Data Store）层、DW（Data Warehouse）层和DM（Data Mart）层。数仓的分级架构
数据平台案例架构
在数仓实施的过程中，通常遵循调研、详细设计、实施、测试上线的步骤。在这个过程中，业务需求始终是推动项目前进的核心动力。我们在进行数据仓库调研时，必须优先考虑业务需求，因为数据仓库的本质就是为管理服务提供数据支持。同时，也需要关注数据标准的治理和相应的技术架构设计。
从功能角度来看，数据仓库在数据取数之后，主要服务于三个方面：数据服务、数据分析和数据指标。
数据服务包括提供AR分析、数据共享、数据模型构建以及统一数据采集等功能；
数据分析则通过搭建不同的分析模型，深入挖掘各主题内容；而数据指标则通过数据仓库的搭建，在各部门间统一指标口径，实现指标的共享与实践。这三点共同构成了数据仓库建设的主要应用方向。
要提高数据使用效率，打破数据库之间的物理隔阂，需要先将数据汇聚到数据仓库中，数据同步分为实时和非实时，采用的技术也不同。目前先从ODS中同步到hive。数据同步策略的类型包括：全量表、增量表、新增及变化表、拉链表：
2、实体表同步策略
实体表：比如用户，理财产品等，实体表数据量比较小，通常可以做每日全量，是每天存一份完整数据。即每日全量。（1）维度表同步策略
维度表：比如订单状态，审批状态，产品分类，维度表数据量比较小，通常可以做每日全量，是每天存一份完整数据。即每日全量。说明：- 没变化的客观世界的维度（比如性别，地区，民族）可以只存一份固定值。
（2）事务型事实表同步策略
事务型事实表：比如，交易流水，操作日志，出库入库记录等。因为数据不会变化，而且数据量巨大，所以每天只同步新增数据即可，所以可以做成每日增量表，即每日创建一个分区存储。（3）周期型事实表同步策略
存储的数据包含业务数据和元数据。存储的数据分为四层，每一层采用的存储方式和数据不同，如下：- ODS层：原始数据层，存放原始数据，直接加载原始日志、数据，数据保持原貌不做处理，目前系统中已经存在。
- DWD层：结构和粒度与原始表保持一致，对ODS层数据进行清洗（去除空值，脏数据，超过极限范围的数据），DWD数据采用hive的方式管理，将从ODS中的数据同步到hive。
- DWS层：以DWD为基础，进行轻度汇总，如将用户的基本信息从各个业务系统中合并为一张宽表，此层的数据仍然存储在hive中。
- ADS层：数据应用也即数据应用开发层，通过数据计算层的计算后，根据数据类型的不同可以存储到不同的存储器中，如文本型查询的数据可以存储的ES中，对计算结果的查询可以存储在MySQL中。
数据仓库分层示意图
通过Atlas来管理Hive中的元数据，形成元数据目录，以此设计出元模型，然后将数据仓库系统之中的元数据按元模型集中汇总并关联到一起，达到企业对数据统一管理与应用的目的。业务元数据相对复杂，来源较广泛且不统一，需要对业务系统进行深入理解，按业务主题进行整理，梳理出业务范围、业务名称 、业务定义、业务描述、业务关系等，并添加到元数据管理系统中，主要作用实现如下：数据计算由数据管理员来实现，解决的问题根据业务需要对数据融合得出的数据结果。计算层分为离线计算和实时计算。（1）业务流程
数据管理人员可以在平台上可视化的对数据处理，先创建数据应用集合以及对应的数据表，然后在可视化界面上编写数据处理脚本，需要提交后台任务管理系统执行，执行完成后根据数据要求存储到不同的数据器中。（2）离线计算
针对数据量大、逻辑复杂的计算交由后台任务系统，调用Hive计算。将计算的结果可以存储到MySQL或者ES中，根据数据需求场景不同而定。（3）实时查询
针对业务频繁查询的场景，并且数据量大的数据计算完成后可以存储到ES，针对统计分析类同时数据量较大可以使用Doris来查询。本系统的任务主要对数据同步任务、离线计算等任务管理。数据管理员将数据处理任务可以在线或者离线编辑完成后，上传到Airflow平台执行，执行完成后自动同步发布到相关的数据器中并且通知相关人员。（1）业务流程
用户（开发人员或者数据分析人员）在平台上申请数据资源，并且在平台上可视化选择需要的数据源以及数据字段，数据分为业务开发支撑的数据和数据分析。数据管理人员接收到数据集资源申请后，处理数据完成后，通知用户。（2）数据提供方式
同上业务开发人员需求，需要数据仍然向数据管理员申请数据，指定需要的数据。数据管理人员在平台上，制作数据主题。同时，在线的数据分析平台会预置一些数据图表、计算公式等。在实际业务中，尤其是 涉及机密和敏感数据时，仅限授权用户访问就至关重要。同时访问是否合理等信息也 需要系统记录下来，让管理员可以回溯，进一步保证数据安全。平台通过认证 (Authentication)、授权(Authorization)、审计(Audit)三个方面来保证数据安全。（1）认证
认证是用户进入系统的第一道屏障。建议采用了 Kerberos 做用户级别的认证。Kerberos 的设计主要针对 client-server 模型，基于加密方法建立用户(和系统)识别自己的方法，对个人通信以安全的手段进行身份认证，用户和服务器都能验证对方的身份。（2）授权
平台提供基于角色和个人的访问控制。对 HDFS、Hive 等实现了统一的，细粒度的数据访问控制。从数据角度，可以查看当前何种角色/何人有何种权限。从角色/个人角度，可以查看对哪些数据有何种权限。（3）审计
平台为项目安全提供较直观的整体评估和事件跟踪，包括实时监测对系统敏感信 息的访问和操作行为，根据规则设定报警并及时阻断违规操作，收集并记录行为，可 检索所有记录，提供统计信息五个方面。 监控处理的信息包括用户动作，管理员动作两大类。用户动作，所有用户的登录 信息，对数据、对资源、对服务的访问和操作等;管理员动作，管理员对项目、成员等做出的配置等。05 管理规范建设
将数据平台的作用和价值最大化，靠的是软件和制度规范，比如在创建数据表时，没有规范的情况下，可能会带来数据血缘的杂乱等情况。数据平台管理的规范是一个体系化，以下为举例一些规范。可分为基本分层结构规范、各层物理表命名规范、数据库对象命名规范等。为了规范管理，做好经营分析数据仓库的安全管理工作，实现不同的责任人不同的层次，将用户权限尽可能的管理起来同时又不影响正常工作，需要对数据库进行安全管理，如：
（1）数据库管理人员由项目经理和数据经理来掌控，一般情况下不得使用DBA角色登录数据库。
（2）数据人员使用数据库开发人员角色登录，每个数据人员一个用户，归属数据库开发人员组。
（3）前台程序开发人员，由界面开发人员使用，可以查看所有的表，但是无法进行DDL操作。06 建设经验分享
数据管理平台体系涵盖既包含数据技术平台，也包含数据开发、数据模型、数据应用产品。通过建设数据平台建立数据管理和数据应用提现，规模化服务业务，保证数据质量，更大限度的发挥数据价值，主要有以下三个方面来保障建设：数据同步过程中的一致性问题主要包含如下几大分类，增量一致性、状态变更一致性、数据丢失。增量一致性：一般情况下，可以用时间维度或者id来做增量标识。
状态变更一致性：如用户更新了个人信息或者订单状态变更，最好的办法是同步日志，要不然就是根据时间范围批量更新。
数据丢失：在传输过程中由于程序错误等情况的发送，目前的解决办法分为两种：
（1）发送端以批的形式，同时配合事务。
（2）接收端根据不同数据采用不同的规避策略来实现，如目的有自增长ID，一般是容错后报错提醒。源数据变化捕获是数据集成的起点，获取数据源变化主要有三种方式：基于日志的解析模式、基于增量条件查询模式、数据源主动Push模式。通常来说，采用数据库的日志进行增量捕获应当被优先考虑。能够完整获取数据变化的操作类型，尤其是Delete操作，这是增量条件查询模式很难做到的；不依赖特别的数据字段语义，例如更新时间；多数情况下具备较强的实时性。不论是数据同步还是数据的使用，数据治理至关重要。比如在数据同步过程中，出现了不合法的数据格式，在源库中存储没有问题，同步就会出现一些问题。另外在数据分析时，特别是数值分析，出现的数值是字符型就无法分析了。数据治理的工作展开，主要考虑三个维度：模型架构、平台技术和流程规范。（1）在模型架构层面，依据传统数据仓库的理论是对数据进行分层管理，每一层进行相应的业务主题梳理，提炼出业务实体、实体之间的关系、实体的业务行为以及这些由业务行为所沉淀出的度量指标。（2）在平台技术层面，首先要有元数据管理系统，其次要有数据血缘追溯系统、数据质量监测系统等，这些平台技术可以帮助我们部分实现自动化管理。作为互联网企业，业务迭代、表以及字段的增加速度都非常快，如果没有好的平台技术支撑，消耗的人力成本会非常高。来源：数据学堂
- End -
还没有评论，来说两句吧...