案例15:avro 远程访问内容中的内容

将133,上的文件内容发送到132机器上

将132机器上的flume拷贝到133上
在132机器上创建avro source

  
a1.sources = r1
a1.sinks = k1
a1.channels = c1
   
# Describe/configure the source
a1.sources.r1.type = avro
a1.sources.r1.bind =0.0.0.0
a1.sources.r1.port =41414
   
# Describe the sink
a1.sinks.k1.type = logger
   
# Use a channel which buffers events in memory
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100
   
# Bind the source and sink to the channel
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1

3.在133机器上执行

bin/flume-ng avro-client --conf conf/ --host 192.168.13.132 --port 41414 --filename /opt/test.log

时间： 2024-11-05 18:37:40

案例15:avro 远程访问内容中的内容的相关文章

案例15:avro 负载均衡的方式动态获取文件中内容

需求: 将131上产生的日志文件负载均衡到 132 和133机器上如图: 配置132 机器和133机器 (相同)) arov.conf a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = avro a1.sources.r1.bind =0.0.0.0 a1.sources.r1.port =41414 # Describe t

案例17:avro 负载均衡加优先级

增加一下信息说明优先往哪台机器上写数据,如果优先级高的服务宕机了,会向优先级低的服务上写. a1.sources = r1 a1.sinks = k1 k2 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = exec a1.sources.r1.command = tail -F /opt/test.log # define sinkgroups a1.sinkgroups=g1 a1

linux shell 脚本获取和替换文件中特定内容

1.从一串字符串中获取特定的信息要求1:获取本机IP:menu.lst为系统镜象的IP配置文件,需要从中获取到本机IP信息(从文件获取信息) 1 timeout 1 2 default 0 3 4 title live 5 find --set-root /casper/vmlinuz 6 kernel /casper/vmlinuz boot=casper ignore_uuid showmounts ip=eth0,10.0.66.66,255.255.240.0,10.0.64.3 7

微信公众平台新增图文内容中图片上传接口，并过滤外链图片(这是封闭么？)

为了加快图文内容的浏览速度,公众平台新增了图文消息内容中的图片上传接口.开发者可以通过该接口上传所需要的图片来获得图片链接,再把图片链接放到图文内容中. 同时,为了加强平台安全性,从8月15日起, 系统将自动过滤图文内容中的外链图片(8月15日之前的图文内容不会过滤).下述接口受到影响,请开发者尽快修改: 1.群发图文消息时,上传图文的接口,查看接口文档 2.素材管理中的新增永久图文素材接口,查看接口文档

java中的文件读取和文件写出：如何从一个文件中获取内容以及如何向一个文件中写入内容

1 2 3 import java.io.BufferedReader; 4 import java.io.BufferedWriter; 5 import java.io.File; 6 import java.io.FileInputStream; 7 import java.io.FileNotFoundException; 8 import java.io.FileOutputStream; 9 import java.io.IOException; 10 import java.io.

R语言读取csv中的内容

1992年,R语言诞生.R语言是PC和Linux时代的产物,R语言和贝尔实验室开发的S语言类似,R支持一系列分析技术,包括统计分析.预测建模.数据可视化.在CRAN上可以找到众多的扩张包. R软件的首选界面是命令行界面,通过编写脚本来调用相应的功能函数.同时,它也支持图形界面. R语言可以用来做数据挖掘,下面我们就用它来读取birth2.csv 中的内容. //birth2.csv ALGERIA ,36.4,14.6 CONGO ,37.3,8 EGYPT ,42.1,15.3 GHANA

DataList的使用分页用Button删除编辑 datalist中的内容数据源的绑定及表格的使用

以前没接触过datalist 这次做项目第一次使用它遇到一些问题所以跟大家分享一下以后遇到问题可以节约点时间先来个效果图吧先来说模版八我用的是ItemTemplate模块 1:先在页面中假如datalist控件接下来我们编辑模块选择ItemTempalte选项然后结束模版编辑 2:数据源的绑定数据源根据你自己的情况来选择我的数据在sql中所以选的这个按上面表好的步骤操作 4是你自己的数据库名称测试成功后一路默认选择下一步

JS 导出网页中Table内容到excel

1 <html> 2 <head> 3 <script type="text/javascript" language="javascript"> 4 var idTmr; 5 function method1(tableid) {//整个表格拷贝到EXCEL中 6 var curTbl = document.getElementById(tableid); 7 var oXL = new ActiveXObject("

[转]iOS技巧之获取本机通讯录中的内容，解析通讯录源代码

一.在工程中添加AddressBook.framework和AddressBookUI.framework 二.获取通讯录 1.在infterface中定义数组并在init方法中初始化 ? 1 2 3 4 5 6 NSMutableArray *addressBookTemp; - (id)initWithNibName:(NSString *)nibNameOrNil bundle:(NSBundle *)nibBundleOrNil { addressBookTemp = [NSMu