W3Cschool
恭喜您成為首批注冊用戶
獲得88經(jīng)驗值獎勵
該資源公開端點以支持任務(wù)范圍內(nèi)的操作。初始實現(xiàn)包括列出特定作業(yè)的所有任務(wù)的能力。這是“ 工作資源”的子資源,不能單獨使用。
各個端點的響應(yīng)將根據(jù)其功能和范圍而有所不同。但是,所有任務(wù)的資源端點的錯誤消息將具有以下形式。
錯誤信息
每個錯誤響應(yīng)將具有以下結(jié)構(gòu):
{
"message": "Unrecognized status parameter: null"
}
message 是響應(yīng)中唯一的字段,并包含對該問題的描述。
列出有關(guān)特定作業(yè)的所有任務(wù)的完整詳細信息
GET /v1/jobs/{jobName}/{jobId}/tasks
狀態(tài):200 OK
[
{
"preferredHost" : "samza-preferredHost",
"taskName" : "Samza task",
"containerId" : "0",
"partitions" : [{
"system" : "kafka",
"stream" : "topic-name",
"partitionId" : "0"
}]
}
]
狀態(tài) | 描述 |
---|---|
200好 | 操作成功完成,并返回作業(yè)的所有任務(wù)。 |
錯誤(404 | 提供了無效的作業(yè)實例作為參數(shù)。
|
500服務(wù)器錯誤 | 在服務(wù)器上執(zhí)行該命令時發(fā)生錯誤。例如命令超時。
|
TasksResource 需要兩個主要抽象,用戶可以通過這些抽象來處理特定于其環(huán)境的任何細節(jié)。
應(yīng)該在與 Samza REST 配置相同的文件中指定 TasksResource 屬性。
名稱 | 描述 |
---|---|
task.proxy.factory.class | 必需: TaskProxyFactory將用于創(chuàng)建TaskProxy實例。該值是必須實現(xiàn)TaskProxyFactory的完全限定類名稱。Samza配有一個實現(xiàn): org.apache.samza.rest.proxy.task.SamzaTaskProxy 獲取工作的所有任務(wù)的細節(jié)。它使用 SimpleInstallationRecord 與安裝在磁盤上的Samza作業(yè)進行交互。 |
job.installations.path | 必需:包含Samza作業(yè)安裝的文件系統(tǒng)路徑。路徑必須與Samza REST Service在同一主機上。每個安裝必須是一個目錄,其結(jié)構(gòu)符合JobProxy使用的InstallationRecord實現(xiàn)的期望。 |
job.config.factory.class | 用于閱讀Samza作業(yè)配置的配置工廠。這用于獲取InstallationRecord中每個作業(yè)實例的job.name和job.id屬性。它也用于驗證安裝路徑中的特定目錄實際包含Samza作業(yè)。如果沒有指定 org.apache.samza.config.factories.PropertiesConfigFactory 將會被使用。 |
Copyright©2021 w3cschool編程獅|閩ICP備15016281號-3|閩公網(wǎng)安備35020302033924號
違法和不良信息舉報電話:173-0602-2364|舉報郵箱:jubao@eeedong.com
掃描二維碼
下載編程獅App
編程獅公眾號
聯(lián)系方式:
更多建議: