文档首页/ 数据湖探索 DLI/ API参考/ 历史API/ IEF相关API(废弃)/ 边缘Flink作业状态上报(废弃)
更新时间:2023-11-27 GMT+08:00
分享

边缘Flink作业状态上报(废弃)

功能介绍

该API用于处理边缘Flink作业状态上报信息。

DLI不再支持边缘作业场景的API调用。

调试

您可以在API Explorer中调试该接口。

URI

  • URI格式

    POST /v1/{project_id}/edgesrv/job-report

  • 参数说明
    表1 URI参数说明

    参数名称

    是否必选

    参数类型

    说明

    project_id

    String

    项目编号,用于资源隔离。获取方式请参考获取项目ID

请求消息

  • 请求样例
    表2 请求参数说明

    参数名称

    是否必选

    参数类型

    说明

    jobs

    Array of Objects

    作业信息列表。具体请参考表3

    msg_confirm_topic

    String

    消息确认topic。

    message_id

    String

    消息id。

    表3 jobs参数说明

    参数名称

    是否必选

    参数类型

    说明

    job_id

    Integer

    作业ID。

    status

    String

    作业状态。

    create_time

    Long

    时间戳。

    exceptions

    String

    作业异常信息。

    metrics

    String

    作业指标信息。

    plan

    String

    作业执行计划。

响应消息

表4 响应参数说明

参数名称

是否必选

参数类型

说明

is_success

Boolean

执行请求是否成功。“true”表示请求执行成功。

message

String

消息内容。

请求示例

上报ID为99270的边缘Flink作业状态。

{
    "jobs": [
        {
            "create_time": 1591104868201,
            "job_id": 99270,
            "exceptions": {
                "error_id": "Agent.51000",
                "error_type": "JOB_SUBMIT_EXCEPTION",
                "error_cause": "agent_submit_job_exception_error",
                "exception": "",
                "error_time": "2020-06-02 13:34:28"
            },
            "status": "job_submit_fail"
        }
    ],
    "msg_confirm_topic": "hw/events/messages/dli/message/confirm",
    "message_id": "uuid"
}

响应示例

{
    "is_success": "true",
    "message": "IEF Flink作业状态信息上报成功"
}

状态码

状态码如表5所示。

表5 状态码

状态码

描述

200

IEF Flink作业状态信息上报成功。

400

请求错误。

错误码

调用接口出错后,将不会返回上述结果,而是返回错误码和错误信息,更多介绍请参见错误码

相关文档