flume data to hdfs

Posted fandong90

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了flume data to hdfs相关的知识,希望对你有一定的参考价值。

flume 开发梳理

flume 数据到hadoop

conf/hdfsAgent.conf

 #配置sources、channels、sinks

a1.sources=r1
a1.channels=c1
a1.sinks=k1

#sources.r1 配置源数据类型
a1.sources.r1.type=exec
a1.sources.r1.shell=bin/bash -c
a1.sources.r1.command=ping 192.168.1.125

#channels c1 配置传输通道
a1.channels.c1.type=memory
a1.channels.c1.capacity=1000
a1.channels.c1.transactionCapacity=100

#sinks k1 配置接收数据

a1.sinks.k1.type=hdfs
a1.sinks.k1.hdfs.path=hdfs://192.168.1.125:9000/flume/webData

#关联sources、channels、sinks
a1.sources.r1.channels=c1
a1.sinks.k1.channel=c1

tips:

 flume 配置输入到hadoop,需要把 hadoop-2.7.1/share/ hadoop/ 下的common/* common/lib/* hdfs/* hdfs/lib/* mapreduce/* mapreduce/lib/* 拷贝到flume-1.6.0/lib/* 目录下。

开启命令:

bin/flume-ng agent -c conf -f conf/hdfsAgent.conf -n a1

以上是关于flume data to hdfs的主要内容,如果未能解决你的问题,请参考以下文章

使用flume将csv文件传输到hdfs,并将它们转换为avro

kafka+flume-ng+hdfs 整合

Flume配置参数详解

[React Testing] Use Generated Data in Tests with tests-data-bot to Improve Test Maintainability(代码片段

flume简介与监听文件目录并sink至hdfs实战

flume抽取日志为啥没写到hdfs中