API概览

更新时间:
复制 MD 格式

API标准及多语言预置SDK

本产品(ververica/2022-07-18)的OpenAPI采用ROA签名风格。我们已经为开发者封装了常见编程语言的SDK,开发者可通过下载SDK直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求,可通过签名机制进行自签名对接。由于自签名细节非常复杂,需花费 5个工作日左右。因此建议加入我们的服务钉钉群(147535001692),在专家指导下进行签名对接。

在使用API前,您需要准备好身份账号及访问密钥(AccessKey),才能有效通过客户端工具(SDK、CLI等)访问API。细节请参见获取AccessKey

自定义签名场景

若您的业务场景有特殊需求,需通过自签名方式对接 API,建议优先咨询我们的技术支持团队(服务钉钉群:147535001692),获取专业指导以确保高效接入。

账号与安全准备

阿里云账号具备对所有资源的完全管理权限。一旦 AccessKey 泄露,所有相关资源都将面临未经授权访问的风险。为确保安全,建议创建一个仅具备 API 访问权限的RAM用户并配置其 AccessKey,同时基于最小权限原则 (PoLP) 配置 RAM 策略。仅在明确需要阿里云账号权限的特定场景下,才使用阿里云账号。

作业草稿文件夹

API

标题

API概述

CreateFolder 创建文件夹 创建文件夹。
UpdateFolder 更新文件夹 调用本API可完成对文件夹信息的更新。
DeleteFolder 删除文件夹 删除空文件夹,如果该文件夹下存在其他文件或文件夹则无法删除。
GetFolder 获取文件夹信息 获取文件夹的具体信息

作业草稿

API

标题

API概述

CreateDeploymentDraft 创建作业草稿 创建SQL、数据摄入作业的草稿。
DeleteDeploymentDraft 删除作业草稿 删除SQL、数据摄入作业草稿,如该草稿存在已经上线或运行中的部署作业,则无法删除
UpdateDeploymentDraft 更新作业草稿 更新SQL、数据摄入作业草稿。
GetDeploymentDraft 获取作业草稿详情 获取SQL、数据摄入作业草稿详情。
DeployDeploymentDraftAsync 部署作业草稿 SQL作业草稿部署上线
GetDeployDeploymentDraftResult 获取作业草稿部署结果 根据作业草稿部署异步工单的ID信息,查看部署的结果
ValidateSqlStatement 验证sql语句 校验sql作业代码。
ListDeploymentDrafts 查看作业草稿列表 获取SQL、数据摄入作业草稿的列表信息
ValidateDeploymentDraftAsync 异步进行作业草稿深度检查 异步进行Flink作业草稿深度检查,进行语法检查、资源配置等合法性检验
GetValidateDeploymentDraftResult 查询深度检查结果 根据ticketId查询作业草稿深度校验的结果
GetDeploymentDraftLock 获取作业草稿锁 当您调用API编辑、检查、部署作业草稿时,为避免页面操作和API操作互相影响,您需要先获取作业草稿锁。拥有【开发SQL/YAML作业(创建、编辑)】或【解锁SQL/YAML作业草稿】任一权限即可获取锁。

自定义函数

API

标题

API概述

CreateUdfArtifact 创建自定义函数文件 通过对您上传的Jar/Python包的解析,解析您Jar/Python包中全部的UDF方法并为你创建自定义函数文件。
UpdateUdfArtifact 更新自定义函数文件 对已创建的自定义函数文件进行更新。
GetUdfArtifacts 获取自定义函数资源详情 获取您上传并创建的包含UDFJar或者Python文件的详情信息。
DeleteUdfArtifact 删除自定义函数资源 删除已经创建的自定义函数资源,删除前需要您先删除该资源下注册的自定义函数
DeleteUdfFunction 删除自定义函数 删除已注册的自定义函数。
RegisterUdfFunction 注册自定义函数 通过本API可以选择已创建的自定义函数文件中解析出的自定义函数,选择其中的部分或全部函数进行注册,注册后可在SQL中使用。

自定义连接器

API

标题

API概述

ListCustomConnectors 获取自定义连接器列表 获取已注册的自定义连接器的列表信息。
RegisterCustomConnector 注册自定义连接器 在项目空间下注册自定义连接器,注册的自定义连接器可以在SQL中使用。
DeleteCustomConnector 删除自定义连接器 删除已经注册的自定义连接器。

元数据

API

标题

API概述

GetDatabases 获取Database信息 获取指定CatalogDataBase的信息或列出所有DataBase的信息
GetTables 获取表信息 获取指定catalogdatabase下某张表的具体详情或者database下所有表的信息
GetCatalogs 获取Catalog信息 获取指定或全部catalog详情GetCatalogs
ExecuteSqlStatement 执行元数据SQL语句 您可以通过本API完成元数据相关SQL的运行,仅支持DDLDML,不支持DQL。

快照

API

标题

API概述

CreateSavepoint 创建快照 创建快照。
GetSavepoint 获取快照和系统检查点 获取快照和系统检查点的详细信息。
DeleteSavepoint 删除快照 删除快照。
ListSavepoints 获取作业快照及系统检查点列表 获取作业快照及最近系统检查点列表。

已部署作业

API

标题

API概述

GetDeploymentsByName 通过名称搜索已部署作业 本接口用于通过已部署作业名称搜索并获取指定工作空间和项目空间下匹配的已部署作业实例
GetDeploymentsByLabel 通过标签搜索已部署作业 本接口支持通过指定标签查询关联的已部署作业列表以及作业信息
GetDeploymentsByIp 通过IP搜索已部署作业 本接口支持通过指定IP查询该节点上已部署作业列表以及作业信息。
CreateDeployment 创建已部署作业 创建一个已部署作业。
UpdateDeployment 更新已部署作业 更新已部署作业的信息。
UpdateDeploymentByName 通过名称更新部署作业 该接口支持根据部署作业名称更新部署作业详情以及配置参数等。
GetDeployment 获取已部署作业 获取已部署作业的详细信息。
ListDeployments 获取已部署作业列表 获取所有已部署作业的信息。
DeleteDeployment 删除已部署作业 根据已部署作业ID删除已部署作业。
DeleteDeploymentByName 通过名称删除已部署作业 本接口用于根据已部署作业名称删除指定工作空间和项目空间下的作业部署实例信息。
GetEvents 获取运行事件 获取运行事件

作业实例

API

标题

API概述

GetJob 获取作业实例 获取作业实例的详细信息。
ListJobs 获取作业实例列表 获取到某个已部署作业下所有作业实例的信息。
StartJobWithParams 启动作业实例 启动一个作业实例。
StopJob 停止作业实例 停止一个作业实例。
DeleteJob 删除作业实例 删除一个作业下非运行状态的作业实例信息。
HotUpdateJob 动态更新作业 对正在运行的作业进行参数或资源的动态更新。
GetHotUpdateJobResult 获取作业动态更新结果 对作业进行动态更新时,可通过本API获取作业动态更新的结果
GetLatestJobStartLog 获取最新作业实例的启动日志 获取作业实例最新的启动日志。
GetJobDiagnosis 获取作业诊断详情 智能诊断作业,获取异常诊断项信息
StartJob 启动作业实例(废弃) 创建并启动一个作业实例。

数据血缘

API

标题

API概述

GetLineageInfo 获取血缘信息 通过本API可以获取作业和数据的血缘信息。

定时计划

API

标题

API概述

CreateScheduledPlan 创建定时计划 创建定时计划
UpdateScheduledPlan 更新定时计划 更新定时计划
DeleteScheduledPlan 删除定时计划 删除定时计划
ListScheduledPlan 获取定时计划列表 获取定时计划的列表信息
ApplyScheduledPlan 应用定时计划 执行定时计划
StopApplyScheduledPlan 停止应用定时计划 停止应用定时计划
GetAppliedScheduledPlan 获取应用的定时计划 获取应用的执行计划
ListScheduledPlanExecutedHistory 获取定时计划执行历史 获取定时计划执行历史

自动调优计划

API

标题

API概述

UpdateAutopilotPolicy 修改自动调优配置 更新Autopilot 调优策略
ListAutopilotTuningHistories 查询调优历史记录 获取Autopilot调优历史记录
GetAutopilotPolicy 查询Autopilot调优配置 获取Autopilot调优配置。

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概述

CreateDeploymentTargetV2 创建部署目标(V2版本) 创建部署目标
UpdateDeploymentTargetV2 更新部署目标(V2) 更新部署目标
CreateDeploymentTarget 创建部署目标 创建部署目标
UpdateDeploymentTarget 更新部署目标 更新部署目标
DeleteDeploymentTarget 删除部署目标 删除部署目标
ListDeploymentTargets 获取部署目标列表 获取作业可部署目标的列表,部署目标是session集群或者perjob集群。

数据查询

API

标题

API概述

StartSqlExecution 执行SQL数据查询脚本 该接口用于执行sql数据查询脚本任务。
StopSqlExecution 停止SQL数据查询脚本 该接口用于执行sql数据查询脚本任务。
FetchSqlExecutionResult 获取Sql查询执行结果 该接口用于获取平台提交的 SQL 数据查询执行结果。
CreateSqlFile 创建查询脚本 该接口用于创建一个 SQL 类型的查询脚本作业文件。
GetSqlFile 获取查询脚本 该接口用于获取已创建的 SQL 查询脚本详情。
DeleteSqlFile 删除查询脚本 该接口用于删除一个已创建的 SQL 查询脚本文件。
UpdateSqlFile 获取查询脚本 该接口用于跟更新已创建的 SQL 查询脚本。

变量

API

标题

API概述

UpdateVariable 修改项目变量 修改项目级别的变量。
CreateVariable 创建变量 创建变量。
DeleteVariable 删除变量 删除变量。
ListVariables 获取变量列表 获取变量列表。

成员管理

API

标题

API概述

CreateMember 新增成员授权 将一个用户添加到对应项目空间下并授予对应权限。
UpdateMember 更新用户授权信息 更新特定项目空间下某个或某些用户的权限。
DeleteMember 删除用户权限 删除指定的用户权限信息。
GetMember 查看成员授权信息 查看用户授权详情。
ListMembers 查看项目下成员授权列表 查看特定项目下用户UID和授权的对应关系。

智能助手

API

标题

API概述

ChatAiAgent 发起智能助手对话 AI Agent进行流式对话

其他

API

标题

API概述

ListEngineVersionMetadata 获取引擎版本列表 获取系统支持的引擎版本列表。
GenerateResourcePlanWithFlinkConfAsync 异步生成细粒度资源 提交异步生成resource plan工单,返回一个异步工单ID用于查询工单结果。
GetGenerateResourcePlanResult 获取异步生成细粒度资源结果 根据异步工单ID获取异步生成细粒度资源结果。
FlinkApiProxy Flink Rest API代理 您可以使用flink rest api的方式来调用本接口,获取session集群或者运行作业的相关信息。注意本接口仅支持您获取相关信息,无法对session集群和作业进行操作或管理。