管理即時任務

即時任務是指在Dataphin建立的即時整合任務、FLINK_SQL、FLINK_TEMPLATE_SQL和FLINK_DATASTREAM計算任務。在Dataphin的即時任務頁面為您展示了任務執行個體的基本資料及營運管理選項，方便您查看執行個體任務並進行管理。本文為您介紹即時任務支援的營運管理功能。

即時任務頁面入口

在Dataphin首頁的頂部功能表列中，選擇研發 > 任務營運。
在左側導覽列中選擇任務營運 > 即時任務，開啟即時任務頁面。
在頂部功能表列選擇生產或開發環境。

即時任務頁面介紹

即時任務頁面主要由快捷搜尋及篩選區域、即時工作清單和大量操作區組成。您可以在即時任務頁面對提交的即時任務進行相關的營運操作。

區塊	說明
①搜尋及篩選	支援輸入任務對象名稱或ID來搜尋即時任務，適用於知道任務名稱或ID時進行快捷搜尋。我操作的任務：任務負責人為當前登入帳號的即時任務。我的已啟動執行個體任務：任務負責人為當前登入帳號且啟動的即時任務。篩選：單擊篩選，可展開所有篩選項，篩選項包括：細分類型：即時引擎不同，支援選擇的細分類型也不相同，具體以實際介面為準。最近操作人：根據任務的最近操作人進行篩選。負責人：根據任務的負責人進行篩選。若已選中我操作的任務，則此篩選項預設包含當前登入帳號。引擎類型：根據引擎類型進行篩選，可選擇Ververica Flink、Blink、開源Flink和FusionInsight Flink。資源隊列：即時引擎為Alibaba Blink、開源Flink時可根據任務啟動並執行資源隊列進行篩選。叢集：即時引擎為Ververica Flink時可根據任務啟動並執行叢集進行篩選。引擎版本：任務使用的引擎版本。是否啟動正式執行個體：根據正式執行個體是否運行進行篩選，僅適用於Prod和Basic專案。是否啟動測試執行個體：根據測試執行個體是否已運行進行篩選，僅適用於Dev專案。專案：根據任務所在專案進行篩選，可選擇多個當前登入使用者擁有營運-訪問目錄許可權的專案。重設：開啟所有篩選項後，可單擊重設，快速清除已選篩選條件。重新整理：單擊重新整理表徵圖，重新整理當前即時工作清單。
②即時工作清單	即時任務頁面以列表形式為您展示系統已產生的即時任務。即時任務營運列表中展示當前任務對象、最近操作人、負責人、是否啟動正式執行個體、最近提交時間、引擎類型、引擎版本等資訊。任務對象：提交到營運中心的即時任務，包含指令碼名稱和指令碼ID。最近操作人：任務的上一次操作人的帳號名稱。負責人：任務的負責人帳號名稱。是否啟動正式執行個體：即時任務的正式執行個體啟動狀態。專案：任務所屬的專案，展示格式為`專案英文名（專案中文名）`。最近提交時間：即時任務上一次提交到營運中心的時間。引擎類型：當前即時任務所使用的引擎類型。叢集：僅當即時引擎為Ververica Flink時，展示任務生產環境叢集，其他類型引擎此欄位展示為空白。資源隊列：僅當即時引擎為Alibaba Blink、開源Flink時，展示任務運行時使用的資源隊列，其他類型引擎此欄位展示為空白。引擎版本：任務所使用的引擎版本。列表操作欄為您展示即時任務支援的營運管理操作。即時任務支援的單個營運操作，請參見單個操作。
③大量操作	您可通過大量操作地區提供的修改負責人、啟動正式執行個體營運功能，對即時任務進行批量處理，提高營運效率。即時任務支援的批量營運操作，請參見大量操作。

單個操作

操作項	描述
DAG圖	單擊目標即時任務操作列的表徵圖，查看該即時任務的DAG圖。更多資訊，請參見即時任務DAG圖支援的操作。
查看執行個體	單擊目標即時任務操作列的表徵圖，查看該即時任務運行產生的執行個體。說明僅已啟動運行且已產生執行個體的即時任務，支援查看執行個體。
啟動執行個體	單擊目標即時任務操作列的表徵圖啟動執行個體。操作詳情，請參見啟動即時執行個體。說明僅支援啟動未啟動啟動並執行執行個體。
查看任務代碼	單擊目標即時任務操作列的表徵圖，選擇查看任務代碼，查看該即時任務的代碼。
查看任務參數	單擊目標即時任務操作列的表徵圖，選擇查看任務參數，查看即時任務節點定義的參數。
修改負責人	在生產環境下，單擊目標即時任務操作列的表徵圖，選擇修改負責人，在修改負責人對話方塊中選擇新的負責人。說明僅支援選擇專案內且有營運許可權的成員。
修改資源配置	單擊目標即時任務操作列的表徵圖，選擇修改資源配置，修改即時任務啟動並執行資源參數，包括Core、Memory等。說明系統僅支援對Prod和Basic專案中的任務修改資源配置。 Fusioninsight Flink引擎不支援修改資源配置。

大量操作

操作項

描述

啟動正式執行個體

支援同時啟動運行多個即時整合執行個體或即時研發執行個體。

說明

僅適用於Prod和Basic專案，且選中的即時任務均未啟動運行。

啟動即時整合執行個體：

選擇多個未啟動的即時整合任務，或單擊本頁全選後，單擊啟動正式執行個體，選擇啟動即時整合執行個體。
在大量啟動即時整合執行個體對話方塊中，配置啟動資訊。
- 啟動n個執行個體：展示啟動執行個體的個數及執行個體名稱，多個執行個體間使用半形逗號（,）分隔。
- 啟動範圍：選擇增量+全量（僅增全量即時整合任務可用）或僅增量。
- 全量同步：僅當啟動範圍選取增量+全量時，支援配置此模組參數。
  - 重跑方式：可選擇從初始化或續跑。
    - 初始化：啟動所有同步對象的全量同步臨時任務，所有臨時任務執行完成後，啟動即時增量同步處理任務。
    - 續跑：啟動所有未同步完成（不包含已同步完成、已停止、已忽略）的同步對象的全量同步臨時任務，所有臨時任務執行完成後，啟動即時增量同步處理任務。
  - 記憶體（非必填）：不支援輸入小數和負數，最大記憶體不超過8192MB（8GB）。
  - 限流（非必填）：按照資料量大小進行速度限制，不支援輸入小數和負數，預設值為10M/s，若為空白則不限流。
  - 並發（非必填）：用於設定全量任務期望最大的並發數，不支援輸入小數和負數，預設值為10 ，若為空白則並發數為3。
  說明
  僅Prod環境可配置調度資源群組、記憶體、限流和並發。
- 增量同步處理：僅當啟動範圍選取僅增量時，支援配置此模組參數。
  - 啟動方式：僅支援無狀態啟動，即不帶任何初始狀態啟動。
  - 讀取資料時點：設定指定開始時間會讓所有支援startTime的來源表（Log Service、Kafka、MySQL、MongoDB、OceanBase）均從該時刻開始讀取資料。
    說明
    SQL任務中的代碼參數配置將優先於此指定的開始時間。
單擊確定，開始啟動。

啟動即時研發執行個體：

選擇多個未啟動的即時研發任務，或單擊本頁全選後，單擊啟動正式執行個體，選擇啟動即時研發執行個體。
在大量啟動即時研發執行個體對話方塊中，配置啟動資訊。
- 啟動n個執行個體：展示啟動執行個體的個數及執行個體名稱，多個執行個體間使用半形逗號（,）分隔。
- 啟動方式：支援無狀態啟動和從有效狀態啟動。
  - 無狀態啟動：不帶任何初始狀態啟動。
  - 從有效狀態啟動：從已存在的有效狀態啟動。
    說明
    若選中的執行個體中包含無狀態的執行個體，則大量啟動執行個體時僅支援選擇無狀態啟動。
- 讀取資料時點：設定指定開始時間會讓所有支援startTime的來源表（Log Service、Kafka、MySQL、MongoDB、OceanBase）均從該時刻開始讀取資料。
  說明
  SQL作業中的代碼參數配置將優先於此指定的開始時間。
- 業務日期：支援通過配置業務日期對時間變數賦值，時間類型的變數基於業務日期計算，預設為當天。
  說明
  SQL作業中的代碼參數配置將優先於此指定的開始時間。
單擊確定，開始啟動。

修改責任人

支援同時修改多個即時任務的責任人。

選擇多個即時任務，或單擊本頁全選後，單擊修改責任人。
在修改負責人對話方塊中，選擇新的負責人。
單擊確定。

說明

僅支援選擇本專案內有營運許可權的成員。
僅適用於Prod和Basic專案。

即時任務DAG圖支援的操作

滑鼠移至上方至DAG節點上，可以查看該節點的名稱、類型、調度周期、營運負責人及其描述資訊，此外，即時任務在DAG圖中支援的營運操作如下：

操作項	描述
展開父節點	展開DAG圖中main節點不同層級的依賴節點。
展開子節點	展開DAG圖中main節點不同層級的依賴節點。
啟動即時執行個體	即時執行個體的運行需要您單擊手動啟動執行個體，並配置相關啟動資訊。操作詳情，請參見啟動即時執行個體。
查看即時執行個體	進入即時執行個體頁面，查看當前即時任務產生的即時執行個體。
查看節點代碼	查看即時任務節點的代碼。
查看任務參數	查看即時任務節點的任務參數。
查看動作記錄	查看即時任務節點的動作記錄。
編輯開發節點	進入Dev專案下當前任務的編輯頁面，編輯該任務。僅適用於Dev-Prod開發模式。
編輯節點	進入當前任務對應的編輯頁面，編輯任務。僅適用於Basic模式。
查看生產節點	查看Prod專案中當前任務的配置。
查看任務參數	查看任務的參數。
查看拓撲結構	查看即時任務的資源群組節點和元件節點。
修改資源配置	修改即時任務啟動並執行資源參數，包括Core、Memory等。重要系統僅支援對Prod和Basic專案中的任務修改資源配置。 Fusioninsight Flink引擎不支援修改資源配置。