4. 实例palybook安装管理flume
1. 安装管理配置:
[root@bdroute-s1 roles]# cat flume/vars/main.yml
flume_conf_dir: "/usr/local/common/flume/conf"
logFile: "{{logfile}}"
checkpoinDir: "/data/flume/checkpoint/{{app}}"
dataDir: "/data/flume/data/{{app}}"
[root@bdroute-s1 roles]# cat flume/tasks/install.yml
- name: install flume agent
yum: name=flume state=present
- name: sync config
template: src=flume.conf dest={{flume_conf_dir}}/flume.conf
- name: sync script
copy: src=flume-agent dest=/etc/init.d/flume-agent owner=root group=root mode=766
[root@bdroute-s1 roles]# cat flume/tasks/manager.yml
- name: manager flume
service: name=flume-agent state={{action}}
[root@bdroute-s1 flume]# cat tasks/main.yml
- include: install.yml tags=install
- include: manager.yml tags=service
2. flume结构:
[root@bdroute-s1 roles]# tree flume
flume
├── files
│ └── flume-agent
├── handlers
├── tasks
│ ├── install.yml
│ ├── main.yml
│ └── manager.yml
├── templates
│ └── flume.conf
└── vars
└── main.yml
3. 执行结果:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
[root@bdroute-s1 ansible] # ansible-playbook flume.yml -e 'host="test" action="started" app="syh_php_api" logfile="/data/nginx/test.log"'
PLAY [ test ] *******************************************************************
TASK: [flume | install flume agent] *******************************************
ok: [10.0.0.174]
TASK: [flume | sync config] ***************************************************
changed: [10.0.0.174]
TASK: [flume | sync script] ***************************************************
ok: [10.0.0.174]
TASK: [flume | manager flume] *************************************************
changed: [10.0.0.174]
PLAY RECAP ********************************************************************
10.0.0.174 : ok=4 changed=2 unreachable=0 failed=0
[root@h000174 ~] # ps aux|grep flume
root 8049 1.7 0.1 8540576 97628 ? Sl 19:39 0:09 /usr/bin/java -Xmx20m - cp /usr/local/common/flume/conf : /usr/local/flume/lib/ * -Djava.library.path= org.apache.flume.node.Application --conf- file /usr/local/common/flume/conf/flume .conf --name a1
root 10337 0.0 0.0 103244 880 pts /0 S+ 19:47 0:00 grep flume
[root@h000174 ~] # cat /usr/local/common/flume/conf/flume.conf
#Define source, channel, sink
a1.sources = r1
a1.channels = c1
a1.sinks = k1 k2
#Configure source 1
a1.sources.r1. type = exec
a1.sources.r1.channels = c1
a1.sources.r1. command = tail -F /data/nginx/test .log
a1.sources.r1.shell = /bin/bash -c
a1.sources.r1.restartThrottle = 10000
a1.sources.r1.restart = true
a1.sources.r1.batchSize = 20
a1.sources.r1.batchTimeout = 3000
#Configure channel 1
a1.channels.c1. type = file
a1.channels.c1.checkpointDir = /data/flume/checkpoint/syh_php_api
a1.channels.c1.dataDirs = /data/flume/data/syh_php_api
a1.channels.c1.capacity = 200000000
a1.channels.c1.transactionCapacity = 1000
a1.channels.c1.keep-alive = 30
a1.channels.c1.write-timeout = 30
a1.channels.c1.checkpoint-timeout=600
#Configure sinkgroups
a1.sinkgroups = g1
a1.sinkgroups.g1.sinks = k1 k2
a1.sinkgroups.g1.processor. type = load_balance
a1.sinkgroups.g1.processor.backoff = true
a1.sinkgroups.g1.processor.selector = round_robin
a1.sinkgroups.g1.processor.selector.maxTimeOut = 600000
#Configure sink 1
a1.sinks.k1. type = avro
a1.sinks.k1.channel = c1
a1.sinks.k1. hostname = hdcollect-s1.abc.com
a1.sinks.k1.port = 40003
#Configure k1
a1.sinks.k2. type = avro
a1.sinks.k2.channel = c1
a1.sinks.k2. hostname = hdcollect-s2.abc.com
a1.sinks.k2.port = 40003
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
[root@bdroute-s1 ansible] # ansible-playbook flume.yml -e 'host="test" action="stopped"' --tags service
PLAY [ test ] *******************************************************************
TASK: [flume | manager flume] *************************************************
changed: [10.0.0.174]
PLAY RECAP ********************************************************************
10.0.0.174 : ok=1 changed=1 unreachable=0 failed=0
[root@h000174 ~] # /etc/init.d/flume-agent status
flume-ng agent is not running [FAILED]
[root@bdroute-s1 ansible] # ansible-playbook flume.yml -e 'host="test" action="started"' --tags service
PLAY [ test ] *******************************************************************
TASK: [flume | manager flume] *************************************************
changed: [10.0.0.174]
PLAY RECAP ********************************************************************
10.0.0.174 : ok=1 changed=1 unreachable=0 failed=0
[root@h000174 ~] # /etc/init.d/flume-agent status
flume-ng agent is running [ OK ]
|
转载于:https://www.cnblogs.com/51runsky/p/a6b360fe851aa708d6d63c2c96630bd2.html
4. 实例palybook安装管理flume相关推荐
- mysql多实例的安装和管理(一台服务器上运行两个mysql实例)
mysql的多实例有两种方式可以实现,两种方式各有利弊. 第一种是使用多个配置文件启动不同的进程来实现多实例,这种方式的优势逻辑简单,配置简单,缺点是管理起来不太方便. 第二种是通过官方自带的mysq ...
- 亚马逊ec2 实例删除_亚马逊免费使用套餐:在EC2 Linux实例上安装Tomcat 7
亚马逊ec2 实例删除 Amazon Web Services提供了12个月的免费使用期限,使开发人员可以在云中运行任何他们想要的东西. 免费层包括14个服务,其中Web开发人员最关注EC2服务. E ...
- 亚马逊免费使用套餐:在EC2 Linux实例上安装Tomcat 7
Amazon Web Services提供了12个月的免费使用期限,使开发人员可以在云中运行任何他们想要的东西. 免费层包括14个服务,其中Web开发人员最关注EC2服务. EC2是一项服务,通过停止 ...
- ORACLE 19C 单实例数据库安装
目录 环境信息 安装前准备 开始安装 安装程序 配置监听 安装数据库 安装后 本地连接数据库 总结 本文涉及的安装包下载: 链接:https://pan.baidu.com/s/1cXxAUTvWE6 ...
- NOSQL系列-memcached安装管理与repcached高可用性
Memcached :基于内存工作键值存储型数据库,可以作为应用->memcached 缓存层->数据库.Danga Interactive公司开发,最初为了加速LiveJournal访问 ...
- Linux学习笔记-软件安装管理
0 Linux 软件安装管理概述 一.软件包管理简介 二.rpm命令管理 三.yum在线管理 四.源码包管理 五.脚本安装包 1 软件包管理简介 软件包的分类 源码包 二进制包 源码包的特点 开源,如 ...
- 亚马逊AWS EC2云实例AMI安装LNMP环境(1)——Nginx安装
概括:这里选择亚马逊EC2的Linux AMI实例,该Linux服务器是亚马逊预配置的Linux环境,内置多个YUM源,属于亚马逊首推的稳定Linux服务器.默认登录用户名为ec2-user,执行ro ...
- Python 安装管理器 pythonz
pythonz 是一个 Python 安装管理器,支持 CPython, Stackless, PyPy 和 Jython 使用示例: 1 pythonz install 2.7.3 2 python ...
- python3.7扩展库是什么_Python3.4以后的版本中,____________库用于安装管理Python扩展包,________________库用于发布Python包。_学小易找答案...
[填空题]Python3.4以后的版本中,____________库用于安装管理Python扩展包,________________库用于发布Python包. [判断题]Directions: The ...
- RAC (双节点) + 单实例 DATAGUARD 安装遇到的问题处理
RAC (双节点) + 单实例 DATAGUARD 安装遇到的问题处理 PRIMARY: RAC 双节点 ,存储:ASM STANDBY: 单实例 存储: ASM 单实例 数据库 ...
最新文章
- :/index.php,http://localhost/my/INDEX.PHP/INDEX/INDEX无法正常运行:解决时找不到Options FollowSymLinks谢谢...
- Channel 与ChannelPipeline
- android 启动service报错,Android小经验
- 爱奇艺如何开启两指双击触发奇观功能
- iOS LLDB console debug总结
- jquery实现的时间轴
- js string转json要注意的地方
- 开发版速达光耀-无公网IP服务器访问整体解决方案
- 计算机未来职业人生规划目标与行动措施,计算机职业规划书1500字
- JSP从入门到实战视频教程
- mvc:annotation-driven:注解驱动
- 【小滴课堂】独孤求败-小滴云架构大课十八式
- eureka 缺点
- 小马激活手动分配磁盘_不要成为“单把小马”手动测试仪
- 《高质量C++/C编程指南》陷阱 【转】
- 计算机三种校验方式,三种校验码
- 【WSAGetLastError】WSAGetLastError返回值
- 大数据培训课程哪家靠谱?和盈十五年资历做保证
- Eclipse的物联网架构(Eclipse IoT Architectures)
- Vue基础入门(下)