Samza 提供了可在群集中的任何節(jié)點上部署的 REST服務，并具有可插入接口以添加自定義資源和監(jiān)視器。它旨在成為一個常見的動作的節(jié)點本地委托，例如啟動作業(yè)，取樣本地狀態(tài)，測量磁盤使用情況，采取堆轉(zhuǎn)儲，驗證活動等等。

Samza REST服務尚未啟用 SSL 或身份驗證，因此最初適用于更多后端和操作用例。例如，在不允許用戶停止對方的工作的環(huán)境中將其暴露為面向用戶的 API 是不明智的。

Samza REST的打包和配置與 Samza 的工作非常相似。一個明顯的區(qū)別是 Samza REST 必須在要運行的每個主機上部署和執(zhí)行，而 Samza 作業(yè)通常在集群管理器的主節(jié)點上啟動，并且主人將作業(yè)部署到其他節(jié)點。

部署

Samza REST旨在成為需要從 Samza 群集節(jié)點執(zhí)行的所有操作的代理。它可以部署到集群中的所有主機，并可能在不同主機上提供不同的用途。在這種情況下，使用不同的配置部署相同的版本的壓縮來自定義主機角色的功能可能會有用。例如，Samza REST可以部署在具有 ResourceManager（RM）主機的一個配置和 NodeManager（NM））主機的另一個配置的 YARN 集群上。

部署服務與運行 Samza 工作非常相似。首先使用以下命令構建壓縮：

./gradlew samza-rest:clean releaseRestServiceTar

然后從提取的位置運行服務：

samza-example/target/bin/run-samza-rest-service.sh  \
  --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory \
  --config-path=file://$PWD/config/samza-rest.properties

兩個配置參數(shù)與 run-job.sh 的用途相同。

按照 入門教程 第一次快速部署和測試 Samza REST服務。

組態(tài)

Samza REST服務依賴于與 Samza Jobs 相同的配置系統(tǒng)。但是，Samza REST服務配置文件本身與 Samza 作業(yè)的配置文件完全不同。

配置可能提供核心配置的值，以及您可能添加到服務中的資源或監(jiān)視器所需的任何其他配置。包含核心服務配置和 JobsResource 的基本配置文件如下所示：

# Service port. Set to 0 for a dynamic port.
services.rest.port=9139

# JobProxy
job.proxy.factory.class=org.apache.samza.rest.proxy.job.SimpleYarnJobProxyFactory
# Installation path for hello-samza project. Your root may vary.
job.installations.path=/hello-samza-ROOT/deploy/samza

核心配置

rest.resource.classes

org.apache.samza.rest.resources.DefaultResourceFactory

記錄

Samza REST使用 SLF4J 進行日志記錄。在 run-samza-rest-service.sh 默認情況下，上述腳本需要在包的 bin 目錄中的 log4j.xml 和日志寫入到包根 logs 目錄。但是，由于腳本調(diào)用run-class.sh 用于運行 Samza 作業(yè)的相同腳本，因此可以重新配置與Samza作業(yè)的日志記錄非常相似。

Samza REST服務資源  ?