(57)【要約】  ＡＰＩインタフェースの呼び出しをパラメータ化するために、マルチタスクスケジューリング方法、アプリケーションサーバ及びコンピュータの読み取り可能な記憶媒体を提供する。マルチタスクスケジューリング方法、システム、アプリケーションサーバ及びコンピュータの読み取り可能な記憶媒体であって、前記方法は、データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立するステップと、ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つそれを予め設定されたワークフロースケジューリングエンジンに発行するステップと、ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、前記同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を含む。本発明はＡＰＩインタフェースの呼び出しをパラメータ化し、データ同期の時に同期パラメータを伝達するだけで同期タスクを完了することができる。
2019523462.tif 000002
【特許請求の範囲】
【請求項１】
アプリケーションサーバであって、プロセッサ上で動作可能なマルチタスクスケジューリングシステムが記憶されている記憶装置と、プロセッサと、を含み、前記マルチタスクスケジューリングシステムが前記プロセッサによって実行される時、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立するステップと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するステップと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を実現する
ことを特徴とするアプリケーションサーバ。
【請求項２】
前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む
ことを特徴とする請求項１に記載のアプリケーションサーバ。
【請求項３】
前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプトと、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプトと、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトと、を含む
ことを特徴とする請求項２に記載のアプリケーションサーバ。
【請求項４】
前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む
ことを特徴とする請求項２又は３に記載のアプリケーションサーバ。
【請求項５】
前記データ同期タスクの実行は、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、を含む
ことを特徴とする請求項４に記載のアプリケーションサーバ。
【請求項６】
アプリケーションサーバに適用されるマルチタスクスケジューリング方法において、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立し、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行し、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達し、及び
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行する
ことを特徴とするマルチタスクスケジューリング方法。
【請求項７】
前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む
ことを特徴とする請求項６に記載のマルチタスクスケジューリング方法。
【請求項８】
前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプトと、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプトと、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトと、を含む
ことを特徴とする請求項７に記載のマルチタスクスケジューリング方法。
【請求項９】
前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む
ことを特徴とする請求項８又は７に記載のマルチタスクスケジューリング方法。
【請求項１０】
前記データ同期タスクの実行は、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、を含む
ことを特徴とする請求項９に記載のマルチタスクスケジューリング方法。
【請求項１１】
コンピュータの読み取り可能な記憶媒体であって、前記コンピュータの読み取り可能な記憶媒体にマルチタスクスケジューリングシステムが記憶されており、前記マルチタスクスケジューリングシステムが少なくとも１つのプロセッサによって実行されることにより、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームとアプリケーションサーバとの第２の接続を確立するステップと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するステップと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を実現する
ことを特徴とするコンピュータの読み取り可能な記憶媒体。
【請求項１２】
前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む
ことを特徴とする請求項１１に記載のコンピュータの読み取り可能な記憶媒体。
【請求項１３】
前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプトと、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプトと、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトと、を含む
ことを特徴とする請求項１２に記載のコンピュータの読み取り可能な記憶媒体。
【請求項１４】
前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む
ことを特徴とする請求項１３又は１２に記載のコンピュータの読み取り可能な記憶媒体。
【請求項１５】
前記データ同期タスクの実行は、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、を含む
ことを特徴とする請求項１４に記載のコンピュータの読み取り可能な記憶媒体。
【請求項１６】
マルチタスクスケジューリングシステムであって、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームとアプリケーションサーバとの第２の接続を確立するための接続モジュールと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するためのタスク発行モジュールと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するためのスケジューリングモジュールと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するための実行モジュールと、
を含むことを特徴とするマルチタスクスケジューリングシステム。
【請求項１７】
前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む
ことを特徴とする請求項１６に記載のマルチタスクスケジューリングシステム。
【請求項１８】
前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプトと、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプトと、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトと、を含む
ことを特徴とする請求項１７に記載のマルチタスクスケジューリングシステム。
【請求項１９】
前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む
ことを特徴とする請求項１７又は１８に記載のマルチタスクスケジューリングシステム。
【請求項２０】
前記データ同期タスクの実行は、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、を含む
ことを特徴とする請求項１９に記載のマルチタスクスケジューリングシステム。
【発明の詳細な説明】
【技術分野】
【０００１】
「関連出願の相互参照」
本願は、２０１７年６月２５日に中国国家知識産権局に出願された、中国特許出願第２０１７１０４９０４５４．５号の「マルチタスクスケジューリング方法、アプリケーションサーバ及びコンピュータの読み取り可能な記憶媒体」と題する中国特許出願の優先権を主張し、当該出願の全体が参照によりここに組み込まれる。
【０００２】
本発明は、コンピュータ情報技術の分野に関し、詳しく言えば、マルチタスクスケジューリング方法、アプリケーションサーバ及びコンピュータの読み取り可能な記憶媒体に関するものである。
【背景技術】
【０００３】
従来のタスクスケジューリングインタフェース（例えば、ｏｏｚｉｅ  ｗｅｂ  ｓｅｒｖｉｃｅ  ＡＰＩ）の設計では、異なる特定のファイル（例えば、実行スクリプト、スケジューリングスクリプトなど）を順次Ｈａｄｏｏｐ分散ファイルシステム（Ｈａｄｏｏｐ  Ｄｉｓｔｒｉｂｕｔｅｄ  Ｆｉｌｅ  Ｓｙｓｔｅｍ、ＨＤＦＳ）に配置する必要があり、このような設計方法は、必ず配置プロセスを経なければならず、不便である。よって、従来技術のタスクスケジューリングインタフェースの設計は合理的でなく、改良する必要がある。
【発明の概要】
【発明が解決しようとする課題】
【０００４】
これに鑑みて、本発明は、マルチタスクスケジューリング方法、システム、アプリケーションサーバ及びコンピュータの読み取り可能な記憶媒体を提供し、ＡＰＩインタフェースの呼び出しをパラメータ化し、データ同期の時に同期パラメータを伝達するだけで同期タスクを完了することができ、配置プロセスが不要となる。
【課題を解決するための手段】
【０００５】
まず、上記の目的を達成するために、本発明はアプリケーションサーバを提供し、前記アプリケーションサーバは、プロセッサ上で動作可能なマルチタスクスケジューリングシステムが記憶されている記憶装置と、プロセッサと、を含み、前記マルチタスクスケジューリングシステムが前記プロセッサによって実行される時、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立するステップと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するステップと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を実現する。
【０００６】
また、上記の目的を達成するために、本発明は、アプリケーションサーバに適用されるマルチタスクスケジューリング方法を提供し、前記方法において、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立し、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行し、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達し、及び
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行する。
【０００７】
好ましくは、前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む。
【０００８】
さらに、上記の目的を達成するために、本発明は、コンピュータの読み取り可能な記憶媒体を提供し、前記コンピュータの読み取り可能な記憶媒体にマルチタスクスケジューリングシステムが記憶されており、前記マルチタスクスケジューリングシステムが少なくとも１つのプロセッサによって実行されることにより、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立するステップと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するステップと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を実現する。
【０００９】
さらに、上記の目的を達成するために、本発明は、マルチタスクスケジューリングシステムを提供し、前記マルチタスクスケジューリングシステムは、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立するための接続モジュールと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するためのタスク発行モジュールと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するためのスケジューリングモジュールと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するための実行モジュールと、を含む。
【発明の効果】
【００１０】
従来技術と比べ、本発明の提供するアプリケーションサーバ、マルチタスクスケジューリング方法、システム及びコンピュータの読み取り可能な記憶媒体は、ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを自動的に生成し、同時に、異なる特定のファイル（例えば、パラメータ設定スクリプト、タスク実行スクリプト及びタスクスケジューリングスクリプト）をタスクスケジューリングインタフェーステンプレートに一度に配置し、データ同期操作を行う場合、前記タスクスケジューリングインタフェーステンプレートを直接呼び出し、且つ各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達し、各データソースの対応するテーブル作成タスクとデータ同期タスクを自動的に実行することにより、マルチデータソースのデータ同期の完全自動化を実現し、配置プロセスが不要となり、ＡＰＩインタフェースの呼び出しをパラメータ化し、データ同期の時に同期パラメータを伝達するだけで同期タスクを完了することができる。
【図面の簡単な説明】
【００１１】
【図１】本発明に係る各実施例の選択可能な適用環境の概略図である。
【図２】図１におけるアプリケーションサーバの選択可能なハードウェアアーキテクチャの概略図である。
【図３】アプリケーションサーバにおけるマルチタスクスケジューリングシステムの一実施例の機能モジュールの概略図である。
【図４】本発明のマルチタスクスケジューリング方法の一実施例の実施フローチャートである。
【発明を実施するための形態】
【００１２】
実施例と図面を組み合わせて本発明の目的の実現、機能的特徴及び利点についてさらに説明する。
【００１３】
本発明の目的、技術的解決手段、及び利点をより明らかにするために、以下では、図面及び実施例を組み合わせて、本発明をさらに詳しく説明する。理解すべきものとして、本明細書に記載された具体的な実施例は、単に本発明を説明するためのものであり、本発明を限定するためのものではない。本発明の実施例に基づき、当業者が創造的な労力を要さずに、想到し得る他の実施例は、いずれも本発明の技術的範囲に属する。
【００１４】
なお、本発明では、「第１」、「第２」などに関するものは、目的を説明するためのみであり、その相対的な重要性を指示、又は暗示し、又は指示された技術的特徴の数を暗黙的に指定するものとして解釈されるべきではない。従って、「第１」、「第２」に限定された特徴は、明示的又は暗黙的に少なくとも１つの前記特徴を含むことができる。また、各実施例間の技術的解決手段は、互いに組み合わせることができるが、当業者が実現できることを基礎としなければならず、技術的解決手段の組み合わせは互いに矛盾し、又は実現できない場合、このような技術的解決手段の組み合わせは存在せず、本発明の特許請求の保護範囲に属しないと認めるべきである。
【００１５】
さらに、説明すべきものとして、本明細書において、用語「含む」、「備える」又はその他の任意の変形は、非排他的な包含をカバーすることを意図し、それにより一連の要素を含む他のプロセス、方法、物品又は装置は、これらの要素を含むだけでなく、明確に挙げられないその他の要素をも含み、又はこのようなプロセス、方法、物品又は装置の固有の要素をも含む。それ以上の制限がない場合、センテンス「１つの．．．を含む」によって限定された要素は、前記要素を含むプロセス、方法、物品又は装置において、また別の同じ要素が存在することを排除しない。
【００１６】
図１は、本発明に係る各実施例の選択可能な適用環境の概略図を示す。
【００１７】
本実施例において、本発明は、アプリケーションサーバ２、ネットワーク３、データプラットフォーム４、及びデータソース５を含むがそれらに限定されない適用環境に適用することができる。ただし、アプリケーションサーバ２は、ラックマウント型のサーバ、ブレードサーバ、タワーサーバ又はキャビネットサーバなどの演算装置であってもよく、アプリケーションサーバ２は、独立したサーバであってもよく、また複数のサーバからなるサーバクラスタであってもよい。ネットワーク３は、イントラネット（Ｉｎｔｒａｎｅｔ）、インターネット（Ｉｎｔｅｒｎｅｔ）、グローバル移動通信システム（Ｇｌｏｂａｌ  Ｓｙｓｔｅｍ  ｏｆ  Ｍｏｂｉｌｅ  ｃｏｍｍｕｎｉｃａｔｉｏｎ、ＧＳＭ(登録商標)）、広帯域符号分割多元接続（Ｗｉｄｅｂａｎｄ  Ｃｏｄｅ  Ｄｉｖｉｓｉｏｎ  Ｍｕｌｔｉｐｌｅ  Ａｃｃｅｓｓ、ＷＣＤＭＡ(登録商標)）、４Ｇネットワーク、５Ｇネットワーク、ブルートゥース(登録商標)（Ｂｌｕｅｔｏｏｔｈ(登録商標)）、Ｗｉ−Ｆｉなどの無線又は有線ネットワークであってもよい。
【００１８】
ただし、アプリケーションサーバ２は、ネットワーク３によってデータプラットフォーム４に通信可能に接続され、データプラットフォーム４は、ネットワーク３によって各データソース５にそれぞれ通信可能に接続される。データプラットフォーム４と各データソース５との間に、第１の接続（又はそれを第１タイプの接続と称する）が確立されることにより、データプラットフォーム４が前記第１の接続によって各データソース５とデータ伝送及び交換を行うことができるようになる。データプラットフォーム４とアプリケーションサーバ２との間に、第２の接続（又はそれを第２タイプの接続と称する）が確立されることにより、データプラットフォーム４が前記第２の接続によってアプリケーションサーバ２とデータ伝送及び交換を行うことができるようになる。
【００１９】
図２は、図１におけるアプリケーションサーバの選択可能なハードウェアアーキテクチャの概略図を示す。本実施例において、アプリケーションサーバ２は、システムバスを介して互いに通信可能に接続された記憶装置２１、プロセッサ２２、ネットワークインタフェース２３を含むが、それらに限定されない。なお、図２は構成要素２１−２３を有するアプリケーションサーバ２のみを示すが、理解すべきものとして、示した全ての構成要素を実施することを要求せず、代替可能な、より多く又はより少ない構成要素を実施することができる。
【００２０】
ただし、記憶装置２１は、少なくとも１種の読み取り可能な記憶媒体を含み、前記読み取り可能な記憶媒体は、フラッシュメモリ、ハードディスク、マルチメディアカード、カード型記憶装置（例えば、ＳＤ又はＤＸ記憶装置など）、ランダムアクセスメモリ（ＲＡＭ）、スタティックランダムアクセスメモリ（ＳＲＡＭ）、読み出し専用メモリ（ＲＯＭ）、電気的消去可能なプログラマブル読み出し専用メモリ（ＥＥＰＲＯＭ）、プログラマブル読み取り専用メモリ（ＰＲＯＭ）、磁気メモリ、磁気ディスク、光ディスクなどを含む。いくつかの実施例において、記憶装置２１は、アプリケーションサーバ２の内部記憶ユニットであってもよく、例えば、アプリケーションサーバ２のハードディスク又はメモリである。別の実施例において、記憶装置２１は、例えば、アプリケーションサーバ２に配置されたプラグインハードディスク、スマートメディアカード（Ｓｍａｒｔ  Ｍｅｄｉａ(登録商標)  Ｃａｒｄ、ＳＭＣ）、セキュアデジタル（Ｓｅｃｕｒｅ  Ｄｉｇｉｔａｌ、ＳＤ）カード、フラッシュカード（Ｆｌａｓｈ  Ｃａｒｄ）などのアプリケーションサーバ２の外部記憶機器であってもよい。当然のことながら、記憶装置２１は、さらにアプリケーションサーバ２の内部記憶ユニットと、その外部記憶機器の両者とも、含むことができる。本実施例において、記憶装置２１は、通常、例えばマルチタスクスケジューリングシステム２０のプログラムコードなどのアプリケーションサーバ２にインストールされているオペレーティングシステムや種々のアプリケーションソフトウェアを記憶するために用いられる。また、記憶装置２１は、既に出力されたか又は出力される各種データを一時的に記憶するために用いられる。
【００２１】
いくつかの実施例において、プロセッサ２２は、中央処理装置（Ｃｅｎｔｒａｌ  Ｐｒｏｃｅｓｓｉｎｇ  Ｕｎｉｔ、ＣＰＵ）、コントローラ、マイクロコントローラ、マイクロプロセッサ、又は他のデータ処理チップであってもよい。プロセッサ２２は、通常、アプリケーションサーバ２の全体動作を制御するために用いられ、例えば、アプリケーションサーバ２とのデータ交換又は通信に関わる制御及び処理などを実行する。本実施例において、プロセッサ２２は、記憶装置２１に記憶されたプログラムコードの実行やデータ処理に用いられ、例えば、マルチタスクスケジューリングシステム２０の実行などである。
【００２２】
ネットワークインタフェース２３は、無線ネットワークインタフェース又は有線ネットワークインタフェースを含むことができ、ネットワークインタフェース２３は、通常、アプリケーションサーバ２と他の電子機器との間に通信接続を確立するために用いられる。本実施例において、ネットワークインタフェース２３は、主に、ネットワーク３を介してアプリケーションサーバ２とデータプラットフォーム４を接続し、アプリケーションサーバ２とデータプラットフォーム４との間に、データ伝送チャネルと通信接続を確立するために用いられる。
【００２３】
以上、本発明の各実施例の適用環境及び関連機器のハードウェア構造及び機能について詳細に説明した。以下では、上記の適用環境及び関連機器に基づき、本発明の各実施例を提供する。
【００２４】
まず、本発明は、マルチタスクスケジューリングシステム２０を提供する。
【００２５】
図３は、アプリケーションサーバ２におけるマルチタスクスケジューリングシステム２０の一実施例の機能モジュールの概略図を示す。本実施例において、マルチタスクスケジューリングシステム２０は、１つ又は複数のモジュールに分割することができ、前記１つ又は複数のモジュールは、記憶装置２１に記憶されており、且つ１つ又は複数のプロセッサ（本実施例において、プロセッサ２２）によって実行されることにより、本発明を完了させる。例えば、図３において、マルチタスクスケジューリングシステム２０は、接続モジュール２０１、タスク発行モジュール２０２、スケジューリングモジュール２０３、及び実行モジュール２０４に分割することができる。本発明で言う機能モジュールとは、特定の機能を完了できる一連のコンピュータプログラム命令セグメントであり、プログラムよりもマルチタスクスケジューリングシステム２０のアプリケーションサーバ２における実行プロセスを説明することに適する。以下では、各機能モジュール２０１−２０４の機能について、詳細に説明する。
【００２６】
接続モジュール２０１は、データプラットフォーム４と少なくとも１つのデータソース５との第１の接続（又はそれを第１タイプの接続と称する）を確立し、且つデータプラットフォーム４とアプリケーションサーバ２（例えば、解析サーバ）との第２の接続（又はそれを第２タイプの接続と称する）を確立するために用いられる。
【００２７】
好ましくは、本実施例において、データプラットフォーム４はＨａｄｏｏｐデータプラットフォームを採用し、且つデータプラットフォーム４におけるデータ伝送ツールによって、データプラットフォーム４と各データソース５との第１の接続を確立する。例えば、前記データ伝送ツールはＨａｄｏｏｐ内に設けられたＳｑｏｏｐツールである。当業者であれば、その他の実施例において、前記データプラットフォームとデータ伝送ツールは他のタイプを用いることもできる。
【００２８】
タスク発行モジュール２０２は、ユーザーの選択した同期する必要のあるソーステーブル（一部又は全部）とデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスク（又は、それをデータ抽出タスクと称する）を生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジン（例えば、ｏｏｚｉｅスケジューリングエンジン）に発行するために用いられる。
【００２９】
好ましくは、本実施例において、前記データソースのタイプは、第１タイプのデータソース（例えば、ＭＳ  ＳＱＬ  Ｓｅｒｖｅｒデータソース）、第２タイプのデータソース（例えば、Ｏｒａｃｌｅデータソース）、第３タイプのデータソース（例えば、ＭｙＳＱＬデータソース）などを含むが、それらに限定されない。当業者であれば、他の実施例において、前記データソースのタイプの数が、異なるデータプラットフォームの要件に従って増加又は減少することができることが理解される。例えば、ユーザーは、第１タイプのデータソースにおける一部のソーステーブルを同期させることを選択することができる。
【００３０】
好ましくは、本実施例において、前記データソースのソーステーブル構造は、各データソースのデータタイプと含まれたフィールド情報などを含むが、それらに限定されない。
【００３１】
好ましくは、本実施例において、アプリケーションサーバ２内に、各データソース５の対応する解析スクリプトファイルが設けられており、並列スケジューリングメカニズムによって、データプラットフォーム４におけるデータ伝送ツールが各解析スクリプトファイルにおけるソーステーブル構造の解析タスクを並列実行するように制御し、解析によって、各データソースのソーステーブル構造を取得し、且つ前記第２の接続によって、解析して取得された各データソースのソーステーブル構造をアプリケーションサーバ２に返させる。
【００３２】
好ましくは、本実施例において、前記生成された各データソースの対応するテーブル作成タスクは、ユーザーの選択した同期する必要のあるソーステーブル（一部又は全部）と各ソーステーブルのタイプに基づき、前記選択されたソーステーブルのタイプに対応する目標テーブルを生成することを含む。好ましくは、本実施例において、前記ソーステーブルのタイプは、第１タイプのディメンションテーブル（即ち、データ量が少なく、設定に使用されたソーステーブルに関連する）、第２タイプのタスクテーブル（即ち、テーブル内のデータは絶えず更新及び追加され、且つ当日に当日以外の履歴データを更新する）、第３タイプのフローテーブル（即ち、テーブル内のデータは絶えず追加され、且つ当日に当日以外の履歴データを更新しない）を含むが、それらに限定されない。
【００３３】
具体的には、ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブル（即ち、データ量が少なく、設定に使用されたソーステーブルに関連する）である場合、前記第１タイプのディメンションテーブルのソーステーブル構造に対応する第１タイプの目標テーブルを生成し、ただし、前記第１タイプの目標テーブルの数は前記ユーザーの選択した同期する必要のある第１タイプのソーステーブル数によって確定される。
【００３４】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブル（即ち、テーブル内のデータは絶えず更新及び追加され、且つ当日に当日以外の履歴データを更新する）である場合、前記第２タイプのタスクテーブルのソーステーブル構造に対応する第２タイプの目標テーブルを生成し、ただし、前記第２タイプの目標テーブルの数は前記ユーザーの選択した同期する必要のある第２タイプのソーステーブル数によって確定される。
【００３５】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブル（即ち、テーブル内のデータは絶えず追加され、且つ当日に当日以外の履歴データを更新しない）である場合、前記第３タイプのフローテーブルのソーステーブル構造に対応する第３タイプの目標テーブルを生成し、ただし、前記第３タイプの目標テーブルの数は前記ユーザーの選択した同期する必要のある第３タイプのソーステーブル数によって確定される。
【００３６】
好ましくは、本実施例において、前記生成された各データソースの対応するデータ同期タスクは、
ユーザーの選択した同期する必要のある開始時刻と終了時刻に基づき、各ソーステーブルからのデータ抽出の開始時刻とデータ抽出の終了時刻を確定し、
ユーザーの選択した同期する必要のあるソーステーブル数及び同期する目標側のユーザーに基づき、データ同期の各タスクに必要なリソース配置（例えば、ＣＰＵ、メモリ及び磁気ディスクなど）とリソース管理ノードを確定し、ただし、前記リソース配置はリストの方式によって実現することができ、前記リソース管理ノードはＨａｄｏｏｐリソース表現モデルとリソース割当モデルによって実現することができ、
前記同期する必要のあるソーステーブルの該当するフィールドと前記生成された各目標テーブルの該当するフィールドとの対応関係を確立し、且つソーステーブルと目標テーブルの該当するフィールドの対応関係に基づき、各ソーステーブルの対応するデータ抽出タスクを生成することを含む。
【００３７】
具体的には、ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記同期する必要のある第１タイプのディメンションテーブルの該当するフィールドと前記生成された各第１タイプの目標テーブルの該当するフィールドとの対応関係を確立し、且つ第１タイプのディメンションテーブルと第１タイプの目標テーブルの該当するフィールドとの対応関係に基づき、各第１タイプのディメンションテーブルの対応するデータ抽出タスクを生成する。
【００３８】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記同期する必要のある第２タイプのタスクテーブルの該当するフィールドと前記生成された各第２タイプの目標テーブルの該当するフィールドとの対応関係を確立し、且つ第２タイプのタスクテーブルと第２タイプの目標テーブルの該当するフィールドとの対応関係に基づき、各第２タイプのタスクテーブルの対応するデータ抽出タスクを生成する。
【００３９】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記同期する必要のある第３タイプのフローテーブルの該当するフィールドと前記生成された各第３タイプの目標テーブルの該当するフィールドとの対応関係を確立し、且つ第３タイプのフローテーブルと第３タイプの目標テーブルの該当するフィールドとの対応関係に基づき、各第３タイプのフローテーブルの対応するデータ抽出タスクを生成する。
【００４０】
スケジューリングモジュール２０３は、ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するために用いられる。本実施形態では、前記特定のファイルシステムは分散ファイルシステム、例えば、Ｈａｄｏｏｐ分散ファイルシステム（Ｈａｄｏｏｐ  Ｄｉｓｔｒｉｂｕｔｅｄ  Ｆｉｌｅ  Ｓｙｓｔｅｍ、ＨＤＦＳ）であり、前記タスクスケジューリングインタフェーステンプレートはｏｏｚｉｅ  ｗｅｂ  ｓｅｒｖｉｃｅ  ＡＰＩ（Ａｐｐｌｉｃａｔｉｏｎ  Ｐｒｏｇｒａｍｍｉｎｇ  Ｉｎｔｅｒｆａｃｅ、アプリケーションプログラミングインタフェース）テンプレートである。ただし、前記タスクスケジューリングインタフェーステンプレートは前記特定のファイルシステムに予め配置される。
【００４１】
好ましくは、本実施例において、前記同期パラメータは、各タスクに必要なリソース配置ノードとリソース管理ノード、データ同期の開始時刻と終了時刻、前記同期パラメータを選択するユーザー名などの情報を含むが、それらに限定されない。
【００４２】
好ましくは、本実施例において、前記タスクスケジューリングインタフェーステンプレートは、パラメータ設定スクリプト、タスク実行スクリプト及びタスクスケジューリングスクリプトを含むが、それらに限定されない。ただし、前記パラメータ設定スクリプトはｓｈｅｌｌスクリプトであり、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するために用いられる。前記タスク実行スクリプトは、ＸＭＬ（Ｅｘｔｅｎｓｉｂｌｅ  Ｍａｒｋｕｐ  Ｌａｎｇｕａｇｅ、拡張可能なマークアップ言語）スクリプトであり、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するために用いられる。前記タスクスケジューリングスクリプトはＸＭＬスクリプトであり、各データソースの対応するデータ同期タスクの実行順序を管理するために用いられる。
【００４３】
好ましくは、本実施例において、前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプト、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプト、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトを含むが、それらに限定されない。
【００４４】
実行モジュール２０４は、各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するために用いられる。
【００４５】
好ましくは、本実施例において、前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータ（メタデータ情報）をそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む。
【００４６】
具体的には、ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶する。
【００４７】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶する。
【００４８】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶する。
【００４９】
好ましくは、他の実施例において、マルチタスクスケジューリングシステム２０がプロセッサ２２によって実行される時、さらに、
並列スケジューリングメカニズムによって、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを並列実行し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶するステップを実現する。
【００５０】
機能モジュール２０１−２０４によって、本発明の提供するマルチタスクスケジューリングシステム２０は、ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを自動的に生成し、同時に、異なる特定のファイル（例えば、パラメータ設定スクリプト、タスク実行スクリプト及びタスクスケジューリングスクリプト）をタスクスケジューリングインタフェーステンプレートに一度に配置し、データ同期操作を行う場合、前記タスクスケジューリングインタフェーステンプレートを直接呼び出し、且つ各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達し、各データソースの対応するテーブル作成タスクとデータ同期タスクを自動的に実行することにより、マルチデータソースのデータ同期の完全自動化を実現し、配置プロセスが不要となり、ＡＰＩインタフェースの呼び出しをパラメータ化し、データ同期の時に同期パラメータを伝達するだけで同期タスクを完了することができる。
【００５１】
また、本発明は、さらにマルチタスクスケジューリング方法を提供する。
【００５２】
図４は本発明のマルチタスクスケジューリング方法の一実施例の実施フローチャートを示す。本実施例において、必要に応じて、図４に示したフローチャートにおけるステップの実行順序は変更されてもよく、一部のステップは省略されてもよい。
【００５３】
ステップＳ４１、データプラットフォーム４と少なくとも１つのデータソース５との第１の接続（又はそれを第１タイプの接続と称する）を確立し、且つデータプラットフォーム４とアプリケーションサーバ２（例えば、解析サーバ）との第２の接続（又はそれを第２タイプの接続と称する）を確立する。
【００５４】
好ましくは、本実施例において、データプラットフォーム４はＨａｄｏｏｐデータプラットフォームを採用し、且つデータプラットフォーム４におけるデータ伝送ツールによって、データプラットフォーム４と各データソース５との第１の接続を確立する。例えば、前記データ伝送ツールはＨａｄｏｏｐ内に設けられたＳｑｏｏｐツールである。当業者であれば、その他の実施例において、前記データプラットフォームとデータ伝送ツールは他のタイプを用いることもできる。
【００５５】
ステップＳ４２、ユーザーの選択した同期する必要のあるソーステーブル（一部又は全部）とデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスク（又は、それをデータ抽出タスクと称する）を生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジン（例えば、ｏｏｚｉｅスケジューリングエンジン）に発行する。
【００５６】
好ましくは、本実施例において、前記データソースのタイプは、第１タイプのデータソース（例えば、ＭＳ  ＳＱＬ  Ｓｅｒｖｅｒデータソース）、第２タイプのデータソース（例えば、Ｏｒａｃｌｅデータソース）、第３タイプのデータソース（例えば、ＭｙＳＱＬデータソース）などを含むが、それらに限定されない。当業者であれば、他の実施例において、前記データソースのタイプの数が、異なるデータプラットフォームの要件に従って増加又は減少することができることが理解される。例えば、ユーザーは、第１タイプのデータソースにおける一部のソーステーブルを同期させることを選択することができる。
【００５７】
好ましくは、本実施例において、前記データソースのソーステーブル構造は、各データソースのデータタイプと含まれたフィールド情報などを含むが、それらに限定されない。
【００５８】
好ましくは、本実施例において、アプリケーションサーバ２内に、各データソース５の対応する解析スクリプトファイルが設けられており、並列スケジューリングメカニズムによって、データプラットフォーム４におけるデータ伝送ツールが各解析スクリプトファイルにおけるソーステーブル構造の解析タスクを並列実行するように制御し、解析によって、各データソースのソーステーブル構造を取得し、且つ前記第２の接続によって、解析して取得された各データソースのソーステーブル構造をアプリケーションサーバ２に返させる。
【００５９】
好ましくは、本実施例において、前記生成された各データソースの対応するテーブル作成タスクは、ユーザーの選択した同期する必要のあるソーステーブル（一部又は全部）と各ソーステーブルのタイプに基づき、前記選択されたソーステーブルのタイプに対応する目標テーブルを生成することを含む。好ましくは、本実施例において、前記ソーステーブルのタイプは、第１タイプのディメンションテーブル（即ち、データ量が少なく、設定に使用されたソーステーブルに関連する）、第２タイプのタスクテーブル（即ち、テーブル内のデータは絶えず更新及び追加され、且つ当日に当日以外の履歴データを更新する）、第３タイプのフローテーブル（即ち、テーブル内のデータは絶えず追加され、且つ当日に当日以外の履歴データを更新しない）を含むが、それらに限定されない。
【００６０】
具体的には、ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブル（即ち、データ量が少なく、設定に使用されたソーステーブルに関連する）である場合、前記第１タイプのディメンションテーブルのソーステーブル構造に対応する第１タイプの目標テーブルを生成し、ただし、前記第１タイプの目標テーブルの数は前記ユーザーの選択した同期する必要のある第１タイプのソーステーブル数によって確定される。
【００６１】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブル（即ち、テーブル内のデータは絶えず更新及び追加され、且つ当日に当日以外の履歴データを更新する）である場合、前記第２タイプのタスクテーブルのソーステーブル構造に対応する第２タイプの目標テーブルを生成し、ただし、前記第２タイプの目標テーブルの数は前記ユーザーの選択した同期する必要のある第２タイプのソーステーブル数によって確定される。
【００６２】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブル（即ち、テーブル内のデータは絶えず追加され、且つ当日に当日以外の履歴データを更新しない）である場合、前記第３タイプのフローテーブルのソーステーブル構造に対応する第３タイプの目標テーブルを生成し、ただし、前記第３タイプの目標テーブルの数は前記ユーザーの選択した同期する必要のある第３タイプのソーステーブル数によって確定される。
【００６３】
好ましくは、本実施例において、前記生成された各データソースの対応するデータ同期タスクは、
ユーザーの選択した同期する必要のある開始時刻と終了時刻に基づき、各ソーステーブルからのデータ抽出の開始時刻とデータ抽出の終了時刻を確定し、
ユーザーの選択した同期する必要のあるソーステーブル数及び同期する目標側のユーザーに基づき、データ同期の各タスクに必要なリソース配置（例えば、ＣＰＵ、メモリ及び磁気ディスクなど）とリソース管理ノードを確定し、ただし、前記リソース配置はリストの方式によって実現することができ、前記リソース管理ノードはＨａｄｏｏｐリソース表現モデルとリソース割当モデルによって実現することができ、
前記同期する必要のあるソーステーブルの該当するフィールドと前記生成された各目標テーブルの該当するフィールドとの対応関係を確立し、且つソーステーブルと目標テーブルの該当するフィールドの対応関係に基づき、各ソーステーブルの対応するデータ抽出タスクを生成することを含む。
【００６４】
具体的には、ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記同期する必要のある第１タイプのディメンションテーブルの該当するフィールドと前記生成された各第１タイプの目標テーブルの該当するフィールドとの対応関係を確立し、且つ第１タイプのディメンションテーブルと第１タイプの目標テーブルの該当するフィールドとの対応関係に基づき、各第１タイプのディメンションテーブルの対応するデータ抽出タスクを生成する。
【００６５】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記同期する必要のある第２タイプのタスクテーブルの該当するフィールドと前記生成された各第２タイプの目標テーブルの該当するフィールドとの対応関係を確立し、且つ第２タイプのタスクテーブルと第２タイプの目標テーブルの該当するフィールドとの対応関係に基づき、各第２タイプのタスクテーブルの対応するデータ抽出タスクを生成する。
【００６６】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記同期する必要のある第３タイプのフローテーブルの該当するフィールドと前記生成された各第３タイプの目標テーブルの該当するフィールドとの対応関係を確立し、且つ第３タイプのフローテーブルと第３タイプの目標テーブルの該当するフィールドとの対応関係に基づき、各第３タイプのフローテーブルの対応するデータ抽出タスクを生成する。
【００６７】
ステップＳ４３、ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達する。本実施形態では、前記特定のファイルシステムは分散ファイルシステム、例えば、Ｈａｄｏｏｐ分散ファイルシステム（Ｈａｄｏｏｐ  Ｄｉｓｔｒｉｂｕｔｅｄ  Ｆｉｌｅ  Ｓｙｓｔｅｍ、ＨＤＦＳ）であり、前記タスクスケジューリングインタフェーステンプレートはｏｏｚｉｅ  ｗｅｂ  ｓｅｒｖｉｃｅ  ＡＰＩ（Ａｐｐｌｉｃａｔｉｏｎ  Ｐｒｏｇｒａｍｍｉｎｇ  Ｉｎｔｅｒｆａｃｅ、アプリケーションプログラミングインタフェース）テンプレートである。ただし、前記タスクスケジューリングインタフェーステンプレートは前記特定のファイルシステムに予め配置される。
【００６８】
好ましくは、本実施例において、前記同期パラメータは、各タスクに必要なリソース配置ノードとリソース管理ノード、データ同期の開始時刻と終了時刻、前記同期パラメータを選択するユーザー名などの情報を含むが、それらに限定されない。
【００６９】
好ましくは、本実施例において、前記タスクスケジューリングインタフェーステンプレートは、パラメータ設定スクリプト、タスク実行スクリプト及びタスクスケジューリングスクリプトを含むが、それらに限定されない。ただし、前記パラメータ設定スクリプトはｓｈｅｌｌスクリプトであり、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するために用いられる。前記タスク実行スクリプトは、ＸＭＬ（Ｅｘｔｅｎｓｉｂｌｅ  Ｍａｒｋｕｐ  Ｌａｎｇｕａｇｅ、拡張可能なマークアップ言語）スクリプトであり、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するために用いられる。前記タスクスケジューリングスクリプトはＸＭＬスクリプトであり、各データソースの対応するデータ同期タスクの実行順序を管理するために用いられる。
【００７０】
好ましくは、本実施例において、前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプト、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプト、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトを含むが、それらに限定されない。
【００７１】
ステップＳ４４、各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行する。
【００７２】
好ましくは、本実施例において、前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータ（メタデータ情報）をそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む。
【００７３】
具体的には、ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶する。
【００７４】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶する。
【００７５】
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶する。
【００７６】
好ましくは、他の実施例において、該方法は、さらに、
並列スケジューリングメカニズムによって、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを並列実行し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶するステップを含む。
【００７７】
ステップＳ４１−Ｓ４４によって、本発明の提供するマルチタスクスケジューリング方法は、ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを自動的に生成し、同時に、異なる特定のファイル（例えば、パラメータ設定スクリプト、タスク実行スクリプト及びタスクスケジューリングスクリプト）をタスクスケジューリングインタフェーステンプレートに一度に配置し、データ同期操作を行う場合、前記タスクスケジューリングインタフェーステンプレートを直接呼び出し、且つ各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達し、各データソースの対応するテーブル作成タスクとデータ同期タスクを自動的に実行することにより、マルチデータソースのデータ同期の完全自動化を実現し、配置プロセスが不要となり、ＡＰＩインタフェースの呼び出しをパラメータ化し、データ同期の時に同期パラメータを伝達するだけで同期タスクを完了することができる。
【００７８】
さらに、上記の目的を達成するために、本発明は、コンピュータの読み取り可能な記憶媒体（例えば、ＲＯＭ／ＲＡＭ、磁気ディスク、光ディスク）を提供し、前記コンピュータの読み取り可能な記憶媒体にマルチタスクスケジューリングシステム２０が記憶されており、マルチタスクスケジューリングシステム２０が少なくとも１つのプロセッサ２２によって実行されることにより、少なくとも１つのプロセッサ２２が上述したマルチタスクスケジューリング方法のステップを実行する。
【００７９】
上記実施形態の説明によって、当業者であれば、上記実施例の方法がソフトウェアと必要な汎用ハードウェアプラットフォームの方式によって実現することができ、当然のことながら、ハードウェアによって実現することもできるが、多くの場合では、前者がより好ましい実施形態であることは、明らかに理解されるものである。このような理解に基づき、本発明の技術的解決手段は、本質的に又は、従来技術に寄与する部分がソフトウェア製品の形で具体化することができ、前記コンピュータソフトウェア製品は、記憶媒体（例えば、ＲＯＭ／ＲＡＭ、磁気ディスク、光ディスク）に記憶され、複数の命令を含み、それにより１台の端末装置（携帯電話、コンピュータ、サーバ、エアコン、又はネットワーク装置など）で本発明の各実施例に記載の方法を実行する。
【００８０】
以上、図面を参照しながら本発明の好ましい実施例について説明したが、これで本発明の特許請求の範囲を限定するものではない。上記本発明による実施例のシーケンス番号は、単に説明するためのものであり、実施例の優劣を表すものではない。また、フローチャートには論理的な順序が示されているが、場合によっては、ここで異なる順序で示し又は説明したステップを実行することができる。
【００８１】
本発明の趣旨を逸脱しない限り、当業者であれば、種々の変形変更が可能である。例えば、ある実施例における特徴は他の実施例に適用してさらに別の実施例を得る。本明細書及び図面の記載を利用して行う同等の構造又は同等のプロセスの変換、又は他の関連技術分野における直接的又は間接的な利用の全てが、いずれも本発明に属することを理解されたい。
【符号の説明】
【００８２】
アプリケーションサーバ  ２
ネットワーク  ３
データプラットフォーム  ４
データソース  ５
記憶装置  ２１
プロセッサ  ２２
ネットワークインタフェース  ２３
マルチタスクスケジューリングシステム  ２０
接続モジュール  ２０１
タスク発行モジュール  ２０２
スケジューリングモジュール  ２０３
実行モジュール  ２０４
処理ステップ  Ｓ４１―Ｓ４４
【図１】
2019523462.tif 000003
【図２】
2019523462.tif 000004
【図３】
2019523462.tif 000005
【図４】
2019523462.tif 000006
【手続補正書】
【提出日】平成30年9月19日(2018.9.19)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
アプリケーションサーバであって、プロセッサ上で動作可能なマルチタスクスケジューリングシステムが記憶されている記憶装置と、プロセッサと、を含み、前記マルチタスクスケジューリングシステムが前記プロセッサによって実行される時、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立するステップと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するステップと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を実現する
ことを特徴とするアプリケーションサーバ。
【請求項２】
前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む
ことを特徴とする請求項１に記載のアプリケーションサーバ。
【請求項３】
前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプトと、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプトと、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトと、を含む
ことを特徴とする請求項２に記載のアプリケーションサーバ。
【請求項４】
前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む
ことを特徴とする請求項２又は３に記載のアプリケーションサーバ。
【請求項５】
前記データ同期タスクの実行は、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、を含む
ことを特徴とする請求項４に記載のアプリケーションサーバ。
【請求項６】
アプリケーションサーバに適用されるマルチタスクスケジューリング方法において、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームと前記アプリケーションサーバとの第２の接続を確立し、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行し、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達し、及び
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行する
ことを特徴とするマルチタスクスケジューリング方法。
【請求項７】
前記タスクスケジューリングインタフェーステンプレートは、前記ワークフロースケジューリングエンジンから伝達された同期パラメータを受信するためのパラメータ設定スクリプトと、各データソースの対応するデータ同期タスクの同期パラメータに基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するためのタスク実行スクリプトと、各データソースの対応するデータ同期タスクの実行順序を管理するためのタスクスケジューリングスクリプトと、を含む
ことを特徴とする請求項６に記載のマルチタスクスケジューリング方法。
【請求項８】
前記タスク実行スクリプトは、第１タイプのディメンションテーブルからデータを抽出するための第１実行スクリプトと、第２タイプのタスクテーブルからデータを抽出するための第２実行スクリプトと、第３タイプのフローテーブルからデータを抽出するための第３実行スクリプトと、を含む
ことを特徴とする請求項７に記載のマルチタスクスケジューリング方法。
【請求項９】
前記データ同期タスクの実行は、
前記タスクスケジューリングインタフェーステンプレートにおける各データソースの対応するタスク実行スクリプトを呼び出し、データ同期の各タスクに必要なリソース配置を取得し、各ソーステーブルから該当するフィールドに対応するデータをそれぞれ抽出し、且つ抽出されたデータを各目標テーブルの該当するフィールドにそれぞれ記憶することを含む
ことを特徴とする請求項８又は７に記載のマルチタスクスケジューリング方法。
【請求項１０】
前記データ同期タスクの実行は、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第１タイプのディメンションテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第１実行スクリプトを呼び出し、各第１タイプのディメンションテーブルから該当するフィールドに対応する第１データをそれぞれ抽出し、且つ抽出された第１データを各第１タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第２タイプのタスクテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第２実行スクリプトを呼び出し、各第２タイプのタスクテーブルから該当するフィールドに対応する第２データをそれぞれ抽出し、且つ抽出された第２データを各第２タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、
ユーザーの選択した同期する必要のあるソーステーブルのタイプが第３タイプのフローテーブルである場合、前記タスクスケジューリングインタフェーステンプレートにおける第３実行スクリプトを呼び出し、各第３タイプのフローテーブルから該当するフィールドに対応する第３データをそれぞれ抽出し、且つ抽出された第３データを各第３タイプの目標テーブルの該当するフィールドにそれぞれ記憶することと、を含む
ことを特徴とする請求項９に記載のマルチタスクスケジューリング方法。
【請求項１１】
コンピュータの読み取り可能な記憶媒体であって、前記コンピュータの読み取り可能な記憶媒体にマルチタスクスケジューリングシステムが記憶されており、前記マルチタスクスケジューリングシステムが少なくとも１つのプロセッサによって実行されることにより、
データプラットフォームと少なくとも１つのデータソースとの第１の接続を確立し、且つ前記データプラットフォームとアプリケーションサーバとの第２の接続を確立するステップと、
ユーザーの選択した同期する必要のあるソーステーブルとデータソースのタイプを受信し、予め解析して取得された各データソースのソーステーブル構造に基づき、各データソースの対応するテーブル作成タスクとデータ同期タスクを生成し、且つ前記生成された各データソースの対応するテーブル作成タスクとデータ同期タスクを予め設定されたワークフロースケジューリングエンジンに発行するステップと、
ユーザーの選択した同期開始時刻になると、前記予め設定されたワークフロースケジューリングエンジンによって特定のファイルシステムから予め設定されたタスクスケジューリングインタフェーステンプレートを呼び出し、且つ前記予め設定されたワークフロースケジューリングエンジンによって各データソースの対応するデータ同期タスクの同期パラメータを前記タスクスケジューリングインタフェーステンプレートに伝達するステップと、
各データソースの対応するデータ同期タスクの同期パラメータに基づき、前記タスクスケジューリングインタフェーステンプレートにおける対応するタスク実行スクリプトを呼び出し、各データソースの対応するテーブル作成タスクとデータ同期タスクを実行するステップと、を実現する
ことを特徴とするコンピュータの読み取り可能な記憶媒体。
【国際調査報告】
2019523462.tif 000007
2019523462.tif 000008
2019523462.tif 000009
2019523462.tif 000010