You need to enable JavaScript to run this app.
导航
临时查询(Beta)
最近更新时间:2025.11.25 16:05:23首次发布时间:2025.11.25 16:05:23
复制全文
我的收藏
有用
有用
无用
无用

在 Flink 控制台,您可以创建 Flink SQL 数据查询,通过简单的 SQL 语句表达您的业务逻辑,能够实现对外部数据,如数据湖等进行数据探索,也能够高效的完成一些调试和验证工作。

前提条件

您在开始开发 SQL 临时查询前,应提前完成以下准备工作:

  • 项目负责人或项目管理员(Project_Admin)已经在项目内创建好 Flink 资源池,请参见创建通用-VCI 资源池
  • 需要创建 Session 集群(当期仅支持 1.17 版本以上),并启动运行。请参见 创建 Session 集群
  • 一般是由开发人员(Project_Dev) 负责开发任务,请确保操作员已被添加为项目成员并为其关联角色,请参见添加项目成员
  • 当前临时查询仅限制使用部分 DQL 语句。更多 DML/DDL 后续版本即将支持。

  1. 登录流式计算 Flink 版控制台
  2. 在顶部菜单栏选择目标地域。
  3. 在左侧导航栏选择项目管理,在搜索框中根据项目名称进行模糊搜索,然后单击项目区块进入项目。
  4. 在项目左侧导航栏选择数据查询
  5. 数据查询页面单击加号按钮,创建任务。
    您也可以选择目标文件夹,直接在该文件夹中创建任务。

Image

  1. 创建作业对话框,设置脚本名称、所属文件夹等参数,然后单击确定

Image

配置

说明

任务名称

自定义设置任务的名称。
名称的字符长度限制在 1~48,支持数字、大小写英文字母、下划线(_)、短横线(-)和英文句号(.),且首尾只能是数字或字母。

所属文件夹

从下拉列表中选择目标文件夹。
系统默认存在一个数据开发文件夹,但为了更方便的管理任务,您可以自由创建文件夹。
如何创建文件夹,请参见管理任务文件夹

  1. 在任务上部区域,选择运行中的 Session 集群。如果没有运行中的 Session 集群请参考 创建 Session 集群 创建并且启动一个。

Image

  1. 在任务编辑区编辑 SQL 任务的业务逻辑代码。
    任务创建完后默认打开任务的代码编辑区,您可根据实际业务编写 SQL 代码。
    此处提供一个测试用例,可将其中 catalog 、db、table 等替换成实际生产内容。

    select
      now(), *
    from
      `<your_catalog>`.`<your_database>`.`<your_table>`
    limit
      10;
    
  2. 或者可以从数据目录 Tab 复制表名称,可以方便的生成查询目标:

Image

  1. 单击格式化按钮,系统自动调整SQL代码格式。
    系统将自动美化您的 SQL 语句,使得语句更加美观、整洁、可读。
  2. 代码编辑和验证通过后,单击保存按钮,保存任务代码。查询结果示意如下

Image