VIP20

本课程属于：049-实时数据产品化 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

实时数据产品化实战手册

📚 共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

实时数据产品概述

定义、商业价值与典型场景：实时大屏、风控、推荐系统如何驱动决策。

实时计算技术选型

Flink、Spark Streaming、Kafka Streams 对比与选型策略，找到最适合的引擎。

实时数据采集与接入

Kafka 核心概念、生产者/消费者 API、数据入湖入仓策略详解。

实时数据建模

流式数据建模原则、宽表设计、事件驱动模型与维度建模实践。

实时数据开发基础

Flink DataStream API 核心算子：map、filter、keyBy、window 实战。

实时数据处理进阶

Flink 状态管理、Checkpoint 与 Exactly-Once 语义，保障数据一致性。

状态一致性

实时数据清洗与转换

数据脱敏、字段映射、脏数据处理策略，构建高质量流管道。

实时数据聚合与计算

Tumbling Window、Sliding Window、Session Window 实战与调优。

实时数据关联与 Join

双流 Join、维表 Join（Async IO）、Temporal Join 实现复杂关联。

实时数据输出与落地

Flink 写入 Kafka、MySQL、HBase、ClickHouse 的最佳实践。

实时数据产品架构设计

Lambda 架构与 Kappa 架构的抉择与演进，构建可扩展数据平台。

实时数据产品需求分析

如何将业务需求转化为实时数据指标，定义可量化目标。

实时数据产品原型设计

实时大屏、实时报表、实时告警的原型设计要点与工具推荐。

实时数据产品开发流程

从需求评审到上线监控的全流程管理，敏捷交付实时产品。

实时数据质量保障

数据延迟监控、准确性校验、数据回溯机制，构建质量体系。

实时数据产品测试

流式数据测试策略、模拟数据生成、端到端测试方法。

实时数据产品部署与运维

Kubernetes 部署 Flink、资源隔离与弹性伸缩，生产化运维。

实时数据产品监控与告警

Flink Metrics、Prometheus + Grafana 监控体系搭建与告警规则。

实时数据产品性能优化

反压处理、算子链优化、资源参数调优，提升吞吐与稳定性。

实时数据产品安全与权限

数据脱敏、访问控制、审计日志，保障数据安全合规。

案例：实时用户行为分析平台

基于用户行为实时分析，构建个性化洞察与运营策略。

案例用户行为

案例：实时风控决策引擎

毫秒级风控规则计算，拦截欺诈交易与异常行为。

案例：实时数据同步与 CDC 平台

基于 CDC 的实时数据同步，构建异构数据源实时管道。

案例：实时指标计算与 BI 系统

实时聚合指标，赋能 BI 报表与自助分析。

案例：实时推荐系统

基于实时特征与模型推理，实现个性化推荐。

案例：实时物联网数据处理平台

海量设备数据实时接入、处理与可视化监控。

案例：实时日志分析与运维监控

日志流实时分析，异常检测与运维大屏。

案例：实时金融交易风控系统

金融级实时风控，交易链路毫秒级决策。

案例：实时电商大促数据大屏

大促实时销售、流量、库存可视化大屏。

实时数据产品未来趋势

云原生实时计算、AI 与实时数据融合、实时数据湖演进。

趋势云原生