更新时间:2025-03-05 GMT+08:00

查询job列表

功能介绍

异步任务jobId返回后,若jobId业务层丢失无法通过接口重新获取,现在提供一个新的接口用于查询engine中保存的所有异步任务,返回每个任务的jobId、job状态、原始请求。

URI

GET /ges/v1.0/{project_id}/graphs/{graph_name}/jobs/status?limit={limit}&offset={offset}
表1 路径参数

参数

是否必选

类型

说明

project_id

String

项目ID。获取方法请参见获取项目ID

offset

Integer

本次查询偏移量,默认为0。

job_id

String

Response对应的任务Job ID。

limit

Integer

本次查询返回最大数量(最大100000),默认为100000。

请求参数

详见路径参数。

响应参数

表2 响应Body参数说明

参数

类型

说明

errorMessage

String

系统提示信息。

  • 执行成功时,字段可能为空。
  • 执行失败时,用于显示错误信息。

errorCode

String

系统提示信息。

  • 执行成功时,字段可能为空。
  • 执行失败时,用于显示错误码。

result

String

查询成功时值为success,失败时值为failed。

jobs

Object

查询成功时包含jobs字段,jobs字段中包含系统中保存的job状态列表,单个job的状态结构如表3

表3 job状态结构

参数

类型

说明

jobId

String

Job名称。

request

Object

请求内容,包括command、url和body体。

status

String

Job执行状态,取值为pending/running/complete。

请求示例

查询job列表, 返回每个任务的jobId、job状态。

GET /ges/v1.0/{project_id}/graphs/{graph_name}/jobs/status?limit={limit}&offset={offset}

响应示例

状态码: 200

成功响应示例

{
    "jobs": [
        {
            "jobId": "527e0c2e-57ee-4c23-8cf7-baff8049c6b9001234245",
            "rawRequest": "{\"graphName\":\"ges_yiwan_jimengke\",\"offline\":false,\"edgesetPath\":\"/user/ges/data/ranking_edge.csv\",\"vertexsetPath\":\"/user/ges/data/movies_vertex_new.csv\",\"delimiter\":\",\",\"trimQuote\":\"\\\"\",\"vertexsetFormat\":\"csv\",\"parallelEdge\":{\"ignoreLabel\":true,\"action\":\"allow\"},\"edgesetFormat\":\"csv\"}",
            "taskType": "ImportGraph",
            "canStop": false,
            "progress": "100",
            "files": [
                {
                    "edgeFiles": [
                        {
                            "fileName": "/user/ges/data/ranking_edge.csv",
                            "totalLines": 1659,
                            "startTime": 1707201116130344,
                            "successfulLines": 1659,
                            "endTime": 1707201116149714,
                            "status": "success",
                            "failedLines": 0
                        }
                    ]
                },
                {
                    "vertexFiles": [
                        {
                            "fileName": "/user/ges/data/movies_vertex_new.csv",
                            "totalLines": 146,
                            "startTime": 1707201115842346,
                            "successfulLines": 146,
                            "endTime": 1707201115876634,
                            "status": "success",
                            "failedLines": 0
                        }
                    ]
                }
            ],
            "startTime": "2024-02-06 14:31:55",
            "endTime": "2024-02-06 14:31:56",
            "status": "success"
        },
        {
            "jobId": "9d43e7a1-bfc5-4990-b494-01c31098523e001234245",
            "rawRequest": "{\"graphName\":\"ges_yiwan_jimengke\",\"offline\":false,\"edgesetPath\":\"\",\"vertexsetPath\":\"\",\"delimiter\":\",\",\"schemaPath\":\"/user/ges/data/movie_schema.xml\",\"trimQuote\":\"\\\"\",\"vertexsetFormat\":\"csv\",\"parallelEdge\":{\"ignoreLabel\":true,\"action\":\"allow\"},\"edgesetFormat\":\"csv\"}",
            "taskType": "ImportGraph",
            "canStop": false,
            "progress": "100",
            "files": [
                {
                    "schemaFiles": [
                        {
                            "totalLabels": 4,
                            "fileName": "/user/ges/data/movie_schema.xml",
                            "failedLabels": 0,
                            "startTime": 1707201113260909,
                            "successfulLabels": 4,
                            "endTime": 1707201113369960,
                            "status": "success"
                        }
                    ]
                }
            ],
            "startTime": "2024-02-06 14:31:45",
            "endTime": "2024-02-06 14:31:53",
            "status": "success"
        }
    ],
    "jobCount": 2
}

状态码: 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

服务不可用。

错误码

请参见错误码