更新时间:2022-12-07 GMT+08:00
导入Flink作业
功能介绍
该API用于导入Flink作业数据。
URI
- URI格式
- 参数说明
表1 URI参数说明 参数名称
是否必选
参数类型
说明
project_id
是
String
项目编号,用于资源隔离。获取方式请参考获取项目ID。
请求消息
参数名称 |
是否必选 |
参数类型 |
说明 |
---|---|---|---|
zip_file |
是 |
String |
从OBS上导入的作业zip文件路径,支持填写文件夹,导入文件夹下的所有zip文件。
说明:
文件夹中只能包含zip文件。 |
is_cover |
否 |
Boolean |
如果导入的作业与服务已有的作业同名,是否覆盖服务中已有的作业。 |
响应消息
参数名称 |
是否必选 |
参数类型 |
说明 |
---|---|---|---|
is_success |
否 |
Boolean |
执行请求是否成功。“true”表示请求执行成功。 |
message |
否 |
String |
系统提示信息,执行成功时,信息可能为空。 |
job_mapping |
否 |
Array of Objects |
导入作业的信息。具体请参考表4。 |
请求示例
{ "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" } ] }
错误码
调用接口出错后,将不会返回上述结果,而是返回错误码和错误信息,更多介绍请参见错误码。
父主题: Flink作业相关API