Samza REST服務(wù)監(jiān)視器

Samza REST支持向服務(wù)添加監(jiān)視器的功能。監(jiān)視器本質(zhì)上是可以定期運(yùn)行的任務(wù)。它為用戶提供了定義于特定單個(gè)監(jiān)視器的配置的能力。這些配置通過 Config 實(shí)例注入到監(jiān)視器實(shí)例中。

監(jiān)視器配置

監(jiān)視器的所有配置鍵應(yīng)帶有 monitor.{monitorName} 的前綴。由于每個(gè)監(jiān)視器預(yù)期具有唯一的名稱，因此這些前綴在監(jiān)視器配置中提供命名空間。

每個(gè)監(jiān)視器都需要以下配置。

例如，兩個(gè)名為 NMTaskMonitor 和 RMTaskMonitor 的監(jiān)視器的配置應(yīng)如下定義：

monitor.RMTaskMonitor.factory.class=org.apache.samza.monitor.RMTaskMonitor

  monitor.RMTaskMonitor.scheduling.interval.ms=1000

  monitor.RMTaskMonitor.custom.config.key1=configValue1

  monitor.NMTaskMonitor.factory.class=org.apache.samza.monitor.NMTaskMonitor

  monitor.NMTaskMonitor.scheduling.interval.ms=2000

  monitor.NMTaskMonitor.custom.config.key2=configValue2

實(shí)施新的監(jiān)視器

使用應(yīng)該定期執(zhí)行的一些行為來實(shí)現(xiàn) Monitor 界面。監(jiān)視器是在 SAMZA Rest Service 中調(diào)用某些方法的 Java 代碼，運(yùn)行一個(gè) bash 腳本來重新啟動(dòng)失敗的 NodeManager，或者清除Host Affinity 剩下的舊的 RocksDB sst 文件。

實(shí)現(xiàn) MonitorFactory 接口，用于實(shí)例化 Monitor。每個(gè) Monitor 實(shí)現(xiàn)都應(yīng)該有一個(gè)關(guān)聯(lián)的 MonitorFactory 實(shí)現(xiàn)，它負(fù)責(zé)實(shí)例化監(jiān)視器。

向 Samza REST服務(wù)添加新的監(jiān)視器

將 MonitorFactory 實(shí)現(xiàn)的完全限定類名添加到 monitor.monitorName.factory.classservice config 中的屬性中。將配置密鑰 monitor.monitorName.scheduling.interval.ms 設(shè)置為調(diào)度間隔（以毫秒為單位）。

配置密鑰 monitor.monitorName.scheduling.interval.ms 定義方法的周期調(diào)度間隔，單位為 monitor()毫秒。

從監(jiān)視器報(bào)告指標(biāo)

Samza REST服務(wù)允許用戶從其顯示器創(chuàng)建和報(bào)告指標(biāo)。對度量系統(tǒng)的報(bào)告指標(biāo)由度量報(bào)告器封裝，該指標(biāo)應(yīng)在 samza-rest 配置文件中定義。Samza REST服務(wù)中度量報(bào)告員的配置與Samza Jobs的配置相同。

Samza REST服務(wù)資源參考?