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