SQL

SQL任务类型,用于连接数据库并执行相应SQL。本文为您介绍创建SQL类型任务时涉及的参数,并提供了SQL任务的示例。

参数说明

参数

说明

节点名称

任务的名称。一个工作流定义中的节点名称是唯一的。

运行标志

  • 正常(默认):运行工作流时执行该任务。

  • 禁止执行:运行工作流不会执行该任务。

描述

当前节点的功能描述。

任务优先级

流程运行的优先级。支持以下级别:

  • HIGHEST:最高。

  • HIGH:高。

  • MEDIUM(默认):中。

  • LOW:低。

  • LOWEST:最低。

失败重试次数

工作流运行失败自动重试的次数。

失败重试间隔

每次失败重试的间隔。单位:分。

延时执行时间

延时执行时间,默认为0,即立即执行,设置了该值后才执行延时操作。单位:分。

超时告警

该开关默认关闭。打开超时告警开关,可设定超时时长,并选择至少一个超时策略。

  • 选择超时告警策略,当任务运行时长超过设置的超时时长后,系统将向指定的告警组发送通知。

  • 选择超时失败策略,当任务运行时长超过设置的超时时长后,该任务实例会立即失败。

数据源实例

选择对应数据源的名称。需要在数据源中心创建数据源,具体操作请参见数据源中心

任务提交节点

仅支持调度资源组节点,表示任务在Workflow的调度资源组节点提交。

SQL类型

支持查询和非查询两种。

  • 查询(默认):支持DML select类型的命令。

  • 非查询:支持DDL全部命令和DML update、delete、insert三种类型的命令。选择该类型时,需要配置日志显示参数。

日志显示

日志中显示查询结果的行数。默认显示10行查询结果。

sql参数

输入参数格式为key1=value1;key2=value2…

SQL语句

输入SQL语句。

自定义参数

任务自定义参数,会替换SQL语句中${变量}的内容。

前置SQL语句

前置SQL在SQL语句之前执行。

后置SQL语句

后置SQL在SQL语句之后执行。

前置任务

设置当前任务的前置(上游)任务。

任务示例

非查询类SQL任务

  1. 创建create_table节点。

    节点名称设置为create_table,数据源类型选择为HIVE数据源实例选择已添加的HIVE数据源,SQL类型选择为非查询SQL语句内容如下。

    create table if not exists hive_table(id bigint, name string)
  2. 创建insert_data节点。

    节点名称设置为insert_data,数据源类型选择为HIVE数据源实例选择已添加的HIVE数据源,SQL类型选择为非查询SQL语句内容如下。

    insert into hive_table values (1,'name1')

    前置任务:选择创建表SQL任务create_table。

  3. 配置节点顺序。

    如下图配置create_table节点、insert_data节点的运行顺序,即先创建表然后插入数据。

    image

查询类SQL任务

以Hive数据源为例,演示如何创建一个查询类的SQL任务。该示例查询了上述示例中创建的hive_table表中的数据。

SQL任务节点设置中,数据源类型选择为HIVE数据源实例选择已添加的HIVE数据源(与上述非查询类SQL任务示例中选择的数据源保持一致),SQL类型选择为查询SQL语句内容如下。

select * from hive_table