DLI SDK与API的对应关系

Authorize

OBS授权

authorizeBucket

-

POST /v1.0/{project_id}/dli/obs-authorize

Queue

创建队列

createQueue

-

POST /v1.0/{project_id}/queues

删除队列

deleteQueue

-

DELETE /v1.0/{project_id}/queues/{queue_name}

获取默认队列

getDefaultQueue

-

-

查询所有队列

listAllQueues

list_queues

GET/v1.0/{project_id}/queues

packageResources

上传资源包

uploadResources

upload_resource

POST /v2.0/{project_id}/resources

删除资源包

deleteResource

delete_resource

DELETE /v2.0/{project_id}/resources/{resource_name}

查询所有资源包

listAllResources

list_resources

GET /v2.0/{project_id}/resources

查询指定资源包

getResource

get_package_resource

GET /v2.0/{project_id}/resources/{resource_name}

Database

创建数据库

createDatabase

create_database

POST /v1.0/{project_id}/databases

删除数据库

deleteDatabase

delete_database

DELETE /v1.0/{project_id}/databases/{database_name}

查询所有数据库

listAllDatabases

list_databases

GET /v1.0/{project_id}/databases

修改数据库用户

-

-

PUT /v1.0/{project_id}/databases/{database_name}/owner

Table

创建DLI表

createDLITable

create_dli_table

POST /v1.0/{project_id}/databases/{database_name}/tables

创建OBS表

createObsTable

create_obs_table

POST /v1.0/{project_id}/databases/{database_name}/tables

删除表

deleteTable

delete_table

DELETE /v1.0/{project_id}/databases/{database_name}/tables/{table_name}

查询所有表

listAllTables

list_tables

GET /v1.0/{project_id}/databases/{database_name}/tables?keyword=tb&with-detail=true

描述表信息

getTableDetail

get_table_schema

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

导入数据

submit

import_table

POST /v1.0/{project_id}/jobs/import-table

导出数据

submit

export_table

POST /v1.0/{project_id}/jobs/export-table

提交作业

submit

execute_sql

POST /v1.0/{project_id}/jobs/submit-job

取消作业

cancelJob

-

DELETE /v1.0/{project_id}/jobs/{job_id}

查询所有作业

listAllJobs

-

GET /v1.0/{project_id}/jobs?page-size={size}&current-page={page_number}&start={start_time}&end={end_time}&job-type={QUERY}&queue_name={test}&order={duration_desc}

查询作业结果

queryJobResultInfo

-

GET/v1.0/{project_id}/jobs/{job_id}?page-size={size}&current-page={page_number}

查询作业状态

-

-

GET/v1.0/{project_id}/jobs/{job_id}/status

查询作业详细信息

-

-

GET/v1.0/{project_id}/jobs/{job_id}/detail

查询SQL类型作业

listSQLJobs

-

-

检查SQL语法

-

-

POST /v1.0/{project_id}/jobs/check-sql

导出查询结果

-

-

POST /v1.0/{project_id}/jobs/{job_id}/export-result

Job

创建Flink SQL作业

submitFlinkSqlJob

-

POST /v1.0/{project_id}/streaming/sql-jobs

创建Flink自定义作业

createFlinkJarJob

-

POST /v1.0/{project_id}/streaming/flink-jobs

更新Flink SQL作业

updateFlinkSqlJob

-

PUT /v1.0/{project_id}/streaming/sql-jobs/{job_id}

更新Flink自定义作业

updateFlinkJarJob

-

PUT /v1.0/{project_id}/streaming/flink-jobs/{job_id}

查询Flink作业列表

getFlinkJobs

-

GET /v1.0/{project_id}/streaming/jobs

查询Flink作业详情

getFlinkJobDetail

-

GET /v1.0/{project_id}/streaming/jobs/{job_id}

查询Flink作业执行计划图

getFlinkJobExecuteGraph

-

GET /v1.0/{project_id}/streaming/jobs/{job_id}/execute-graph

查询Flink作业监控信息

getFlinkJobsMetrics

-

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

查询Flink作业APIG网关服务访问地址

getFlinkApigSinks

-

GET /v1.0/{project_id}/streaming/jobs/{job_id}/apig-sinks

运行Flink作业

runFlinkJob

-

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

停止Flink作业

stopFlinkJob

-

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

批量删除Flink作业

deleteFlinkJobInBatch

-

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

BatchJob

提交批处理作业

asyncSubmit

submit_spark_batch_job

POST /v2.0/{project_id}/batches

删除批处理作业

deleteBatchJob

del_spark_batch_job

DELETE /v2.0/{project_id}/batches/{batch_id}

查询所有批处理作业

listAllBatchJobs

-

GET /v2.0/{project_id}/batches

查询批处理作业详情

-

-

GET /v2.0/{project_id}/batches/{batch_id}

查询批处理作业状态

getStateBatchJob

-

GET /v2.0/{project_id}/batches/{batch_id}/state

查询批处理作业日志

getBatchJobLog

-

GET /v2.0/{project_id}/batches/{batch_id}/log

Template

createFlinkJobTemplate

-

POST /v1.0/{project_id}/streaming/job-templates

updateFlinkJobTemplate

-

PUT /v1.0/{project_id}/streaming/job-templates/{template_id}

deleteFlinkJobTemplate

-

DELETE /v1.0/{project_id}/streaming/job-templates/{template_id}

getFlinkJobTemplates

-

GET /v1.0/{project_id}/streaming/job-templates