Microservices Engine:タスク管理

スケジューリングタスクの作成

1. MSE SchedulerX コンソールにログインします。

2. 左側のナビゲーションウィンドウで、[タスク管理] をクリックし、リージョンと [名前空間] を選択します。

3. [タスクの作成] をクリックします。[基本設定] ステップでパラメーターを設定し、[次へ] をクリックします。

   次の表に、基本設定パラメーターを示します。

   設定名	説明
   タスク名	タスクのカスタム名です。
   説明	タスクの説明です。タスクの検索を容易にするために、簡潔な説明を指定します。
   アプリケーション ID	タスクが属するグループです。ドロップダウンリストから値を選択します。
   タスクタイプ	タスクが実装されている言語です。有効な値: Java、XXL-JOB、SpringSchedule、Golang、ScriptTask、Http、および DataWorks。 [スクリプトタスク] を選択した場合は、スクリプト言語 (shell、python、または go) を選択する必要があります。エディターでタスクスクリプトを記述できます。
   クラスの完全なパス	説明 このパラメーターは、[タスクタイプ] パラメーターが [Java] に設定されている場合にのみ使用できます。 JobProcessor の完全なパスです。例: xxx.xxx.xxx.HelloProcessor。
   実行モード	タスク実行のモードです。次のモードがサポートされています: スタンドアロン操作: タスクはランダムなワーカーで実行されます。 ブロードキャスト実行: タスクはすべてのワーカーで同時に実行され、システムはすべてのワーカーがタスクを完了するまで待機します。 ビジュアル MapReduce: 300 未満のサブタスクをサポートし、サブタスクリストを提供する Map モデルです。 Professional Edition では、最大 1,000 個のタスクが許可され、タスクはビジネスキーワードでクエリできます。 MapReduce: 多くのサブタスクを並行して処理するための標準の MapReduce モデルです。サブタスクのサマリー情報のみをクエリできます。1,000,000 未満のサブタスクを持つタスクにはこのモードを使用します。 シャード実行: elastic-job モデルに似ています。シャードは、設定されたシャーディングパラメーターに基づいて、実行のために複数のクライアントに均等に分散されます。このモードは、複数のプログラミング言語をサポートします。 説明 詳細設定のパラメーターは、選択した [実行モード] によって異なります。
   タスクパラメーター	実行時にコンテキストから取得できる任意の文字列です。

   次の表に、詳細設定パラメーターを示します。

   パラメーター	適用可能な実行モード	説明	デフォルト値
   タスク失敗時のリトライ回数	すべてのモード	タスクが失敗した場合の自動リトライ回数です。 説明 タスクがワーカーで実行中にワーカーが再起動されると、タスクは失敗します。タスクをすぐに再実行したい場合は、このパラメーターを指定できます。	0
   タスク失敗時のリトライ間隔	すべてのモード	2 回の連続したリトライの間隔です。単位: 秒。	30
   タスクの同時実行数	すべてのモード	同じタスクを同時に実行するインスタンスの数です。値 1 は、同時実行が許可されていないことを指定します。	1
   クリーンアップ戦略	すべてのモード	タスク実行履歴のクリーンアップポリシーです。	最後の N エントリを保持
   保持数	すべてのモード	保持されるタスク実行レコードの数です。	300
   単一マシンでの同時サブタスク数	ビジュアル MapReduce MapReduce シャード実行	分散モデルで単一のワーカーで同時に実行されるタスクの数です。実行を高速化するには、より大きな値を指定できます。ダウンストリームまたはデータベースが指定した値に耐えられない場合は、より小さな値を指定できます。	5
   サブタスクの失敗リトライ回数	ビジュアル MapReduce MapReduce シャード実行	分散モデルでタスクが失敗した場合の自動リトライ回数です。	0
   サブタスク失敗時のリトライ間隔	ビジュアル MapReduce MapReduce シャード実行	分散モデルでタスクが失敗した場合の 2 回の連続したリトライの間隔です。単位: 秒。	0
   サブタスクのフェールオーバー戦略	ビジュアル MapReduce MapReduce シャード実行	ワーカーがタスクの実行に失敗して停止した後、タスクを新しいワーカーに分散するかどうかを指定します。スイッチをオンにすると、フェールオーバーがトリガーされたときにシステムがタスクを複数回実行する可能性があります。タスクのべき等性を実装する必要があります。 説明 このパラメーターは、エージェント V1.8.13 以降に適用されます。
   マスターノードが実行に参加	ビジュアル MapReduce MapReduce シャード実行	マスターノードがタスクの実行に参加するかどうかを指定します。タスクを実行するには、少なくとも 2 つのワーカーが使用可能である必要があります。非常に多数のタスクが存在する場合は、スイッチをオフにすることをお勧めします。 説明 このパラメーターは、エージェント V1.8.13 以降に適用されます。
   サブタスク分散メソッド	ビジュアル MapReduce MapReduce シャード実行	プッシュモデル: タスクはワーカーに均等に分散されます。 プルモデル: すべてのワーカーがタスクをプルします。このモデルには木製のバケツ理論は適用されません。プルプロセス中、すべてのタスクはマスターノードにキャッシュされます。これにより、メモリに負荷がかかります。一度に 10,000 を超えるタスクを分散しないことをお勧めします。	プッシュモデル
   分散ポリシー	ビジュアル MapReduce MapReduce	タスク分散ポリシーです。デフォルト値: ポーリングスキーム。 ポーリングスキーム: システムは、各ワーカーに同数のタスクを均等に分散します。このポリシーは、各ワーカーがタスクの処理にほぼ同じ時間を必要とするシナリオに適しています。 WorkerLoad 最適戦略: マスターノードはワーカーの負荷を自動的に検出します。このポリシーは、各ワーカーがタスクの処理に要する時間に大きな差があるシナリオに適しています。 説明 このパラメーターは、エージェント V1.10.14 以降に適用されます。
   分散レート	ビジュアル MapReduce MapReduce	タスク分散レートです。毎秒または毎分に分散するタスクの数を指定できます。
   一度にプルされるサブタスクの数	ビジュアル MapReduce MapReduce シャード実行	スレーブノードが一度にマスターノードからプルするタスクの数です。このパラメーターは、サブタスク分散メソッドパラメーターがプルモデルに設定されている場合にのみ表示されます。	5
   サブタスクキュー容量	ビジュアル MapReduce MapReduce シャード実行	スレーブノード上のタスクをキャッシュするキューのサイズです。このパラメーターは、サブタスク分散メソッドパラメーターがプルモデルに設定されている場合にのみ表示されます。	10
   サブタスクのグローバル同時実行数	ビジュアル MapReduce MapReduce シャード実行	プルモデルのすべてのワーカー上の同時タスクの総数です。このパラメーターは、同時タスクの数を制限するのに役立ちます。このパラメーターは、サブタスク分散メソッドパラメーターがプルモデルに設定されている場合にのみ表示されます。	1000

4. [タイミング設定] ステップで、スケジューリングと詳細設定を行い、[次のステップ] をクリックします。

   

   次の表に、タイミングパラメーターを示します。

   設定項目	説明
   時間タイプ	なし: タスクは自動的に実行されるようにスケジュールされません。通常、ワークフローによってトリガーされます。 cron: cron 式です。 api: API トリガーです。 fixed_rate: 固定間隔です。 second_delay: 秒単位の固定遅延です。 onetime: ワンタイムタスクです。 unix cron: UNIX スタイルの cron 式です。
   Cron 式 (cron 時間タイプのみ)	cron 構文に準拠した cron 式を入力します。ツールを使用して式を生成および検証することもできます。
   固定頻度 (fixed_rate 時間タイプのみ)	スケジューリング間隔を秒単位で入力します。値は 60 より大きい必要があります。たとえば、200 と入力すると、タスクは 200 秒ごとに実行されます。
   固定遅延 (second_delay 時間タイプにのみ適用)	1 から 60 秒の固定遅延を入力します。たとえば、値 5 は 5 秒の遅延後にタスクをトリガーします。
   スケジューリング時間 (onetime 時間タイプのみ)	タスクの実行時間を指定します。例: 2023-7-13 00:00:00。
   UNIX Cron 式 (UNIX Cron 時間タイプのみ)	UNIX 形式で cron 式を入力します。

   次の表に、詳細設定パラメーターを示します。

   設定項目	説明
   時間オフセット	データタイムスタンプとスケジュール時間の間のオフセットです。スケジューリング中にコンテキストからこの値を取得できます。
   タイムゾーン	国またはリージョンのタイムゾーンを選択します。標準の GMT タイムゾーンを選択することもできます。

5. [通知設定] ステップで、アラート設定と連絡先を設定し、[完了] をクリックします。

   

   [通知チャネルと連絡担当者] パラメーターを [アプリケーショングループの連絡先] または [ユーザー定義] に設定できます。

   • アプリケーショングループの連絡先

     アプリケーショングループ内のすべての連絡先が通知を受信します。

   • ユーザー定義

     カスタム通知の場合、[連絡先グループ] または [連絡先] を選択できます。

     • 連絡先グループ

       連絡先グループ内のすべての連絡先が通知を受信します。連絡先グループの作成方法の詳細については、「通知連絡先」をご参照ください。

     • 連絡先

       1. 通知を受信する 1 つ以上の連絡先を追加します。[連絡先の追加] をクリックし、次に [連絡先の作成に移動] をクリックします。

       

       2. 表示されたページで [新しい連絡先] をクリックし、連絡先情報を入力します。

       

       

6. [タスク管理] ページに戻り、作成したタスクがリストに表示され、そのパラメーターが設定と一致することを確認できます。

   説明

   デフォルトでは、スケジュールされたタスクは作成後に有効になります。必要に応じてタスクを無効または有効にすることもできます。詳細については、「スケジューリングタスクの有効化と無効化」をご参照ください。

スケジューリングタスクの編集

1. [タスク管理] ページのターゲットタスクの [操作] 列で [編集] をクリックします。

   

2. [編集] パネルで、基本設定、スケジューリング設定、およびアラート設定を行うことができます。

   説明

   アプリケーション ID またはタスクタイプは変更できません。他のパラメーターは、タスクの作成時と同じ方法で設定されます。

スケジューリングタスクの実行

[ジョブ管理] ページで、[アクション] 列の [一度実行] をクリックして、スケジュールされたタスクを一度実行できます。

スケジューリングタスクの有効化と無効化

スケジューリングタスクのコピー

[タスク管理] ページで、ターゲットタスクの [アクション] 列で [その他] > [コピー] をクリックします。その後、コピーしたタスク設定を編集して、新しいスケジューリングタスクを作成できます。

スケジューリングタスクの再実行

ビジネスが変更された場合、過去の期間のタスクを再実行する必要がある場合があります。たとえば、データベースにフィールドを追加した後、または前月のデータにエラーが見つかった後に、データを再処理する必要がある場合があります。

以前のタスク実行のデータが正しくないか欠落している場合は、実行パラメーターをリセットしてタスクを再実行し、正しいデータを取得できます。

1. MSE SchedulerX コンソールにログインします。

2. [タスク管理] ページのターゲットタスクの [アクション] 列で、[その他] > [タスクのバックフィル] をクリックします。

3. [タスクのバックフィル] パネルで、[開始日と終了日] および [データ時刻] パラメーターを指定し、[OK] をクリックします。

   • 開始日と終了日: 再実行の日付範囲を指定します。

   • データ時刻: 選択した日付範囲内のバックフィルの時刻を指定します。

   

   設定例:

   • 現在の時刻は 2019 年 1 月 1 日 10:00:00 です。

   • 再実行の日付範囲は 2018 年 10 月 1 日から 2018 年 10 月 7 日までです。デフォルトの開始時刻は 2018 年 10 月 1 日 00:00:00 で、デフォルトの終了時刻は 2018 年 10 月 7 日 23:59:59 です。

   • 再実行のデータタイムスタンプは 11:11:11 です。

   タスクは 7 回再実行され、7 つのインスタンスが生成されます。

   S/N	スケジューリング時間	データタイムスタンプ
   1	2019.1.1 10:00:00	2018.10.1 11:11:11
   2	2019.1.1 10:00:00	2018.10.2 11:11:11
   3	2019.1.1 10:00:00	2018.10.3 11:11:11
   4	2019.1.1 10:00:00	2018.10.4 11:11:11
   5	2019.1.1 10:00:00	2018.10.5 11:11:11
   6	2019.1.1 10:00:00	2018.10.6 11:11:11
   7	2019.1.1 10:00:00	2018.10.7 11:11:11

タスクの実行記録と操作記録の表示

• 実行記録を表示するには: [タスク管理] ページのターゲットタスクの [アクション] 列で、[その他] > [履歴] をクリックします。

• 操作記録を表示するには: [タスク管理] ページで、目的のタスクの [アクション] 列で [その他] > [操作記録] をクリックします。

スケジューリングタスクの削除

1. [ジョブ管理] ページのターゲットタスクの [アクション] 列で、[その他] > [削除] をクリックします。

   

2. 確認ダイアログボックスで [確認] をクリックします。

タスクのインポートまたはエクスポート

1. [タスク管理] ページで、Professional Edition アプリケーションを選択します。

   

2. [タスクのインポート] または [タスクのエクスポート] をクリックします。