DLI SDK与API的对应关系
OBS授权
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Authorize |
OBS授权 |
- |
POST /v1.0/{project_id}/dli/obs-authorize |
队列相关
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Queue |
创建队列 |
- |
POST /v1.0/{project_id}/queues |
|
删除队列 |
- |
DELETE /v1.0/{project_id}/queues/{queue_name} |
||
获取默认队列 |
- |
- |
||
查询所有队列 |
GET/v1.0/{project_id}/queues |
资源相关
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
packageResources |
上传资源包 |
POST /v2.0/{project_id}/resources |
||
删除资源包 |
DELETE /v2.0/{project_id}/resources/{resource_name} |
|||
查询所有资源包 |
GET /v2.0/{project_id}/resources |
|||
查询指定资源包 |
GET /v2.0/{project_id}/resources/{resource_name} |
SQL作业相关
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Database |
创建数据库 |
POST /v1.0/{project_id}/databases |
||
删除数据库 |
DELETE /v1.0/{project_id}/databases/{database_name} |
|||
查询所有数据库 |
GET /v1.0/{project_id}/databases |
|||
修改数据库用户 |
- |
- |
PUT /v1.0/{project_id}/databases/{database_name}/owner |
|
Table |
创建DLI表 |
POST /v1.0/{project_id}/databases/{database_name}/tables |
||
创建OBS表 |
POST /v1.0/{project_id}/databases/{database_name}/tables |
|||
删除表 |
DELETE /v1.0/{project_id}/databases/{database_name}/tables/{table_name} |
|||
查询所有表 |
GET /v1.0/{project_id}/databases/{database_name}/tables?keyword=tb&with-detail=true |
|||
描述表信息 |
GET /v1.0/{project_id}/databases/{database_name}/tables/{table_name} |
|||
预览表内容 |
- |
- |
GET /v1.0/{project_id}/databases/{database_name}/tables/{table_name}/preview |
|
修改表用户 |
- |
- |
PUT /v1.0/{project_id}/databases/{database_name}/tables/{table_name}/owner |
|
Job |
导入数据 |
POST /v1.0/{project_id}/jobs/import-table |
||
导出数据 |
POST /v1.0/{project_id}/jobs/export-table |
|||
提交作业 |
POST /v1.0/{project_id}/jobs/submit-job |
|||
取消作业 |
- |
DELETE /v1.0/{project_id}/jobs/{job_id} |
||
查询所有作业 |
- |
GET /v1.0/{project_id}/jobs?page-size={size}¤t-page={page_number}&start={start_time}&end={end_time}&job-type={QUERY}&queue_name={test}&order={duration_desc} |
||
查询作业结果 |
- |
GET/v1.0/{project_id}/jobs/{job_id}?page-size={size}¤t-page={page_number} |
||
查询作业状态 |
- |
- |
GET/v1.0/{project_id}/jobs/{job_id}/status |
|
查询作业详细信息 |
- |
- |
GET/v1.0/{project_id}/jobs/{job_id}/detail |
|
查询SQL类型作业 |
- |
- |
||
检查SQL语法 |
- |
- |
POST /v1.0/{project_id}/jobs/check-sql |
|
导出查询结果 |
- |
- |
POST /v1.0/{project_id}/jobs/{job_id}/export-result |
Flink作业相关
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Job |
创建Flink SQL作业 |
- |
POST /v1.0/{project_id}/streaming/sql-jobs |
|
创建Flink自定义作业 |
- |
POST /v1.0/{project_id}/streaming/flink-jobs |
||
更新Flink SQL作业 |
- |
PUT /v1.0/{project_id}/streaming/sql-jobs/{job_id} |
||
更新Flink自定义作业 |
- |
PUT /v1.0/{project_id}/streaming/flink-jobs/{job_id} |
||
查询Flink作业列表 |
- |
GET /v1.0/{project_id}/streaming/jobs |
||
查询Flink作业详情 |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id} |
||
查询Flink作业执行计划图 |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id}/execute-graph |
||
查询Flink作业监控信息 |
- |
POST /v1.0/{project_id}/streaming/jobs/metrics |
||
查询Flink作业APIG网关服务访问地址 |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id}/apig-sinks |
||
运行Flink作业 |
- |
POST /v1.0/{project_id}/streaming/jobs/run |
||
停止Flink作业 |
- |
POST /v1.0/{project_id}/streaming/jobs/stop |
||
批量删除Flink作业 |
- |
POST /v1.0/{project_id}/streaming/jobs/delete |
Spark作业相关
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
BatchJob |
提交批处理作业 |
POST /v2.0/{project_id}/batches |
||
删除批处理作业 |
DELETE /v2.0/{project_id}/batches/{batch_id} |
|||
查询所有批处理作业 |
- |
GET /v2.0/{project_id}/batches |
||
查询批处理作业详情 |
- |
- |
GET /v2.0/{project_id}/batches/{batch_id} |
|
查询批处理作业状态 |
- |
GET /v2.0/{project_id}/batches/{batch_id}/state |
||
查询批处理作业日志 |
- |
GET /v2.0/{project_id}/batches/{batch_id}/log |
Flink作业模板相关
Class |
Java Method |
Python Method |
API |
---|---|---|---|
Template |
- |
POST /v1.0/{project_id}/streaming/job-templates |
|
- |
PUT /v1.0/{project_id}/streaming/job-templates/{template_id} |
||
- |
DELETE /v1.0/{project_id}/streaming/job-templates/{template_id} |
||
- |
GET /v1.0/{project_id}/streaming/job-templates |