查询job列表
功能介绍
异步任务jobId返回后,若jobId业务层丢失无法通过接口重新获取,现在提供一个新的接口用于查询engine中保存的所有异步任务,返回每个任务的jobId、job状态、原始请求。
图规格为一千亿的图,目前最多返回100000条请求。
URI
- URI 格式
GET /ges/v1.0/{project_id}/graphs/{graph_name}/jobs/status?limit={limit}&offset={offset}
- 参数说明
表1 URI参数说明 参数
是否必选
类型
说明
project_id
是
String
项目编号,用于资源隔离。请参考获取项目ID。
offset
否
Integer
本次查询偏移量,默认为0。
图规格为一千亿的图,暂不支持该参数。
job_id
是
String
Response对应的任务Job ID。
limit
否
Integer
本次查询返回最大数量(最大100000),默认为100000。
图规格为一千亿的图,暂不支持该参数。
请求
- 请求样例
GET /ges/v1.0/1/graphs/movie/jobs/status
响应
参数 |
是否必选 |
类型 |
说明 |
---|---|---|---|
errorMessage |
否 |
String |
系统提示信息,执行成功时,字段可能为空。执行失败时,用于显示错误信息。 |
errorCode |
否 |
String |
系统提示信息,执行成功时,字段可能为空。执行失败时,用于显示错误码。 |
result |
是 |
String |
查询成功时值为success,失败时值为failed |
jobs |
否 |
Json |
查询成功时包含jobs字段,jobs字段中包含系统中保存的job状态列表,单个job的状态结构如表2。 |
参数 |
是否必选 |
类型 |
说明 |
---|---|---|---|
jobId |
是 |
String |
JobId |
request |
是 |
Json |
请求内容,包括command、url和body体 |
status |
是 |
String |
Job执行状态,取值为pending/running/complete |
- 请求成功样例(一千亿边)
Http Status Code: 200 { "jobs": [ { "jobId": "62582163123991943683d0f9aa3-f701-48be-a662-360e6a0455da", "status": "complete", "request": { "command": "import_graph", "url": "/ges/v1.0/10001/graphs/moviejx/action?action_id=import-graph", "body": { "edgesetPath": "file:///root/ges-install/auDatas/ranking_edge-sp.csv", "vertexsetPath": "file:///root/ges-install/auDatas/movies_vertex_new.csv", "schemaPath": "file:///root/ges-install/auDatas/schema_aikv.xml.bak" } } }, { "jobId": "62582163123991943683fe74caf-f4d3-48b3-b3ee-66daaedcd2ca", "status": "complete", "request": { "command": "import_graph", "url": "/ges/v1.0/10001/graphs/moviejx/action?action_id=import-graph", "body": { "edgesetPath": "file:///root/ges-install/auDatas/ranking_edge-sp.csv", "vertexsetPath": "file:///root/ges-install/auDatas/movies_vertex_new.csv", "schemaPath": "file:///root/ges-install/auDatas/schema_aikv.xml.bak" } } }, { "jobId": "6258216312399194368daa80df3-e3bd-440d-9764-74f4622a550f", "status": "complete", "request": { "command": "import_graph", "url": "/ges/v1.0/10001/graphs/moviejx/action?action_id=import-graph", "body": { "edgesetPath": "file:///root/ges-install/auDatas/ranking_edge-sp.csv", "vertexsetPath": "file:///root/ges-install/auDatas/movies_vertex_new.csv", "schemaPath": "file:///root/ges-install/auDatas/schema_aikv.xml.bak" } } }, { "jobId": "62582163123991943680ed2761f-01f7-4fbf-b867-0a9aae6d9c12", "status": "complete", "request": { "command": "import_graph", "url": "/ges/v1.0/10001/graphs/moviejx/action?action_id=import-graph", "body": { "edgesetPath": "file:///root/ges-install/auDatas/ranking_edge-sp.csv", "vertexsetPath": "file:///root/ges-install/auDatas/movies_vertex_new.csv", "schemaPath": "file:///root/ges-install/auDatas/schema_aikv.xml.bak" } } } ], "result": "success" }
- 请求失败样例(一千亿边)
Http Status Code: 400 { "errorMessage": "graph : movidde not exist", "errorCode": "GES.8000", "result": "failed" }