Samza附錄二 任務(wù)資源

該資源公開端點(diǎn)以支持任務(wù)范圍內(nèi)的操作。初始實(shí)現(xiàn)包括列出特定作業(yè)的所有任務(wù)的能力。這是“ 工作資源”的子資源，不能單獨(dú)使用。

各個(gè)端點(diǎn)的響應(yīng)將根據(jù)其功能和范圍而有所不同。但是，所有任務(wù)的資源端點(diǎn)的錯(cuò)誤消息將具有以下形式。

錯(cuò)誤信息

每個(gè)錯(cuò)誤響應(yīng)將具有以下結(jié)構(gòu)：

{
    "message": "Unrecognized status parameter: null"
}

message 是響應(yīng)中唯一的字段，并包含對(duì)該問題的描述。 

獲取所有任務(wù)

列出有關(guān)特定作業(yè)的所有任務(wù)的完整詳細(xì)信息

請(qǐng)求

GET /v1/jobs/{jobName}/{jobId}/tasks

響應(yīng)

狀態(tài)：200 OK

[
{
   "preferredHost" : "samza-preferredHost",
   "taskName" : "Samza task",
   "containerId" : "0",
   "partitions" : [{
                      "system" : "kafka",
                      "stream" : "topic-name",
                      "partitionId" : "0"
                    }]
 }
 ]

響應(yīng)碼

{
    "message": "Invalid arguments for getTasks. jobName: SamzaJobName jobId: SamzaJobId."
}

{
    "message": "Timeout waiting for get all tasks."
}

設(shè)計(jì)

抽象

TasksResource 需要兩個(gè)主要抽象，用戶可以通過這些抽象來處理特定于其環(huán)境的任何細(xì)節(jié)。

1. TaskProxy：這個(gè)接口是與 Samza 任務(wù)交互的中心點(diǎn)。它暴露了一種方法來獲得 Samza 工作的所有任務(wù)。
2. InstallationFinder：InstallationFinder 提供了一個(gè)通用接口，用于發(fā)現(xiàn)所有安裝的作業(yè)，在作業(yè)包結(jié)構(gòu)及其位置隱藏任何自定義。InstallationFinder 還解決了用于驗(yàn)證和識(shí)別作業(yè)的作業(yè)配置。

組態(tài)

應(yīng)該在與 Samza REST 配置相同的文件中指定 TasksResource 屬性。

org.apache.samza.rest.proxy.task.SamzaTaskProxy

SimpleInstallationRecord

org.apache.samza.config.factories.PropertiesConfigFactory