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