查询job列表(2.2.13)
功能介绍
异步任务jobId返回后，若jobId业务层丢失无法通过接口重新获取，现在提供一个新的接口用于查询engine中保存的所有异步任务，返回每个任务的jobId、job状态、原始请求。
URI
参数 |
是否必选 |
类型 |
说明 |
|---|---|---|---|
project_id |
是 |
String |
项目ID。获取方法请参见获取项目ID。 |
offset |
否 |
Integer |
本次查询偏移量，默认为0。 |
job_id |
是 |
String |
Response对应的任务Job ID。 |
limit |
否 |
Integer |
本次查询返回最大数量(最大100000)，默认为100000。 |
请求参数
详见路径参数。
响应参数
参数 |
类型 |
说明 |
|---|---|---|
errorMessage |
String |
系统提示信息。
|
errorCode |
String |
系统提示信息。
|
result |
String |
查询成功时值为success,失败时值为failed。 |
jobs |
Object |
查询成功时包含jobs字段，jobs字段中包含系统中保存的job状态列表，单个job的状态结构如表3。 |
参数 |
类型 |
说明 |
|---|---|---|
jobId |
String |
Job名称。 |
rawRequest |
String |
原始请求Body体 |
taskType |
String |
任务类型。 |
canStop |
Boolean |
任务能否被停止。 |
progress |
Integer |
任务进度，取值范围[0,100]。 |
startTime |
String |
起始时间，Date型字符串或时间戳。 |
endTime |
String |
终止时间，Date型字符串或时间戳。 |
status |
String |
Job执行状态，取值为pending/running/complete。 |
failReason |
String |
失败原因，当status为failed时才有。 |
files |
Object |
导入文件列表，当taskType为ImportGraph时才有。 |
请求示例
查询job列表， 返回每个任务的jobId、job状态。
GET /ges/v1.0/{project_id}/graphs/movie/jobs/status?limit=2&offset=0
响应示例
状态码： 200
成功响应示例
{
"jobs": [
{
"jobId": "b236a002-6acb-40cd-acca-bc3eb96b807d001680206",
"rawRequest": "{\"algorithmName\":\"shortest_path\",\"parameters\":{\"source\":\"0000\",\"target\":\"38\"}}",
"taskType": "Algorithm",
"canStop": false,
"progress": "100",
"startTime": "2024-05-23 09:54:00",
"failReason": "Running algorithm [shortest_path] error: parameter [source] is invalid!",
"endTime": "2024-05-23 09:54:00",
"status": "failed"
},
{
"jobId": "5a39d9f6-e955-4294-8ec6-2fe18eee98c7001680206",
"rawRequest": "{\"algorithmName\":\"shortest_path\",\"parameters\":{\"source\":\"46\",\"target\":\"38\"}}",
"taskType": "Algorithm",
"canStop": false,
"progress": "100",
"startTime": "2024-05-23 09:41:40",
"endTime": "2024-05-23 09:41:40",
"status": "success"
},
{
"jobId": "cef6ae30-f21b-4a2a-a83c-cf91bee679d9001680206",
"rawRequest": "",
"taskType": "ImportGraph",
"canStop": false,
"progress": "100",
"files": [
{
"edgeFiles": [
{
"fileName": "/root/ges-install/auDatas/ranking_edge.csv",
"totalLines": 1659,
"startTime": 1716428001745772,
"successfulLines": 1659,
"endTime": 1716428001757920,
"status": "success",
"failedLines": 0
}
]
},
{
"vertexFiles": [
{
"fileName": "/root/ges-install/auDatas/movies_vertex_new.csv",
"totalLines": 146,
"startTime": 1716428001656072,
"successfulLines": 146,
"endTime": 1716428001659352,
"status": "success",
"failedLines": 0
}
]
},
{
"schemaFiles": [
{
"totalLabels": 49,
"fileName": "/root/ges-install/auDatas/schema.xml.bak",
"failedLabels": 0,
"startTime": 1716428001563921,
"successfulLabels": 49,
"endTime": 1716428001655884,
"status": "success"
}
]
}
],
"startTime": "2024-05-23 09:33:21",
"endTime": "2024-05-23 09:33:21",
"status": "success"
}
],
"jobCount": 3
}
状态码： 400
失败响应示例
Http Status Code: 400
{
"errorMessage": "graph : movidde not exist",
"errorCode": "GES.8000",
"result": "failed"
}
状态码
返回值 |
说明 |
|---|---|
400 Bad Request |
请求错误。 |
401 Unauthorized |
鉴权失败。 |
403 Forbidden |
没有操作权限。 |
404 Not Found |
找不到资源。 |
500 Internal Server Error |
服务内部错误。 |
503 Service Unavailable |
服务不可用。 |
错误码
请参见错误码。
