DataWorks：開發SQL組件任務

您可根據業務需要分享組件或查看組件的引用記錄。

• 分享組件（序號1）：組件發布後，預設為專案組件，即僅支援當前DataWorks工作空間的使用者使用該組件。組件開發人員可通過分享組件，將具有全域通用性的組件發布到整個租戶內，分享組件並發布後，租戶內所有使用者均可使用該組件。

• 查看組件的引用記錄（序號2）：可查看哪些節點引用了當前組件，用於進行組件變更時提前預估影響。

您需先參考定義SQL組件建立get_top_n組件，組件配置詳情如下。

• 組件參數配置

  參數分類	參數名稱	參數類型	參數描述	參數定義
  輸入參數	myinputtable	table	指定的銷售詳細資料表。	area_id string city_id string order_amt double rank bigint
  	topn	string	取銷售排行的前N名。	不涉及
  輸出參數	myoutput	table	目標輸出表，用於擷取各個地區下指定前N名的城市排行。	area_id string city_id string order_amt double rank bigint

• 組件過程體定義

  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;

您需參考引用SQL組件建立xc_引用組件_get_top_nSQL元件節點，引用步驟一建立的get_top_n組件，並配置相應的參數值，步驟如下圖。參數值說明如下：

• 輸入參數myinputtable：為該參數指定一個輸入表company_sales_record，作為資料輸入源。輸入表的結構如下：

  company_sales_record

  CREATE TABLE IF NOT EXISTS company_sales_record
  (
      order_id         STRING COMMENT '訂單編號（PK）',
      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;