导入Flink作业

功能介绍

该API用于导入Flink作业数据。

授权信息

账号具备所有API的调用权限，如果使用账号下的IAM用户调用当前API，该IAM用户需具备调用API所需的权限。

• 如果使用角色与策略授权，具体权限要求请参见权限及授权项说明。
• 如果使用身份策略授权，需具备如下身份策略权限。

  授权项 Action	访问级别 Access Level	资源类型（*为必须） Resource Type (*: required)	条件键 Condition Key	别名 Alias	依赖的授权项 Dependencies
  dli:jobs:create	write	jobs *	-	-	-
  		-	g:RequestTag/<tag-key> g:TagKeys	-	-

URI

• URI格式

  POST /v1.0/{project_id}/streaming/jobs/import

• 参数说明

  表1 URI参数说明

  参数名称	是否必选	参数类型	说明
  project_id	是	String	项目编号，用于资源隔离。获取方式请参考获取项目ID。

请求消息

响应消息

请求示例

从OBS导入Flink作业数据，如果导入的作业与服务已有的作业同名，是否覆盖服务中已有的作业。

{
    "zip_file": "test/ggregate_1582677879475.zip",
    "is_cover": true
}

响应示例

{
    "is_success": true,
    "message": "导入作业成功",
    "job_mapping": [
        {
            "old_job_id": "100",
            "new_job_id": "200",
            "remark": "Job successfully created"
        }
    ]
}

状态码

状态码如表5所示。

错误码

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