日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

《Flume日志收集与MapReduce模式》一2.2 Flume配置文件概览

發布時間:2025/3/20 编程问答 16 豆豆
生活随笔 收集整理的這篇文章主要介紹了 《Flume日志收集与MapReduce模式》一2.2 Flume配置文件概览 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

本節書摘來自華章出版社《Flume日志收集與MapReduce模式》一書中的第2章,第2.2節,作者 [美] 史蒂夫·霍夫曼(Steve Hoffman)斯里納特·佩雷拉(Srinath Perera),更多章節內容可以訪問云棲社區“華章計算機”公眾號查看

2.2 Flume配置文件概覽

既然已經下載好了Flume,下面來花點時間看看如何配置代理。
Flume代理的默認配置提供者使用了一個簡單的鍵值對的Java屬性文件,你需要在啟動時向代理傳遞一個參數。由于可以在單個文件中配置多個代理,因此還需要額外傳遞一個代理標識符(叫作名字),這樣它就知道該使用哪個代理了。在給出的示例中,我只指定了一個代理,使用agent這個名字。
每個代理的配置都以下面這3個參數開始:



每個源、通道與接收器在該代理的上下文中也有一個唯一的名字。比如,如果不打算傳遞Apache訪問日志,我就可以定義一個名為access的通道。該通道的配置都以前綴agent.channels.access開頭。每個配置項都有一個type屬性,告訴Flume是哪種源、通道還是接收器。在該示例中,我們使用一個內存通道,其類型為memory。名為agent的代理中的名為access的通道的完整配置如下所示:

為源、通道與接收器指定的任何參數都會使用相同的前綴以額外屬性的方式添加進來。memory通道有一個capacity參數,標識它能持有的最大的Flume事件數量。假如我們不想使用100這個默認值,那么配置文件將會如下所示:

最后,我們需要將access通道名添加到agent.channels屬性中,這樣代理就會加載它了:

下面來看看使用標準“Hello World”的完整示例。

總結

以上是生活随笔為你收集整理的《Flume日志收集与MapReduce模式》一2.2 Flume配置文件概览的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。