当前位置:网站首页>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
边栏推荐
- [pit avoidance guide] pit encountered by unity3d project when accessing Tencent bugly tool
- webUI自动化学习
- Edge computing accelerates live video scenes: clearer, smoother, and more real-time
- Blender海洋制作
- [ue5] blueprint making simple mine tutorial
- Pytest learning --base
- Blender multi lens (multi stand) switching
- Postman -- use
- Blender model import UE, collision settings
- UE5——AI追逐(蓝图、行为树)
猜你喜欢
Remember the use of add method once
Understand the composition of building energy-saving system
【虚幻4】UMG组件的简介与使用(更新中...)
webUI自动化学习
[illusory] weapon slot: pick up weapons
ue虚幻引擎程序化植物生成器设置——如何快速生成大片森林
[unreal] animation notes of the scene
MPLS experiment
Ue5 - ai Pursuit (Blueprint, Behavior tree)
stm32和电机开发(上位系统)
随机推荐
SAP Spartacus express checkout design
快速做出原型
02-taildir source
虚幻AI蓝图基础笔记(万字整理)
合并有序数列
It is the most difficult to teach AI to play iron fist frame by frame. Now arcade game lovers have something
Allure -- common configuration items
Project practice, redis cluster technology learning (16)
Blender ocean production
Project practice, redis cluster technology learning (10)
[pit avoidance guide] pit encountered using ugui: the text component cannot indent the first line by two spaces
Network real-time video streaming based on OpenCV
Project practice, redis cluster technology learning (VII)
Notes de base sur les plans illusoires d'IA (triés en 10 000 mots)
【Lua】常见知识点汇总(包含常见面试考点)
Mock Server基本使用方法
Blender volume fog
lunix重新分配root 和 home 空间内存
Blender石头雕刻
Remember the use of add method once