当前位置:网站首页>01-spooldir
01-spooldir
2022-07-02 10:31:00 【Lucky lucky】
-------------------------------------- spooldir -----------------------------------------
1、 establish cnf
vim flume_spooldir_file_hdfs.cnf
2、 Configuration information
# Component description
a1.sources = s1
a1.channels = c1
a1.sinks = k1
# Initialize the data source
a1.sources.s1.type = spooldir
a1.sources.s1.spoolDir = /root/data/flume
a1.sources.s1.ignorePattern = ^(.)*\\.bak$
a1.sources.s1.fileSuffix = .bak
# Initialize channel
a1.channels.c1.type = file
a1.channels.c1.checkpointDir = /opt/software/flume190/mydata/checkpoint
a1.channels.c1.dataDirs = /opt/software/flume190/mydata/data
a1.channels.c1.capacity = 100000
a1.channels.c1.transactionCapacity = 10000
# Initialize data slot
a1.sinks.k1.type = hdfs
a1.sinks.k1.hdfs.path = hdfs://192.168.19.130:9820/flume/events/fakeorder/%Y-%m-%d/%H
a1.sinks.k1.hdfs.round = true # Time abandonment
a1.sinks.k1.hdfs.roundValue = 10
a1.sinks.k1.hdfs.roundUnit = minute
a1.sinks.k1.hdfs.filePrefix = log_%Y%m%d_%H
a1.sinks.k1.hdfs.fileSuffix = .log
a1.sinks.k1.hdfs.useLocalTimeStamp = true
a1.sinks.k1.hdfs.writeFormat = Text
a1.sinks.k1.hdfs.rollCount = 0
a1.sinks.k1.hdfs.rollSize = 134217728
a1.sinks.k1.hdfs.bacthSize = 1000
a1.sinks.k1.hdfs.threadsPoolSize = 4
a1.sinks.k1.hdfs.idleTimeout = 0
a1.sinks.k1.hdfs.minBlockReplicas = 1
# Associated components
a1.sources.s1.channels = c1
a1.sinks.k1.channel = c1
3、 start-up
flume-ng agent -n a1 -c conf/ -f flume-conf-files/flume_spooldir_file_hdfs.cnf -Dflume.root.logger=INFO,console
边栏推荐
- 01-spooldir
- Postman -- use
- Operator exercises
- Following nym, the new project Galaxy token announced by coinlist is gal
- Spatial interpretation | comprehensive analysis of spatial structure of primary liver cancer
- Flink实时计算topN热榜
- allure--常用配置项
- [tutorial] how to make the Helpviewer help document of VisualStudio run independently
- Network real-time video streaming based on OpenCV
- SAP Spartacus express checkout design
猜你喜欢
Basic usage of mock server
Blender camera surround motion, animation rendering, video synthesis
Commutateur Multi - lentilles Blender
虛幻AI藍圖基礎筆記(萬字整理)
【虚幻】过场动画笔记
Delivery mode design of Spartacus UI of SAP e-commerce cloud
[Fantasy 4] the transformation from U3D to UE4
Beautiful and intelligent, Haval H6 supreme+ makes Yuanxiao travel safer
flink 提交程序
Blender海洋制作
随机推荐
Nonlinear optimization: steepest descent method, Newton method, Gauss Newton method, Levenberg Marquardt method
[unity3d] nested use layout group to make scroll view with dynamic sub object height
Blender海洋制作
【避坑指南】Unity3D项目接入腾讯Bugly工具时遇到的坑
【Lua】常见知识点汇总(包含常见面试考点)
Commutateur Multi - lentilles Blender
判断数组中是否存在重复元素
【Unity3D】制作进度条——让Image同时具有Filled和Sliced的功能
Blender ocean production
stm32和电机开发(上位系统)
Beautiful and intelligent, Haval H6 supreme+ makes Yuanxiao travel safer
Network real-time video streaming based on OpenCV
Spatial interpretation | comprehensive analysis of spatial structure of primary liver cancer
webUI自动化学习
How to judge the quality of primary market projects when the market is depressed?
Delivery mode design of Spartacus UI of SAP e-commerce cloud
UE5——AI追逐(蓝图、行为树)
【虚幻】自动门蓝图笔记
【Unity3D】嵌套使用Layout Group制作拥有动态子物体高度的Scroll View
Project practice, redis cluster technology learning (12)