人工精选6期大数据之日志系统Flume技术教程(讲理论还讲实操)
这门课解决什么问题 日志数据量大、来源分散、格式杂乱,直接丢进数据仓库会堵塞、丢数据、难追踪。Flume 就是专门解决这个痛点的——它像个智能分拣员,实时收集服务器、应用的日志,根据规则路由到不同的存储系统(HDFS、HBase 等),还能应对高并发、网络抖动、磁盘故障。如果你的工作涉及日志处理、数
会员 · 按档位
游客按标价购买,不享受上表折扣。
支付成功后自动发放网盘链接,链接失效可找客服免费补
这门课解决什么问题
日志数据量大、来源分散、格式杂乱,直接丢进数据仓库会堵塞、丢数据、难追踪。Flume 就是专门解决这个痛点的——它像个智能分拣员,实时收集服务器、应用的日志,根据规则路由到不同的存储系统(HDFS、HBase 等),还能应对高并发、网络抖动、磁盘故障。如果你的工作涉及日志处理、数据管道搭建、实时数据采集,或者要在大数据平台上做数据治理,Flume 是绕不开的工具。它在互联网公司、金融风控、电商推荐等领域都有大量应用。
门槛和学习路径
你需要对 Linux 系统、基本网络概念、HDFS 或 HBase 有初步了解。如果完全没接触过大数据生态,建议先扫一遍 Hadoop、HDFS 的基础概念,但不用深入专家级别。
课程分两个阶段递进。第一阶段是「核心能力」——理解 Flume 的三层架构(Source 采集源、Channel 缓冲通道、Sink 输出端),然后逐个配置常用数据源(监控文件目录、TCP 网络流、预生成测试数据),以及常见输出端(HDFS、HBase)。这部分要完整跟下来,边看视频边在本地环境动手配置,每个 Source 和 Sink 都自己写一遍配置,确保理解了数据流向。第二阶段深入「生产级可靠性」——学怎样用 Sink 处理器实现故障转移和负载均衡,用不同类型通道在吞吐量和数据安全间平衡权衡。这些都是真实项目会碰到的问题。
学完能独立做什么
学完这门课,你能独立搭建日志采集管道——比如从多台服务器收集应用日志到 HDFS,或把业务事件实时写入 HBase;能根据不同的数据源和输出需求设计 Flume 配置;在日志堆积、网络波动、下游系统故障时,用合理的通道和处理器策略保证数据不丢失。这些都是数据工程师、大数据开发的日常工作。
资料配合练习最关键的是动手。每个章节看完视频后,不要直接看下一节,而是在自己的测试环境里独立写一遍配置文件,用测试数据源验证效果。第二阶段要特别用压测工具模拟高并发场景,观察不同配置下系统的表现差异,这样才能理解为什么要用文件通道而不是内存通道、为什么需要故障转移。把这些经验记录下来,它们就是你后续在公司项目里的设计参考。实际工作中,你会在这套基础上根据具体的日志量级、延迟要求、存储成本来调整参数,课程建立的是那个底层的、能独立诊断问题的能力。
课程目录
课程目录25 集
- 1-1 [Flume第1天] 01.flume介绍 (29:21).mp4
- 1-2 [Flume第1天] 02.flume架构-配置netcat source (17:48).mp4
- 1-3 [Flume第1天] 03.flume spooldir源-监控目录 (07:46).mp4
- 1-4 [Flume第1天] 04.flume 实时收集 (02:31).mp4
- 1-5 [Flume第1天] 05.flume seq源-测试-快速生成事件 (17:54).mp4
- 1-6 [Flume第1天] 06.flume stress源-压测 (03:14).mp4
- 1-7 [Flume第1天] 07.flume hdfs sink (38:09).mp4
- 1-8 [Flume第1天] 08.flume hbase sink (14:45).mp4
- 1-9 [Flume第1天] 09.flume avro source (10:25).mp4
- 1-10 [Flume第1天] 10.flume avro 实现hop跃点 (08:05).mp4
- 1-11 [Flume第1天] 11.flume通道选择器-replicating (17:00).mp4
- 1-12 [Flume第1天] 12.flume通道选择器-multiplexing (26:16).mp4
- 2-1 [Flume第2天] 01.flume架构-source-channel-sink (13:34).mp4
- 2-2 [Flume第2天] 02.flume架构sink处理器-failover (20:03).mp4
- 2-3 [Flume第2天] 03.flume架构sink处理器-loadbalance (08:54).mp4
- 2-4 [Flume第2天] 04.flume架构内存通道 (11:49).mp4
- 2-5 [Flume第2天] 05.flume架构file通道failover (11:09).mp4
- 2-6 [Flume第2天] 06.flume架构spillable内存通道 (17:02).mp4
- 2-7 [Flume第2天] 07.flume架构拦截器-static (18:42).mp4
- 2-8 [Flume第2天] 08.flume架构拦截器-host拦截器 (13:26).mp4
- 2-9 [Flume第2天] 09.flume架构限速拦截器 (36:51).mp4
- 2-10 [Flume第2天] 10.flume架构限速拦截器-修改 (50:00).mp4
- 2-11 [Flume第2天] 11.flume架构限速拦截器-修正处理完结 (27:06).mp4
- 2-12 [Flume第2天] 12.测试内存(2g)和磁盘吞吐量(100m) (14:13).mp4
- 2-13 [Flume第2天] 13.测试hdfs速率 (08:31).mp4





