MaxCompute Script节点

背景信息

MaxCompute的SQL引擎支持脚本模式（Script Mode），允许您将多条SQL语句整合为一个脚本整体编译执行，适用于处理复杂查询（例如嵌套子查询或需要分步操作的情况）。通过一次性提交整个脚本，生成统一的执行计划，作业只需排队和执行一次，从而更高效地利用资源。更多使用详情可参见SQL脚本模式。在DataWorks中，您可以使用MaxCompute Script节点来创建和调度基于脚本模式的任务。

适用场景

脚本模式适用于需要被重写的多层嵌套子查询语句，或因复杂性而需拆分为多个语句的脚本。

例如脚本模式下，您可以对一个变量赋常量值，然后将SELECT * FROM 变量语句转化为标量与其它列进行计算。常量值也可以存放在一个单行的表中，命令示例如下。转化语法请参见子查询（SUBQUERY）。

@a := SELECT 10; --对@a赋值常量10，或者赋值存在一个单行表t1中，SELECT col1 FROM t1。
@b := SELECT key,VALUE+(SELECT * FROM @a) FROM t2 WHERE key >10000; --t2表中value值与@a中的值进行计算。
SELECT * FROM @b;

前提条件

• （可选，RAM账号需要）进行任务开发的RAM账号已被添加至对应工作空间中，并具有开发或空间管理员（权限较大，谨慎添加）角色权限，添加成员的操作详情请参见为工作空间添加空间成员。

  说明

  如果您使用的是主账号，则忽略该添加操作。

• 已为DataWorks工作空间绑定MaxCompute计算资源。

• 在MaxCompute中创建任务所需表，并添加示例数据，详情请参见建表语句与测试数据示例。

语法结构

一个MaxCompute Script脚本完整的形式为SET语句>DDL语句>DML语句，每种类型语句都可以有0到多个语句，但不同类型的语句不能混合。多个语句以@开始，表示变量连接。语法如下：

--SET语句
SET odps.sql.type.system.odps2=true;
[SET odps.stage.reducer.num=***;]
[...]
--DDL语句
CREATE TABLE table1 xxx;
[CREATE TABLE table2 xxx;]
[...]
--DML语句
@var1 := SELECT [ALL | DISTINCT] select_expr, select_expr, ...
    FROM table3
    [WHERE where_condition];
@var2 := SELECT [ALL | DISTINCT] select_expr, select_expr, ...
    FROM table4
    [WHERE where_condition];
@var3 := SELECT [ALL | DISTINCT] var1.select_expr, var2.select_expr, ...
    FROM @var1 JOIN @var2 ON ...;
INSERT OVERWRITE|INTO TABLE [PARTITION (partcol1=val1, partcol2=val2 ...)]
    SELECT [ALL | DISTINCT] select_expr, select_expr, ...
    FROM @var3;
[@var4 := SELECT [ALL | DISTINCT] var1.select_expr, var.select_expr, ... FROM @var1
    UNION ALL | UNION
    SELECT [ALL | DISTINCT] var1.select_expr, var.select_expr, ... FROM @var2;
CREATE [EXTERNAL] TABLE [IF NOT EXISTS] table_name
    AS
    SELECT [ALL | DISTINCT] select_expr, select_expr, ...
    FROM var4;]

使用限制

MaxCompute Script节点的使用限制如下：

• 脚本模式支持SET语句、部分DDL语句（结果是屏显类型的语句除外，例如DESC、SHOW）和DML语句。

• 一个脚本，目前最多支持一个屏幕显示结果的语句（例如单独的SELECT语句），否则会报错。不建议您在脚本中执行屏幕显示的SELECT语句。

• 一个脚本，目前最多支持一个CREATE TABLE AS语句，并且必须是最后一句。建议将建表语句和INSERT语句分开写。

• 脚本模式下，如果有一个语句失败，整个脚本的语句都不会执行成功。

• 脚本模式下，只有所有输入的数据都准备完成，才会生成一个作业进行数据处理。

• 脚本模式下，如果一个表被写入后又被读取，会产生报错信息。

  错误示例：

  INSERT OVERWRITE TABLE src2 SELECT * FROM src WHERE key > 0;
  @a := SELECT * FROM src2;
  SELECT * FROM @a;

  正确示例：

  为避免先写后读，可以进行如下修改。

  @a := SELECT * FROM src WHERE key > 0;
  INSERT OVERWRITE TABLE src2 SELECT * FROM @a;
  SELECT * FROM @a;

新建MaxCompute Script节点

新建入口参考：创建MaxCompute Script节点。

开发MaxCompute Script节点

在MaxCompute Script节点编辑页面，您可根据实际业务需要，选择下方Script示例代码进行业务开发。

CREATE TABLE IF NOT EXISTS dest(key string , VALUE bigint) ;
CREATE TABLE IF NOT EXISTS dest2(key string,VALUE bigint ) ;
@a := SELECT * FROM src WHERE VALUE >0;
@b := SELECT * FROM src2 WHERE key IS NOT NULL;
@c := SELECT * FROM src3 WHERE VALUE IS NOT NULL;
@d := SELECT a.key,b.value FROM @a LEFT OUTER JOIN @b ON a.key=b.key AND b.value>0;
@e := SELECT a.key,c.value FROM @a INNER JOIN @c ON a.key=c.key;
@f := SELECT * FROM @d UNION SELECT * FROM @e UNION SELECT * FROM @a;
INSERT OVERWRITE TABLE dest  SELECT * FROM @f;
@g := SELECT e.key,c.value  FROM @e JOIN @c ON e.key=c.key;
INSERT OVERWRITE TABLE dest2 SELECT * FROM @g;

调试MaxCompute Script节点

1. 在节点编辑页右侧的调试配置中配置相关参数。

   参数	配置说明
   计算资源	选择您已绑定的MaxCompute计算资源。
   计算配额	选择您所创建的计算配额（Quota），为计算作业提供所需计算资源（CPU及内存）。 如无可用计算配额，可在下拉列表中单击新建计算配额，在MaxCompute控制台创建配置Quota。
   资源组	选择与计算资源测试连通性成功的调度资源组。详情请参见网络连通方案。

2. 在工具栏的参数对话框中选择已创建的MaxCompute数据源，单击运行MaxCompute Script任务。

后续步骤

• 节点调度：若项目目录下的节点需要周期性调度执行，您需要在节点右侧的调度配置中设置调度策略，配置相关的调度属性。

• 节点发布：若任务需要发布至生产环境执行，请单击界面图标唤起发布流程，通过该流程将任务发布至生产环境。项目目录下的节点只有在发布至生产环境后，才会进行周期性调度。

建表语句与测试数据示例

示例如下：

--创建表
CREATE TABLE IF NOT EXISTS src(key string ,VALUE BIGINT);
INSERT INTO src VALUES ('1',11) ;
INSERT INTO src VALUES ('1',11) ;
CREATE TABLE IF NOT EXISTS  src2(key string ,VALUE BIGINT);
INSERT INTO src2  VALUES ('1',22);
INSERT INTO src2  VALUES ('2',22);
CREATE TABLE IF NOT EXISTS  src3(key string ,VALUE BIGINT);
INSERT INTO src3 VALUES ('1',33);
INSERT INTO src3 VALUES ('3',33);