リアルタイムタスクページへの移動
Dataphin ホームページの上部のメニューバーで、[Developer] > [Task O&M] を選択します。
左側のナビゲーションウィンドウで、[Task O&M] > [Stream Task] を選択して [Stream Task] ページを開きます。
上部のメニューバーで、本番または開発環境を選択します。
リアルタイムタスクページの概要
リアルタイムタスクページは、クイック検索およびフィルターエリア、リアルタイムタスクリスト、および バッチ操作 エリアで構成されています。このページでは、送信されたリアルタイムタスクに対して O&M を実行できます。
セクション | 説明 |
① 検索とフィルター | タスクオブジェクト名または ID でリアルタイムタスクを検索します。これは、名前または ID がわかっている場合のクイック検索に役立ちます。 マイタスク: 現在のログインアカウントがオーナーであるリアルタイムタスク。 開始済みインスタンスタスク: 開始済みで、現在のログインアカウントがオーナーであるリアルタイムタスク。 フィルター: [フィルター] をクリックして、すべてのフィルターオプションを展開します。フィルターオプションには次のものが含まれます: サブタイプ: 利用可能なサブタイプは、リアルタイム DPI エンジンによって異なります。詳細については、UI をご参照ください。 最終オペレーター: タスクの最終オペレーターでフィルターします。 オーナー: タスクのオーナーでフィルターします。「私が操作するタスク」が選択されている場合、このフィルターオプションにはデフォルトで現在のログインアカウントが含まれます。 エンジンタイプ: DPI エンジンタイプでフィルターします。Ververica Flink、Blink、Open Source Flink、または FusionInsight Flink を選択できます。 リソースキュー: タスクが実行されるリソースキューでフィルターします。このオプションは、リアルタイム DPI エンジンが Alibaba Blink またはオープンソース Flink の場合に利用できます。 クラスター: タスクが実行されるクラスターでフィルターします。このオプションは、リアルタイム DPI エンジンが Ververica Flink の場合に利用できます。 エンジンバージョン: タスクが使用するデータベースエンジンバージョン。 本番インスタンス開始済み: 本番インスタンスが実行中かどうかでフィルターします。このオプションは、Prod および Basic プロジェクトでのみ利用できます。 テストインスタンス開始済み: テストインスタンスが実行中かどうかでフィルターします。このオプションは、Dev プロジェクトでのみ利用できます。 プロジェクト: タスクが属するプロジェクトでフィルターします。現在のログインユーザーが O&M - フォルダーへのアクセス 権限を持つ複数のプロジェクトを選択できます。
リセット: すべてのフィルターオプションを展開した後、[リセット] をクリックして、選択したフィルター条件をクリアします。 リフレッシュ: [リフレッシュ] アイコンをクリックして、リアルタイムタスクリストをリフレッシュします。
|
② リアルタイムタスクリスト | リアルタイムタスクページには、システムによって生成されたリアルタイムタスクが一覧表示されます。リストには、タスクオブジェクト、最終オペレーター、オーナー、本番インスタンスのステータス、最終送信時刻、DPI エンジンタイプ、データベースエンジンバージョンなどの情報が表示されます。 タスクオブジェクト: オペレーションセンターに送信されたリアルタイムタスク。スクリプト名とスクリプト ID が含まれます。 最終オペレーター: タスクを最後に操作した人のアカウント名。 オーナー: タスクオーナーのアカウント名。 本番インスタンス開始済み: リアルタイムタスクの本番インスタンスのステータス。 プロジェクト: タスクが属するプロジェクト。フォーマットは Project English Name (Project Chinese Name) です。 最終送信時刻: リアルタイムタスクが最後にオペレーションセンターに送信された時刻。 エンジンタイプ: 現在のリアルタイムタスクが使用する DPI エンジンタイプ。 クラスター: タスクの本番環境クラスター。このフィールドは、リアルタイム DPI エンジンが Ververica Flink の場合にのみ表示されます。他の DPI エンジンタイプの場合、このフィールドは空です。 リソースキュー: タスクが実行時に使用するリソースキュー。このフィールドは、リアルタイム DPI エンジンが Alibaba Blink または オープンソース Flink の場合にのみ表示されます。他の DPI エンジンタイプの場合、このフィールドは空です。 エンジンバージョン: タスクが使用するデータベースエンジンバージョン。
[アクション] 列には、リアルタイムタスクの O&M 操作が一覧表示されます。個々の操作の詳細については、「個別の操作」をご参照ください。 |
③ バッチ操作 | バッチ操作エリアでは、一度に複数のリアルタイムタスクのオーナーを変更したり、本番インスタンスを開始したりできます。これにより、O&M の効率が向上します。 リアルタイムタスクのバッチ操作の詳細については、「バッチ操作」をご参照ください。 |
リアルタイムタスクの管理
個別の操作
操作 | 説明 |
DAG | 対象のリアルタイムタスクの [アクション] 列で、 アイコンをクリックしてタスクの DAG を表示します。詳細については、「リアルタイムタスクの DAG でサポートされる操作」をご参照ください。 |
インスタンスの表示 | 対象のリアルタイムタスクの [アクション] 列で、 アイコンをクリックしてタスクによって生成されたインスタンスを表示します。
説明 インスタンスを表示できるのは、開始済みでインスタンスが生成されているリアルタイムタスクのみです。 |
インスタンスの開始 | 対象のリアルタイムタスクの [アクション] 列で、 アイコンをクリックしてインスタンスを開始します。詳細については、「リアルタイムインスタンスの開始」をご参照ください。
説明 実行中でないインスタンスのみを開始できます。 |
タスクコードの表示 | 対象のリアルタイムタスクの [アクション] 列で、 アイコンをクリックし、[タスクコードの表示] を選択してタスクのコードを表示します。 |
タスクパラメーターの表示 | 対象のリアルタイムタスクの [アクション] 列で、 アイコンをクリックし、[タスクパラメーターの表示] を選択してタスクノードに定義されているパラメーターを表示します。 |
オーナーの変更 | 本番環境では、対象のリアルタイムタスクの [アクション] 列で アイコンをクリックし、[オーナーの変更] を選択し、[オーナーの変更] ダイアログボックスで新しいオーナーを選択します。
説明 プロジェクトで O&M 権限を持つメンバーのみを選択できます。 |
リソース構成の変更 | 対象のリアルタイムタスクの [アクション] 列で、 アイコンをクリックし、[リソース構成の変更] を選択します。Core や Memory などのタスクのリソースパラメーターを変更します。
説明 リソース構成を変更できるのは、Prod および Basic プロジェクトのタスクのみです。 FusionInsight Flink DPI エンジンは、リソース構成の変更をサポートしていません。 |
バッチ操作
操作 | 説明 |
本番インスタンスの開始 | 複数の リアルタイム統合インスタンスまたは リアルタイムコンピューティングインスタンスを同時に開始します。
説明 この操作は Prod および Basic プロジェクトにのみ適用され、選択したリアルタイムタスクが実行中でない場合にのみ適用されます。 リアルタイム統合インスタンスの開始: 実行中でない複数のリアルタイム統合タスクを選択するか、現在のページのすべてのタスクを選択します。次に、[本番インスタンスの開始] をクリックし、[リアルタイム統合インスタンスの開始] を選択します。 [リアルタイム統合インスタンスのバッチ開始] ダイアログボックスで、パラメーターを構成します。 n 個のインスタンスを開始: 開始するインスタンスの数とその名前。複数のインスタンス名はカンマ (,) で区切ります。 開始範囲: [増分 + フル] (フルおよび増分のリアルタイム統合タスクでのみ利用可能) または [増分のみ] を選択します。 フル同期: このモジュールは、開始範囲が 増分 + フル に設定されている場合にのみ構成可能です。 再実行モード: [初期化] または [続行] を選択します。 メモリ (オプション): 小数および負の数はサポートされていません。最大メモリは 8192 MB (8 GB) です。 レート制限 (オプション): データ量に基づいて速度を制限します。小数および負の数はサポートされていません。デフォルト値は 10 MB/s です。これを空のままにすると、速度は制限されません。 同時実行数 (オプション): 同時実行されるフルタスクの最大数。小数および負の数はサポートされていません。デフォルト値は 10 です。これを空のままにすると、同時実行数は 3 になります。
説明 スケジュールリソースグループ、メモリ、レート制限、および同時実行数を構成できるのは、Prod 環境のみです。 増分同期: このモジュールは、開始範囲が 増分のみ に設定されている場合にのみ構成可能です。
[OK] をクリックしてインスタンスを開始します。
リアルタイムコンピューティングインスタンスの開始: 実行中でない複数のリアルタイムコンピューティングタスクを選択するか、[現在のページのすべてのタスク] を選択します。次に、[本番インスタンスの開始] をクリックし、[リアルタイムコンピューティングインスタンスの開始] を選択します。 [リアルタイムコンピューティングインスタンスのバッチ開始] ダイアログボックスで、パラメーターを構成します。 n 個のインスタンスを開始: 開始するインスタンスの数とその名前。複数のインスタンス名はカンマ (,) で区切ります。 開始モード: ステートレス開始と有効な状態からの開始をサポートします。 データ読み取りポイント: 開始時刻を指定します。startTime をサポートするすべてのソーステーブル (Log Service、Kafka、MySQL、MongoDB、OceanBase など) は、この時刻からデータの読み取りを開始します。
説明 SQL ジョブのパラメーター設定が、この開始時刻よりも優先されます。 データタイムスタンプ: 時間変数に値を割り当てます。時間ベースの変数は、データタイムスタンプに基づいて計算されます。デフォルト値は現在の日付です。
説明 SQL ジョブのパラメーター設定が、この開始時刻よりも優先されます。
[OK] をクリックしてインスタンスを開始します。
|
オーナーの変更 | 複数のリアルタイムタスクのオーナーを同時に変更します。 複数のリアルタイムタスクを選択するか、[現在のページのすべてのタスク] を選択します。次に、[オーナーの変更] をクリックします。 [オーナーの変更] ダイアログボックスで、新しいオーナーを選択します。 [OK] をクリックします。
|
リアルタイムタスクの DAG でサポートされる操作
DAG 内のノードにカーソルを合わせると、その名前、タイプ、スケジュールエポック、O&M オーナー、および説明が表示されます。DAG 内のリアルタイムタスクの O&M 操作は次のとおりです:
操作 | 説明 |
親ノードの展開 | DAG 内の異なるレベルでメインノードの上流ノードを展開します。 |
子ノードの展開 |
リアルタイムインスタンスの開始 | リアルタイムインスタンスを実行するには、 アイコンをクリックしてインスタンスを手動で開始し、そのパラメーターを構成します。詳細については、「リアルタイムインスタンスの開始」をご参照ください。 |
リアルタイムインスタンスの表示 | リアルタイムインスタンスページに移動して、現在のリアルタイムタスクによって生成されたインスタンスを表示します。 |
ノードコードの表示 | リアルタイムタスクノードのコードを表示します。 |
タスクパラメーターの表示 | リアルタイムタスクノードのパラメーターを表示します。 |
操作ログの表示 | リアルタイムタスクノードの操作ログを表示します。 |
開発ノードの編集 | Dev プロジェクトの現在のタスクの編集ページに移動してタスクを編集します。この操作は、Dev-Prod 開発モードでのみ利用できます。 |
ノードの編集 | 現在のタスクの編集ページに移動して編集します。この操作は、Basic モードでのみ利用できます。 |
本番ノードの表示 | Prod プロジェクトの現在のタスクの構成を表示します。 |
タスクパラメーターの表示 | タスクのパラメーターを表示します。 |
トポロジーの表示 | リアルタイムタスクのリソースグループノードとコンポーネントノードを表示します。 |
リソース構成の変更 | Core や Memory などのタスクのリソースパラメーターを変更します。
重要 リソース構成を変更できるのは、Prod および Basic プロジェクトのタスクのみです。 FusionInsight Flink DPI エンジンは、リソース構成の変更をサポートしていません。 |