DLI SDK V1与API的对应关系

OBS授权

表1 OBS授权相关API&SDK的对应关系表
Class	Method	Java Method	Python Method	API
Authorize	OBS授权	authorizeBucket	-	POST /v1.0/{project_id}/dli/obs-authorize

队列相关

表2 队列相关API&SDK的对应关系表
Class	Method	Java Method	Python Method	API
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

资源相关

表3 资源相关API&SDK的对应关系表
Class	Method	Java Method	Python Method	API
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}

SQL作业相关

表4 SQL作业相关API&SDK的对应关系表
Class	Method	Java Method	Python Method	API
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

Flink作业相关

表5 Flink作业相关API&SDK的对应关系表
Class	Method	Java Method	Python Method	API
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

Spark作业相关

表6 Spark作业相关API&SDK的对应关系表
Class	Method	Java Method	Python Method	API
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

Flink作业模板相关

表7 Flink作业模板相关API&SDK的对应关系表
Class	Java Method	Python Method	API
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