抱歉,您的浏览器无法访问本站
本页面需要浏览器支持(启用)JavaScript
了解详情 >


Flume 的安装部署

案例:使用网络 telent 命令向一台机器发送一些网络数据,然后通过 flume 采集网络端口数据

第一步:下载解压修改配置文件

Flume 的安装非常简单,只需要解压即可,当然,前提是已有 hadoop 环境上传安装包到数据源所在节点上
这里我们采用在第三台机器来进行安装

tar -zxvf flume-ng-1.6.0-cdh5.14.0.tar.gz -C /export/servers/
cd /export/servers/apache-flume-1.6.0-cdh5.14.0-bin/conf
cp flume-env.sh.template flume-env.sh
vim flume-env.sh
flume-env.sh
export JAVA_HOME=/export/servers/jdk1.8.0_141

第二步:开发配置文件

根据数据采集的需求配置采集方案,描述在配置文件中 (文件名可任意自定义)
配置我们的网络收集的配置文件
在 flume 的 conf 目录下新建一个配置文件(采集方案)

vim /export/servers/apache-flume-1.6.0-cdh5.14.0-bin/conf/netcat-logger.conf
netcat-logger.conf
# agent name
a1.sources = r1
a1.sinks = k1
a1.channels = c1
# desc source:r1
a1.sources.r1.type = netcat
a1.sources.r1.bind = 192.168.52.120
a1.sources.r1.port = 44444
# desc sink:k1
a1.sinks.k1.type = logger
# desc channel
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100
# desc source channel sink
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1

第三步:启动配置文件

指定采集方案配置文件,在相应的节点上启动 flume agent
先用一个最简单的例子来测试一下程序环境是否正常
启动 agent 去采集数据

bin/flume-ng agent -c conf -f conf/netcat-logger.conf -n a1 -Dflume.root.logger=INFO,console

-c conf 指定 flume 自身的配置文件所在目录
-f conf/netcat-logger.con 指定我们所描述的采集方案
-n a1 指定我们这个 agent 的名字

启动配置文件-1
启动配置文件-2

第四步:安装 telent 准备测试

在 node02 机器上面安装 telnet 客户端,用于模拟数据的发送

yum -y install telnet
telnet node03 44444 # 使用 telnet 模拟数据发送

测试

更多 source 和 sink 组件

Flume 支持众多的 source 和 sink 类型,详细在官方文档
http://archive.cloudera.com/cdh5/cdh/5/flume-ng-1.6.0-cdh5.14.0/FlumeUserGuide.html

推荐阅读
Flume 负载均衡 load balancer Flume 负载均衡 load balancer Flume 两个agent级联 Flume 两个agent级联 Flume 高可用配置 Flume 高可用配置 Flume 监控目录变化 Flume 监控目录变化 Flume 监控文件变化 Flume 监控文件变化 Flume 介绍 Flume 介绍

留言区

Are You A Robot?