本产品(
实时计算 Flink版/2022-07-18)的OpenAPI采用ROA签名风格,签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过下载SDK直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求,可通过签名机制进行自签名对接。由于自签名细节非常复杂,需花费 5个工作日左右。因此建议加入我们的服务钉钉群(78410016550),在专家指导下进行签名对接。在使用API前,您需要准备好身份账号及访问密钥(AccessKey),才能有效通过客户端工具(SDK、CLI等)访问API。细节请参见获取AccessKey。
作业草稿文件夹
| API | 标题 | API概述 | 
|---|---|---|
| CreateFolder | 创建文件夹 | 创建文件夹。 | 
| UpdateFolder | 更新文件夹 | 调用本API可完成对文件夹信息的更新。 | 
| DeleteFolder | 删除文件夹 | 删除空文件夹,如果该文件夹下存在其他文件或文件夹则无法删除。 | 
| GetFolder | 获取文件夹信息 | 获取文件夹的具体信息。 | 
作业草稿
| API | 标题 | API概述 | 
|---|---|---|
| CreateDeploymentDraft | 创建作业草稿 | 创建SQL作业的作业草稿。 | 
| UpdateDeploymentDraft | 更新作业草稿 | 更新SQL作业草稿。 | 
| DeleteDeploymentDraft | 删除作业草稿 | 删除SQL作业草稿,如该草稿存在已经上线或运行中的部署作业,则无法删除。 | 
| GetDeploymentDraft | 获取作业草稿详情 | 获取sql作业草稿详情。 | 
| ListDeploymentDrafts | 查看作业草稿列表 | 获取SQL作业草稿的列表信息。 | 
| GetDeploymentDraftLock | 获取作业草稿编辑锁 | 当您调用API编辑作业草稿时,为避免页面操作和API操作互相影响,您需要先获取编辑锁。 | 
| DeployDeploymentDraftAsync | 部署作业草稿 | SQL作业草稿部署上线。 | 
| GetDeployDeploymentDraftResult | 获取作业草稿部署结果 | 根据作业草稿部署异步工单的ID信息,查看部署的结果。 | 
自定义函数
| API | 标题 | API概述 | 
|---|---|---|
| CreateUdfArtifact | 创建自定义函数文件 | 通过对您上传的Jar/Python包的解析,解析您Jar/Python包中全部的UDF方法并为你创建自定义函数文件。 | 
| UpdateUdfArtifact | 更新自定义函数文件 | 对已创建的自定义函数文件进行更新。 | 
| GetUdfArtifacts | 获取自定义函数资源详情 | 获取您上传并创建的包含UDF的Jar或者Python文件的详情信息。 | 
| DeleteUdfArtifact | 删除自定义函数资源 | 删除已经创建的自定义函数资源,删除前需要您先删除该资源下注册的自定义函数。 | 
| DeleteUdfFunction | 删除自定义函数 | 删除已注册的自定义函数。 | 
| RegisterUdfFunction | 注册自定义函数 | 通过本API可以选择已创建的自定义函数文件中解析出的自定义函数,选择其中的部分或全部函数进行注册,注册后可在SQL中使用。 | 
自定义连接器
| API | 标题 | API概述 | 
|---|---|---|
| ListCustomConnectors | 获取自定义连接器列表 | 获取已注册的自定义连接器的列表信息。 | 
| RegisterCustomConnector | 注册自定义连接器 | 在项目空间下注册自定义连接器,注册的自定义连接器可以在SQL中使用。 | 
| DeleteCustomConnector | 删除自定义连接器 | 删除已经注册的自定义连接器。 | 
元数据
| API | 标题 | API概述 | 
|---|---|---|
| GetDatabases | 获取Database信息 | 获取指定Catalog下DataBase的信息或列出所有DataBase的信息。 | 
| GetTables | 获取表信息 | 获取指定catalog的database下某张表的具体详情或者database下所有表的信息。 | 
| GetCatalogs | 获取Catalog信息 | 获取指定或全部catalog详情。 | 
| ExecuteSqlStatement | 执行元数据SQL语句 | 您可以通过本API完成元数据相关SQL的运行,仅支持DDL和DML,不支持DQL。 | 
快照
| API | 标题 | API概述 | 
|---|---|---|
| CreateSavepoint | 创建快照 | 创建快照。 | 
| GetSavepoint | 获取快照和系统检查点 | 获取快照和系统检查点的详细信息。 | 
| DeleteSavepoint | 删除快照 | 删除快照。 | 
| ListSavepoints | 获取作业快照及系统检查点列表 | 获取作业快照及最近系统检查点列表。 | 
已部署作业
| API | 标题 | API概述 | 
|---|---|---|
| CreateDeployment | 创建已部署作业 | 创建一个已部署作业。 | 
| UpdateDeployment | 更新已部署作业 | 更新已部署作业的信息。 | 
| GetDeployment | 获取已部署作业 | 获取已部署作业的详细信息。 | 
| ListDeployments | 获取已部署作业列表 | 获取所有已部署作业的信息。 | 
| DeleteDeployment | 删除已部署作业 | 根据已部署作业ID删除已部署作业。 | 
| GetEvents | 获取运行事件 | 获取运行事件。 | 
作业实例
| API | 标题 | API概述 | 
|---|---|---|
| GetJob | 获取作业实例 | 获取作业实例的详细信息。 | 
| ListJobs | 获取作业实例列表 | 获取到某个已部署作业下所有作业实例的信息。 | 
| StartJobWithParams | 启动作业实例 | 启动一个作业实例。 | 
| StopJob | 停止作业实例 | 停止一个作业实例。 | 
| DeleteJob | 删除作业实例 | 删除一个作业下非运行状态的作业实例信息。 | 
| HotUpdateJob | 动态更新作业 | 对正在运行的作业进行参数或资源的动态更新。 | 
| GetHotUpdateJobResult | 获取作业动态更新结果 | 对作业进行动态更新时,可通过本API获取作业动态更新的结果。 | 
| GetLatestJobStartLog | 获取最新作业实例的启动日志 | 获取作业实例最新的启动日志。 | 
| StartJob | 启动作业实例(废弃) | 创建并启动一个作业实例。 | 
定时计划
| API | 标题 | API概述 | 
|---|---|---|
| CreateScheduledPlan | 创建定时计划 | 创建定时计划。 | 
| UpdateScheduledPlan | 更新定时计划 | 更新定时计划。 | 
| DeleteScheduledPlan | 删除定时计划 | 删除定时计划。 | 
| ListScheduledPlan | 获取定时计划列表 | 获取定时计划的列表信息。 | 
| ApplyScheduledPlan | 应用定时计划 | 执行定时计划。 | 
| StopApplyScheduledPlan | 停止应用定时计划 | 停止应用定时计划。 | 
| GetAppliedScheduledPlan | 获取应用的定时计划 | 获取应用的执行计划。 | 
| ListScheduledPlanExecutedHistory | 获取定时计划执行历史 | 获取定时计划执行历史。 | 
Session集群
| API | 标题 | API概述 | 
|---|---|---|
| CreateSessionCluster | 创建Session集群 | 创建Session集群。 | 
| UpdateSessionCluster | 更新Session集群 | 更新Session集群。 | 
| DeleteSessionCluster | 删除Session集群 | 删除Session集群。 | 
| GetSessionCluster | 获取Session集群 | 获取Session集群。 | 
| ListSessionClusters | 获取Session集群列表 | 获取Session集群的列表信息。 | 
| StartSessionCluster | 启动Session集群 | 启动Session集群。 | 
| StopSessionCluster | 停止Session集群 | 停止Session集群。 | 
作业部署目标
| API | 标题 | API概述 | 
|---|---|---|
| CreateDeploymentTarget | 创建部署目标 | 创建部署目标。 | 
| UpdateDeploymentTarget | 更新部署目标 | 更新部署目标。 | 
| DeleteDeploymentTarget | 删除部署目标 | 删除部署目标。 | 
| ListDeploymentTargets | 获取部署目标列表 | 获取作业可部署目标的列表,部署目标是session集群或者perjob集群。 | 
成员管理
| API | 标题 | API概述 | 
|---|---|---|
| CreateMember | 新增成员授权 | 将一个用户添加到对应项目空间下并授予对应权限。 | 
| UpdateMember | 更新用户授权信息 | 更新特定项目空间下某个或某些用户的权限。 | 
| DeleteMember | 删除用户权限 | 删除指定的用户权限信息。 | 
| GetMember | 查看成员授权信息 | 查看用户授权详情。 | 
| ListMembers | 查看项目下成员授权列表 | 查看特定项目下用户UID和授权的对应关系。 | 
变量
| API | 标题 | API概述 | 
|---|---|---|
| UpdateVariable | 修改项目变量 | 修改项目级别的变量。 | 
| CreateVariable | 创建变量 | 创建变量。 | 
| DeleteVariable | 删除变量 | 删除变量。 | 
| ListVariables | 获取变量列表 | 获取变量列表。 | 
其他
| API | 标题 | API概述 | 
|---|---|---|
| GetJobDiagnosis | 获取作业诊断详情 | 智能诊断作业,获取异常诊断项信息。 | 
| ListEngineVersionMetadata | 获取引擎版本列表 | 获取系统支持的引擎版本列表。 | 
| ValidateSqlStatement | 验证sql语句 | 校验sql作业代码。 | 
| GenerateResourcePlanWithFlinkConfAsync | 异步生成细粒度资源 | 提交异步生成resource plan工单,返回一个异步工单ID用于查询工单结果。 | 
| GetGenerateResourcePlanResult | 获取异步生成细粒度资源结果 | 根据异步工单ID获取异步生成细粒度资源结果。 | 
| FlinkApiProxy | Flink Rest API代理 | 您可以使用flink rest api的方式来调用本接口,获取session集群或者运行作业的相关信息。注意本接口仅支持您获取相关信息,无法对session集群和作业进行操作或管理。 | 
| GetLineageInfo | 获取血缘信息 | 通过本API可以获取作业和数据的血缘信息。 |