SQL任务类型,用于连接数据库并执行相应SQL。本文为您介绍创建SQL类型任务时涉及的参数,并提供了SQL任务的示例。
参数说明
参数 | 说明 |
节点名称 | 任务的名称。一个工作流定义中的节点名称是唯一的。 |
运行标志 |
|
描述 | 当前节点的功能描述。 |
任务优先级 | 流程运行的优先级。支持以下级别:
|
失败重试次数 | 工作流运行失败自动重试的次数。 |
失败重试间隔 | 每次失败重试的间隔。单位:分。 |
延时执行时间 | 延时执行时间,默认为0,即立即执行,设置了该值后才执行延时操作。单位:分。 |
超时告警 | 该开关默认关闭。打开超时告警开关,可设定超时时长,并选择至少一个超时策略。
|
数据源实例 | 选择对应数据源的名称。需要在数据源中心创建数据源,具体操作请参见数据源中心。 |
任务提交节点 | 仅支持调度资源组节点,表示任务在Workflow的调度资源组节点提交。 |
SQL类型 | 支持查询和非查询两种。
|
日志显示 | 日志中显示查询结果的行数。默认显示10行查询结果。 |
sql参数 | 输入参数格式为 |
SQL语句 | 输入SQL语句。 |
自定义参数 | 任务自定义参数,会替换SQL语句中 |
前置SQL语句 | 前置SQL在SQL语句之前执行。 |
后置SQL语句 | 后置SQL在SQL语句之后执行。 |
前置任务 | 设置当前任务的前置(上游)任务。 |
任务示例
非查询类SQL任务
创建create_table节点。
节点名称设置为create_table,数据源类型选择为HIVE,数据源实例选择已添加的HIVE数据源,SQL类型选择为非查询,SQL语句内容如下。
create table if not exists hive_table(id bigint, name string)
创建insert_data节点。
节点名称设置为insert_data,数据源类型选择为HIVE,数据源实例选择已添加的HIVE数据源,SQL类型选择为非查询,SQL语句内容如下。
insert into hive_table values (1,'name1')
前置任务:选择创建表SQL任务create_table。
配置节点顺序。
如下图配置create_table节点、insert_data节点的运行顺序,即先创建表然后插入数据。
查询类SQL任务
以Hive数据源为例,演示如何创建一个查询类的SQL任务。该示例查询了上述示例中创建的hive_table表中的数据。
SQL任务节点设置中,数据源类型选择为HIVE,数据源实例选择已添加的HIVE数据源(与上述非查询类SQL任务示例中选择的数据源保持一致),SQL类型选择为查询,SQL语句内容如下。
select * from hive_table