DataWorks:スクリプトテンプレートを開発する

ビジネス要件に基づいて、スクリプトテンプレートを共有したり、スクリプトテンプレートの参照レコードを表示したりできます。

• スクリプトテンプレートを共有する: スクリプトテンプレートがデプロイされると、スクリプトテンプレートはワークスペースレベルのスクリプトテンプレートになります。 現在のワークスペースのメンバーのみがスクリプトテンプレートを使用できます。 開発した汎用スクリプトテンプレートの構成タブにある上部のツールバーの [Snippet の公開] アイコンをクリックすると、現在のテナント内でスクリプトテンプレートを公開できます。 これにより、現在のテナント内のすべてのユーザーがスクリプトテンプレートを使用できるようになります。 [Snippet の公開] アイコンは、前の図の 1 でマークされています。

• スクリプトテンプレートの参照レコードを表示する: [Snippet ノード] タブで、現在のスクリプトテンプレートを参照するノードを表示できます。 これにより、行おうとしているスクリプトテンプレートの変更の影響を推定できます。 [Snippet ノード] タブは、前の図の 2 でマークされています。

get_top_n という名前のスクリプト テンプレートを作成します。詳細については、このトピックの「スクリプト テンプレートを定義する」セクションをご参照ください。次の説明は、スクリプト テンプレートの構成を示しています。

• パラメーター設定

  カテゴリ	パラメーター	タイプ	説明	パラメーター定義
  入力パラメーター	myinputtable	table	売上データ テーブルを指定します。	area_id string city_id string order_amt double rank bigint
  	topn	string	上位都市の数を指定します。	該当なし
  出力パラメーター	myoutput	table	各地域の上位都市のランキングを表示する出力テーブルを指定します。	area_id string city_id string order_amt double rank bigint

• SQL コード プロセスの定義

  INSERT OVERWRITE TABLE  @@{myoutput}  PARTITION (pt='${bizdate}')
   SELECT r3.area_id,
   r3.city_id,
   r3.order_amt,
   r3.rank
  from (
  SELECT
     area_id,
     city_id,
     rank,
     order_amt_1505468133993_sum as order_amt ,
     order_number_1505468133991_sum,
     profit_amt_1505468134000_sum
  FROM
     (SELECT
     area_id,
     city_id,
     ROW_NUMBER() OVER (PARTITION BY r1.area_id ORDER BY r1.order_amt_1505468133993_sum DESC) AS rank,
     order_amt_1505468133993_sum,
     order_number_1505468133991_sum,
     profit_amt_1505468134000_sum
  FROM
     (SELECT
     area AS area_id,
     city AS city_id,
     SUM(order_amt) AS order_amt_1505468133993_sum,
     SUM(order_number) AS order_number_1505468133991_sum,
     SUM(profit_amt) AS profit_amt_1505468134000_sum
  FROM
    @@{myinputtable}
  WHERE
     SUBSTR(pt, 1, 8) IN ( '${bizdate}' )
  GROUP BY
     area,
     city )
     r1 ) r2
  WHERE
     r2.rank >= 1 AND r2.rank <= @@{topn}
  ORDER BY
     area_id,
     rank limit 10000) r3;

xc_Referenced script template_get_top_n という名前の SQL スニペットノードを作成し、手順 1 で作成した get_top_n スクリプト テンプレートを参照してから、パラメーターを構成します。次の図は、パラメーター構成手順を示しています。 SQL スニペットノードを作成してスクリプト テンプレートを参照する方法の詳細については、このトピックの「スクリプト テンプレートを参照する」セクションをご参照ください。 パラメーター設定：

• 入力パラメーター myinputtable：company_sales_record という名前の入力テーブルをデータソースとして指定します。入力テーブルのスキーマ：

  company_sales_record

  CREATE TABLE IF NOT EXISTS company_sales_record
  (
      order_id         STRING COMMENT 'Order ID (PK)',
      report_date      STRING COMMENT 'Order generation date',
      customer_name    STRING COMMENT 'Customer name',
      order_level      STRING COMMENT 'Order level',
      order_number     DOUBLE COMMENT 'Number of orders',
      order_amt        DOUBLE COMMENT 'Order amount',
      back_point       DOUBLE COMMENT 'Discount',
      shipping_type    STRING COMMENT 'Transportation method',
      profit_amt       DOUBLE COMMENT 'Amount of profit',
      price            DOUBLE COMMENT 'Unit price',
      shipping_cost    DOUBLE COMMENT 'Cost of transportation',
      area             STRING COMMENT 'Region',
      province         STRING COMMENT 'Province',
      city             STRING COMMENT 'City',
      product_type     STRING COMMENT 'Product type',
      product_sub_type STRING COMMENT 'Product subtype',
      product_name     STRING COMMENT 'Product name',
      product_box      STRING COMMENT 'Product packaging',
      shipping_date    STRING COMMENT 'Date of transportation'
  ) 
  COMMENT 'Detailed sales data'
  PARTITIONED BY
  (
      pt               STRING
  )
  LIFECYCLE 365;

• 入力パラメーター topn：各地域の都市の売上高合計のランキングに基づいて、昇順で上位都市の数を指定します。この例では、このパラメーターは 10 に設定されています。

• 出力パラメーター myoutput：company_sales_top_n という名前の出力テーブルを指定します。出力テーブルには、データ処理結果が含まれています。出力テーブルのスキーマ：

  company_sales_top_n

  CREATE TABLE IF NOT EXISTS company_sales_top_n
  ( 
  area STRING COMMENT 'Region', 
  city STRING COMMENT 'City', 
  sales_amount DOUBLE COMMENT 'Sales amount', 
  rank BIGINT COMMENT 'Ranking'
  )
  COMMENT 'Company sales rankings'
  PARTITIONED BY (pt STRING COMMENT '')
  LIFECYCLE 365;