2013-07-30 38 views
1

我試圖通過flume來獲取1TB左右的數據。爲此,我嘗試使用多路複用通道選擇器。Fluiz使用多路複用通道選擇器

有一些示例顯示如何使用多路複用通道選擇器。

我的問題是如何確定事件的標題內容?

例如,在以下結構中,我使用的與標頭,如國家和映射覆用信道選擇器,以CN,ID,IN等製成

spoolDirAgent.sources.source1.selector.type = multiplexing 
spoolDirAgent.sources.source1.selector.header = State 
spoolDirAgent.sources.source1.selector.mapping.CN = channel1 
spoolDirAgent.sources.source1.selector.mapping.IN = channel2 
spoolDirAgent.sources.source1.selector.mapping.ID = channel2 
spoolDirAgent.sources.source1.selector.defalut = channel1 

此外,如果可能的話,請讓我知道如何在水槽中使用事件頭?

在此先感謝!

+0

另外,請讓我知道我們如何檢查事件標題是否包含作爲狀態的標題值? – Avinash

回答

0

如flume-ng用戶指南所示,如果事件標題不包含關鍵字「狀態」,則將使用默認的 通道。並在Flume-ng用戶指南中搜索「靜態攔截器」,或多或少地知道如何將「狀態」鍵添加到標題中。

+0

我認爲正則表達式提取攔截器比靜態攔截器更合適。參見:http://stackoverflow.com/questions/19287766/how-to-use-regex-extractor-selector-and-multiplexing-interceptor-together-in-flu – frb