首頁(yè)Python+大數(shù)據(jù)學(xué)習(xí)常見(jiàn)問(wèn)題正文

大數(shù)據(jù)培訓(xùn)：故障轉(zhuǎn)移機(jī)制

更新時(shí)間:2023年12月13日10時(shí)46分來(lái)源:傳智教育瀏覽次數(shù):

好口碑IT培訓(xùn)

　　故障轉(zhuǎn)移接收器處理器(Failover Sink Processor)維護(hù)一個(gè)具有優(yōu)先級(jí)的sink列表，保證在處理event只要有一個(gè)可用的sink即可。

　　故障轉(zhuǎn)移機(jī)制的工作原理是將故障的sink降級(jí)到故障池中，在池中為它們分配一個(gè)冷卻器，在重試之前冷卻時(shí)間會(huì)增加，當(dāng)sink成功發(fā)送event后，它將恢復(fù)到活躍池中。sink具有與之相關(guān)的優(yōu)先級(jí)，數(shù)值越大，優(yōu)先級(jí)越高。如果在發(fā)送event時(shí)sink發(fā)生故障，則會(huì)嘗試下一個(gè)具有最高優(yōu)先級(jí)的sink來(lái)繼續(xù)發(fā)送event。如果未指定優(yōu)先級(jí)，則根據(jù)配置文件中指定sink的順序確定優(yōu)先級(jí)。

　　Failover Sink Processor提供的配置屬性，如表8-14所示(加粗部分為必須屬性)。

　　表8-14 Failover Sink Processor屬性說(shuō)明

1702435193016_Failover-Sink-Processor屬性說(shuō)明.jpg

　　使用Failover Sink Processor配置一個(gè)名稱(chēng)為al的Agent示例如下。

al.sinkgroups=gl
al.sinkgroups.gl.sinks=k1 k2
al.sinkgroups.gl.processor.type=failover
al.sinkgroups.gl.processor.priority.kl=5
al.sinkgroups.gl.processor.priority.k2=10
al.sinkgroups.gl.processor.maxpenalty=10000

上一篇：大數(shù)據(jù)培訓(xùn)：Flume Sources的種類(lèi)有哪些? 下一篇：大數(shù)據(jù)培訓(xùn)：Avro Source有哪些常用屬性?