做纺织外贸网站,广州做网站设计,长春网站推广优化,建设机械网站案例分析Flume简介安装配置使用教程
1、Flume简介
一#xff1a;概要
Flume 是一个可配置、可靠、高可用的大数据采集工具#xff0c;主要用于将大量的数据从各种数据源#xff08;如日志文件、数据库、本地磁盘等#xff09;采集到数据存储系统#xff08;主要为Had…Flume简介安装配置使用教程
1、Flume简介
一概要
Flume 是一个可配置、可靠、高可用的大数据采集工具主要用于将大量的数据从各种数据源如日志文件、数据库、本地磁盘等采集到数据存储系统主要为Hadoop HDFS中用来处理日志数据并支持在数据流中可靠、高效地移动数据。
二Flume的基础架构 详细讲解
Flume主要由三部分组成SourceChannelSink。
1.Source负责接收数据至 Flume Agent 组件中【入口】常见的数据源主要有TailDirSpoolingDir。
SpoolingDir和TailDir都是Flume中的一个文件型数据源可以实时监控指定目录下的新增和修改文件并将这些文件的内容传输至Flume中。TailDir适用于实时监控日志文件并传输到其他系统的场景特别是处理持续追加内容的日志文件情景支持正则表达式匹配文件名。SpoolingDir适用于同步新文件完整且不变到Flume Sink的场景不支持直接通过正则表达式匹配文件名。
2.Channel位于 Source 和 Sink 之间的【缓冲区】。通常是Memory【内存中的队列】FileKafka。
3.Sink负责从Channel缓冲区中获取数据并将其存储到目标存储系统中【出口】。目标存储系统一般有HDFS,Hive,Hbase,Kafka通常将数据存放于HDFS中。
2、Flume安装配置
# 1、将安装包放置虚拟机中的/opt/download目录下# 2、解压缩至/opt/software目录下并改名为flume-1.9.0
解压cd /opt/downloadtar -zxvf apache-flume-1.9.0-bin.tar.gz -C /opt/software/
重命名cd /opt/softwaremv apache-flume-1.9.0-bin/ flume-1.9.0# 3、复制相关依赖操作
进入flume的lib目录中cd /opt/software/flume-1.9.0/lib/# 复制 hadoop 相关依赖到flume的lib目录下cp /opt/software/hadoop-3.1.3/share/hadoop/*/*.jar ./# 复制 hive hcatelog 相关依赖到flume的lib目录下cp /opt/software/hive-3.1.2/hcatalog/share/hcatalog/*.jar ./# 复制 hive 相关依赖到flume的lib目录下cp /opt/software/hive-3.1.2/lib/hive-*.jar ./cp /opt/software/hive-3.1.2/lib/antlr*.jar ./# 4、放大堆内存
进入flume的bin目录下cd /opt/software/flume-1.9.0/bin/vim flume-ng--------- 修改配置 -----------JAVA_OPTS-Xmx1024m-----------------------------# 结束3、Flume使用教程——交易行为日志采集
一创建ebs_act_log目录存放源数据【入口】
此处我们的数据源是与交易相关的数据。因此在ebs_act_log目录下创建一个transaction_log目录,用于存放与交易数据相关的文件。此处的transaction_log目录将作为【数据来源】使用今后只需将相关数据文件放置在该目录下即可主要用于【上传数据】
mkdir ebs_act_log
cd ebs_act_log
mkdir transaction_log二需在HDFS上提前创建好存放数据的目录【出口】
此处我们将数据存放在**/external_ebs/transaction**目录下如图所示: 三Flume相关需求配置
为了使得构建时目录结构清晰同时为我们之后做数仓更为便利我将Flume相关配置统一放置在了project_ebs目录中的act_log_extract/flume_config目录下。
在flume_config目录中我们需要构建四个基本目录分别是channel-checkpoint、channel-data、conf-file、position-file。先介绍这四个目录分别所起到的作用
channel-checkpoint和channel-data目录是存放任务过程文件position-file目录是存放位置记录相关文件便于下次读取数据时无需重复读取相同内容conf-file目录是用于存放flume相关的配置文件。
在position-file目录中可以创建一个文件transaction_pos.log内部可先进行以下操作 然后在conf-file目录下创建transaction.cnf文件【其中配置源文件source目标文件sink以及channel相关信息】Flume数据采集就是通过读取此配置来实现实时监控。【◉可修改处】
vim transaction.cnf
-----------------------------------------------------------------------
a1.sources r1
a1.channels c1
a1.sinks s1 a1.sources.r1.type TAILDIR
a1.sources.r1.positionFile /root/project_ebs/act_log_extract/flume_config/position-file/transaction_pos.log # 采集数据的相关位置记录标志读取数据位置便于下次操作时不重复读取相同内容 ◉
a1.sources.r1.filegroups f1
a1.sources.r1.filegroups.f1 /root/ebs_act_log/transaction_log/part-.* # 数据来源【数据名不可相同否则会覆盖】◉
a1.sources.r1.fileHeader false # 数据没有表头只需填写 false 即可若有则true
# a1.sources.r1.headers.f1.headerKey1 store # 数据没有表头就无需配置a1.channels.c1.type file
a1.channels.c1.checkpointDir /root/project_ebs/act_log_extract/flume_config/channel-checkpoint # 检查点
a1.channels.c1.dataDirs /root/project_ebs/act_log_extract/flume_config/channel-data # 管道数据a1.sinks.s1.type hdfs
a1.sinks.s1.hdfs.fileType DataStream # 不会压缩输出文件若不配置会进行序列化操作
a1.sinks.s1.hdfs.writeFormat Text
a1.sinks.s1.hdfs.path hdfs://single:9000/external_ebs/transaction # 将数据存放到hdfs中目录下【目录路径】◉
a1.sinks.s1.hdfs.filePrefix event-
a1.sinks.s1.hdfs.fileSuffix .json # 结果出来文件的后缀名
a1.sinks.s1.hdfs.rollInterval 180 # 180s溢写一次
a1.sinks.s1.hdfs.rollSize 134217728 # 128M溢写一次
a1.sinks.s1.hdfs.rollCount 0# 关联sourceschannelssinks
a1.sinks.s1.channel c1
a1.sources.r1.channels c1
-----------------------------------------------------------------------四启动Flume检测
说明其中--name a1中名为a1是因为在配置中都是以a1开头进行配置的--conf指向flume中conf文件--conf-file指向我们所配置的transaction.cnf文件。
/opt/software/flume-1.9.0/bin/flume-ng agent \
--name a1 \
--conf /opt/software/flume-1.9.0/conf/ \
--conf-file /root/project_ebs/act_log_extract/flume_config/conf-file/transaction.cnf \ # ◉
-Dflume.root.loggerINFO,consoleHDFS存储结果 五定期处理
由于channel-checkpoint和channel-data中存放与过程相关数据可以对其进行定期的处理。
rm -rf channel-checkpoint/*
rm -rf channel-data/*
