DataWorks:スクリプトテンプレートの作成と使用

必要に応じて、スクリプトテンプレートを公開したり、その使用履歴を表示したりできます。

• スニペットの公開：この機能は、ワークスペースレベルのスクリプトテンプレートを公開スクリプトテンプレートに昇格させ、テナント内のすべてのユーザーが利用できるようにします。 デフォルトでは、新しいスクリプトテンプレートはそのワークスペース内でのみ利用可能です。

• スニペットノード：現在のスクリプトテンプレートを使用しているノードを確認できます。 これにより、テンプレートに変更を加える前に影響を評価できます。

まず、スクリプトテンプレートを定義する の説明に従って、get_top_n という名前のスクリプトテンプレートを作成します。構成の詳細は以下のとおりです。

• パラメーター設定

  カテゴリ	パラメーター名	型	説明	パラメーター定義
  入力パラメーター	myinputtable	テーブル	指定された売上詳細データテーブル。	area_id string city_id string order_amt double rank bigint
  	topn	文字列	取得する売上上位ランキングの数。	N/A
  出力パラメーター	myoutput	テーブル	各地域のトップ N 都市ランキングを格納する出力テーブル。	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_ref_snippet_get_top_n という名前の SQL スニペットノードを作成し、ステップ 1 で作成した get_top_n スクリプトテンプレートを参照して、そのパラメーターを設定します。 詳細については、「スクリプトテンプレートの参照」をご参照ください。

コードコンポーネントエディターで、[get_top_n (V1)] スクリプトテンプレートを選択します。 左側のコードエディターの SQL ロジックは、INSERT OVERWRITE TABLE @@{myoutput} を使用して結果を出力テーブルに書き込み、ROW_NUMBER() OVER (PARTITION BY ...) ウィンドウ関数を使用して各地域内の都市を売上順にランク付けし、SUM(order_amt) を使用して総売上を計算します。 右側の [パラメーター設定] パネルで入出力パラメーターを設定します。 パラメーターは次のように設定されます：

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

  company_sales_record

  CREATE TABLE IF NOT EXISTS company_sales_record
  (
      order_id         STRING COMMENT '注文 ID (プライマリキー)',
      report_date      STRING COMMENT '注文日',
      customer_name    STRING COMMENT '顧客名',
      order_level      STRING COMMENT '注文レベル',
      order_number     DOUBLE COMMENT '注文数量',
      order_amt        DOUBLE COMMENT '注文金額',
      back_point       DOUBLE COMMENT '割引ポイント',
      shipping_type    STRING COMMENT '配送方法',
      profit_amt       DOUBLE COMMENT '利益額',
      price            DOUBLE COMMENT '単価',
      shipping_cost    DOUBLE COMMENT '配送料',
      area             STRING COMMENT 'エリア',
      province         STRING COMMENT '省',
      city             STRING COMMENT '市',
      product_type     STRING COMMENT '製品タイプ',
      product_sub_type STRING COMMENT '製品サブタイプ',
      product_name     STRING COMMENT '製品名',
      product_box      STRING COMMENT '製品パッケージ',
      shipping_date    STRING COMMENT '出荷日'
  ) 
  COMMENT '売上詳細情報'
  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 'エリア', 
  city STRING COMMENT '市', 
  sales_amount DOUBLE COMMENT '売上金額', 
  rank BIGINT COMMENT 'ランク'
  )
  COMMENT '企業売上ランキング'
  PARTITIONED BY (pt STRING COMMENT '')
  LIFECYCLE 365;