(57)【要約】  メッセージ処理方法、装置およびシステムを開示し、メッセージ処理方法は、前処理ノードは、データソースが送信した１つのイベントの最初のメッセージの受信に応答し、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索することと、前記前処理ノードは、検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立することと、前記検索されたルールインスタンスによって前記最初のメッセージを処理するために、前記前処理ノードは、前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信することと、を含む。【選択図】図２
2021524085.tif 000002
【特許請求の範囲】
【請求項１】
前処理ノードは、データソースが送信した１つのイベントの最初のメッセージの受信に応答し、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索することと、
前記前処理ノードは、検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立することと、
前記前処理ノードは、前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信し、前記検索されたルールインスタンスによって前記最初のメッセージを処理することと、を含む、メッセージ処理方法。
【請求項２】
前記前処理ノードは、検索されたルールインスタンスに従い、処理経路を確立した後、
前記前処理ノードは、前記処理経路を保存し、前記データソースが送信した前記１つのイベントの後続メッセージの受信に応答し、保存された前記処理経路に従い、前記後続メッセージを前記処理ノードに送信すること、をさらに含む、請求項１に記載のメッセージ処理方法。
【請求項３】
前記作成されたルールインスタンスは、少なくとも１つの処理ルールに従って作成され、異なる処理ルールに従って作成されたルールインスタンスが所在する処理ノードは異なる、請求項１に記載のメッセージ処理方法。
【請求項４】
前記作成されたルールインスタンスは、少なくとも１つのグループに分けられ、同じ処理ルールに従って作成されたルールインスタンスは、１つのグループに分けられ、
前記前処理ノードが、作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索することは、前記前処理ノードが、各グループにおいてルールインスタンスを検索し、各グループにおいて前記１つのイベントのルールインスタンスを含む最大１つの前記処理対象を検索すること、を含む、請求項３に記載のメッセージ処理方法。
【請求項５】
前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、前記検索されたルールインスタンスの識別を含み、または、
前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、前記検索されたルールインスタンスの識別とタイプを含み、同じ処理ルールに従って作成されたルールインスタンスのタイプは同じであり、異なる処理ルールに従って作成されたルールインスタンスのタイプは異なる、請求項３に記載のメッセージ処理方法。
【請求項６】
前記前処理ノードが、前記最初のメッセージを前記処理ノードに送信することは、前記前処理ノードが、前記検索されたルールインスタンスのパラメータと識別を前記最初のメッセージに書き込み、前記最初のメッセージを前記処理ノードに送信すること、を含む、請求項１に記載のメッセージ処理方法。
【請求項７】
前記処理経路は、複数の処理ノードのアドレス指定情報を含み、前記前処理ノードが、前記最初のメッセージを前記複数の処理ノードに送信し、前記検索されたルールインスタンスによって前記最初のメッセージを処理することは、
前記前処理ノードは、前記最初のメッセージと前記処理経路の１つ目の処理ノードの後の全ての処理ノードのアドレス指定情報を前記１つ目の処理ノードに送信することと、
前記最初のメッセージを受信した各前記処理ノードは、各前記処理ノードでの前記検索されたルールインスタンスを利用して前記最初のメッセージを処理し、各前記処理ノードが前記複数の処理ノードの最後の１つの処理ノードではないと確定することに応答し、前記最初のメッセージと前記処理経路の次の処理ノードの後の全ての処理ノードのアドレス指定情報を前記次の処理ノードに送信することと、を含む、請求項１〜６のいずれか１項に記載のメッセージ処理方法。
【請求項８】
前記ルールインスタンスは、関連分析ルールに従って作成されたルールインスタンスを含む、請求項１〜６のいずれか１項に記載のメッセージ処理方法。
【請求項９】
処理ノードは、前処理ノードまたは１つ前の処理ノードが送信した１つのイベントのメッセージを受信することと、
前記処理ノードは、前記メッセージを前記１つのイベントの最初のメッセージとして確定することに応答し、前記処理ノードでの対応するルールインスタンスを利用して前記最初のメッセージを処理することと、を含む、メッセージ処理方法。
【請求項１０】
前記処理ノードは、前記１つのイベントのメッセージの受信に応答し、前記１つのイベントの処理経路の後続処理ノードのアドレス指定情報を受信することと、
前記処理ノードは、前記１つのイベントの処理経路の後続処理ノードのアドレス指定情報を受信した後、前記アドレス指定情報を保存し、前記アドレス指定情報に基づいて前記後続処理ノードに前記最初のメッセージを送信することと、および、前記１つのイベントの後続メッセージの受信に応答し、保存された前記アドレス指定情報に基づき、前記後続処理ノードに前記後続メッセージを送信することと、をさらに含む、請求項９に記載のメッセージ処理方法。
【請求項１１】
前記処理ノードは、前記処理ノードでの対応するルールインスタンスを利用して前記最初のメッセージを処理した後、
前記最初のメッセージを処理する際に前記１つのイベントの新しいメッセージを生成することに応答し、前記新しいメッセージを前記１つのイベントのメッセージの収集を担当するデータソースに送信すること、をさらに含む、請求項９に記載のメッセージ処理方法。
【請求項１２】
データソースが送信したメッセージを受信するように設定されるメッセージ受信モジュールと、
前記メッセージ受信モジュールが１つのイベントの最初のメッセージを受信した後、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索するように設定されるインスタンス検索モジュールと、
検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立するように設定される経路確立モジュールと、
前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信して処理するように設定されるメッセージ送信モジュールと、を含む、メッセージ前処理ノード。
【請求項１３】
前記経路確立モジュールは、前記処理経路を確立した後、前記処理経路を保存するように設定され、
前記メッセージ送信モジュールは、前記データソースが送信した前記１つのイベントの後続メッセージを前記メッセージ受信モジュールが受信した後、保存された前記処理経路に従い、前記後続メッセージを前記処理ノードに送信するようにさらに設定される、請求項１２に記載のメッセージ前処理ノード。
【請求項１４】
前記経路確立モジュールが確立した前記処理経路において、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、前記検索されたルールインスタンスの識別を含み、または、前記検索されたルールインスタンスの識別とタイプを含み、前記作成されたルールインスタンスは、少なくとも１つの処理ルールに従って作成され、同じ処理ルールに従って作成されたルールインスタンスのタイプは同じであり、異なる処理ルールに従って作成されたルールインスタンスのタイプは異なる、請求項１２に記載のメッセージ前処理ノード。
【請求項１５】
前記経路確立モジュールが確立した前記処理経路は、複数の処理ノードのアドレス指定情報を含み、
前記メッセージ送信モジュールは、前記検索されたルールインスタンスのパラメータと識別を携帯する前記最初のメッセージと、前記処理経路の１つ目の処理ノードの後の全ての処理ノードのアドレス指定情報と、を前記１つ目の処理ノードに送信するように設定される、請求項１２に記載のメッセージ前処理ノード。
【請求項１６】
データソースと、前処理ノードと、処理ノードと、を含む、メッセージ処理システムであって、
前記データソースは、１つのイベントの全てのメッセージを前記前処理ノードに送信するように設定され、
前記前処理ノードは、請求項１２〜１５のいずれか１項に記載のメッセージ前処理ノードであり、
前記処理ノードは、前記前処理ノードが送信した前記１つのイベントのメッセージを受信し、前記メッセージを前記１つのイベントの最初のメッセージとして確定することに応答し、前記処理ノードでの前記前処理ノードによって検索されたルールインスタンスを利用して前記最初のメッセージを処理する、メッセージ処理システム。
【請求項１７】
前記処理ノードは、前記１つのイベントのメッセージを受信すると、前記１つのイベントの処理経路の後続処理ノードのアドレス指定情報を受信するように設定され、
前記処理ノードは、前記メッセージが前記１つのイベントの最初のメッセージであると確定した後、さらに後続処理ノードのアドレス指定情報を保存し、前記アドレス指定情報に基づいて後続処理ノードに前記最初のメッセージを送信し、および、前記１つのイベントの後続メッセージの受信に応答し、保存された前記アドレス指定情報に基づき、前記後続処理ノードに前記後続メッセージを送信するように設定される、請求項１６に記載のメッセージ処理システム。
【請求項１８】
前記ルールインスタンスは、関連分析ルールに従って作成されたルールインスタンスを含む、請求項１６または１７に記載のメッセージ処理システム。
【請求項１９】
メモリと、プロセッサと、前記メモリに記憶された前記プロセッサで動作可能なコンピュータプログラムと、を含むメッセージ処理装置であって、前記プロセッサが前記コンピュータプログラムを実行すると、請求項１〜１１のいずれか１項に記載のメッセージ処理方法を実現する、メッセージ処理装置。
【請求項２０】
コンピュータプログラムが記憶されているコンピュータ可読記憶媒体であって、前記コンピュータプログラムがプロセッサに実行されると、請求項１〜１１のいずれか１項に記載のメッセージ処理方法を実現する、コンピュータ可読記憶媒体。
【発明の詳細な説明】
【技術分野】
【０００１】
本出願は、出願番号２０１８１０４３８７３９．９、出願日２０１８年５月９日の中国特許出願に基づいて提出し、該中国特許出願の優先権を主張するものであり、該中国特許出願の全ての内容が引用により本出願に援用される。
【０００２】
本出願は、データ処理に関し、例えば、メッセージ処理方法、装置およびシステムに関する。
【背景技術】
【０００３】
現在、ストリーム処理は、電子商取引、ニュース集約、ソーシャルネットワーキングサイト、データマイニング、機械学習などの分野に広く使われており、ストリーム処理は、低遅延、高性能、分散型、拡張可能、フォールトトレランスの特徴があり、スレッド、プロセス、サーバレベルの拡張を簡単に実現できる。現在、例えば、ｓｔｏｒｍ、ｓｐａｒｋなど、既に多くの成熟したストリーム処理フレームワークがある。
【０００４】
図１に、ストリーム処理のシステムフレームワークを示し、ストリーム処理では、メッセージは、少なくとも１つのデータソースから出発し、複数のノードによって処理され、図中のＳ１およびＳ２はデータソースであり、Ｂ１〜Ｂ５はメッセージを処理するノードである。ストリーム処理の利点は、メッセージ処理の拡張能力にあり、メッセージ処理の各段階は、いずれもプロセス内の拡張とプロセス間の拡張を含む拡張が得られる。このようにハードウェアが充実している状況では、メッセージ処理能力は無限に拡張できる。
【０００５】
電気通信の分野では、第５世代モバイル通信技術（５−Ｇｅｎｅｒａｔｉｏｎ、５Ｇ）ネットワーク時代の到来に伴い、モバイルネットワークデバイスのアクセス数が大幅に増加し、２０２０年には、５００億台のモバイルデバイスがネットワークにアクセスすると予想されている。それに伴い、ネットワーク管理デバイスの数が大幅に増加し、ネットワーク管理ソフトウェアは大量のメッセージを処理する必要がある。ストリーム処理を導入すると、伝統的なネットワーク管理のメッセージ処理能力を大幅に向上させることができるが、伝統的なネットワーク管理にはいくつかの独自の業務要求があり、関連分析ルールに従ってメッセージに対する関連分析はその１つである。アラームメッセージを例にとると、ネットワーク管理システムにおけるアラームメッセージの関連分析は、異なるイベントによって発生されるアラームメッセージの間の関連関係を見出すことに使用され、それにより、アラーム発生の主な原因を特定し、ユーザが迅速に問題を見つけて解決することができる。別の例として、ネットワーク管理システムでは、マージルールに従ってアラームメッセージに対してマージ処理を行うニーズも存在する。ビッグデータ解析の分野でも、例えば、異なるニュースイベントのメッセージの関連分析や、異なる購入イベントのメッセージのマージ処理など、様々なルールに従ってメッセージを処理するニーズがある。
【０００６】
ストリーム処理において、どのように対応するルールに従ってメッセージに対するこれらの処理を実現するかは、注目すべきキーポイントである。また、いくつかの特定のメッセージは、順番に処理する必要があり、ストリーム処理の際にどのように実現するかも、注目すべきキーポイントである。
【発明の概要】
【課題を解決するための手段】
【０００７】
以下は本明細書で説明した主題の概要である。この概要は、特許請求の保護範囲を制限するためのものではない。
【０００８】
本出願実施例は、前処理ノードは、データソースが送信した１つのイベントの最初のメッセージの受信に応答し、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索することと、前記前処理ノードは、検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立することと、前記処理ノードで前記検索されたルールインスタンスによって前記最初のメッセージを処理するために、前記前処理ノードは、前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信することと、を含む、メッセージ処理方法を提供する。
【０００９】
本出願実施例は、処理ノードは、前処理ノードまたは１つ前の処理ノードが送信した１つのイベントのメッセージを受信することと、前記処理ノードは、前記メッセージを前記１つのイベントの最初のメッセージとして確定することに応答し、前記処理ノードでの対応するルールインスタンスを利用して前記最初のメッセージを処理することと、を含む、メッセージ処理方法をさらに提供する。
【００１０】
本出願実施例は、データソースが送信したメッセージを受信するように設定されるメッセージ受信モジュールと、前記メッセージ受信モジュールが１つのイベントの最初のメッセージを受信した後、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索するように設定されるインスタンス検索モジュールと、検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立するように設定される経路確立モジュールと、前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信するように設定されるメッセージ送信モジュールと、を含む、メッセージ前処理ノードをさらに提供する。
【００１１】
本出願実施例は、データソースと、前処理ノードと、処理ノードと、を含む、メッセージ処理システムであって、前記データソースは、１つのイベントの全てのメッセージを前記前処理ノードに送信するように設定され、前記前処理ノードは、前述した実施例に記載のメッセージ前処理ノードであり、前記処理ノードは、前記前処理ノードが送信した前記１つのイベントのメッセージを受信し、前記メッセージが前記１つのイベントの最初のメッセージであると確定した場合、前記処理ノードでの前記検索されたルールインスタンスを利用して前記最初のメッセージを処理する、メッセージ処理システムをさらに提供する。
【００１２】
本出願実施例は、メモリと、プロセッサと、前記メモリに記憶された前記プロセッサで動作可能なコンピュータプログラムと、を含むメッセージ処理装置であって、前記プロセッサが前記コンピュータプログラムを実行すると、本出願実施例に記載のメッセージ処理方法を実現する、メッセージ処理装置をさらに提供する。
【００１３】
本出願実施例は、コンピュータプログラムが記憶されているコンピュータ可読記憶媒体であって、該コンピュータプログラムがプロセッサに実行されると、本出願実施例に記載のメッセージ処理方法を実現する、コンピュータ可読記憶媒体をさらに提供する。
【００１４】
図面と詳細な説明を読んで理解した後、他の側面を理解することができる。
【図面の簡単な説明】
【００１５】
【図１】ストリーム処理の模式図である。
【図２】本出願実施例１に係るメッセージ処理方法のフローチャートである。
【図３】本出願実施例１に係る前処理ノードのブロック図である。
【図４】本出願実施例１に係る処理ノードが実行するメッセージ処理方法のフローチャートである。
【図５】本出願実施例２に係る段階を分けてメッセージを処理する模式図である。
【図６】本出願実施例２に係るメッセージに対して関連分析を行うフローチャートである。
【図７】本出願実施例３に係るアラームメッセージに対して関連分析を行う模式図である。
【図８】本出願実施例４に係るアラームメッセージに対して関連分析を行う模式図である。
【図９】本出願実施例５に係るアラームメッセージに対して関連分析を行う模式図である。
【図１０】本出願実施例６に係るアラームメッセージに対して関連分析を行う模式図である。
【図１１】本出願実施例７に係るニュースデータに対して関連分析を行う模式図である。
【発明を実施するための形態】
【００１６】
以下、図面に関連して本出願の実施例を詳細に説明する。なお、衝突しない場合、本出願の実施例および実施例の特徴を任意に組み合わせることができる。
【００１７】
実施例１
本実施例は、ストリーム処理方式でメッセージの処理経路を動的に計算し、処理経路に従ってメッセージの配信および処理を実現することができる、メッセージ処理方法を提供する。
【００１８】
本実施例のメッセージの処理システムは、図１を参照し、データソースとメッセージを処理するノードとを含む、ｊｓｔｏｒｍストリーム処理フレームワークなどのストリーム処理フレームワークを採用し、これらのノードは２つのタイプに分かれ、１つのタイプは前処理ノードと呼ばれ、１つのタイプは処理ノードと呼ばれる。前処理ノードは、データソースからイベントのメッセージを受信し、メッセージの処理経路を確立し、メッセージを処理ノードに配信するように設定され、処理ノードは、メッセージを受信すると、処理ルールに従って確立されたルールインスタンスを利用してメッセージを処理する。
【００１９】
図２に示すように、本実施例のメッセージ処理方法は、ステップ１１０、ステップ１２０とステップ１３０を含む。
【００２０】
ステップ１１０において、前処理ノードは、データソースが送信した１つのイベントの最初のメッセージの受信に応答し、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索する。
【００２１】
ここでの「１つのイベント」は、ある１つのイベントを指すためにのみ使用され、特定のイベントを指すものではない。イベントの最初のメッセージは、データソースが時間順に収集した該イベントの１つ目のメッセージである。１つのインスタンスにおいて、前記ルールインスタンスは、関連分析ルールに従って作成されたルールインスタンスを含み、前記１つのイベントはアラームイベントであり、１つのイベントの最初のメッセージはアラームイベントの発生メッセージであり、メッセージに対する処理はメッセージに対して関連分析を行うことである。しかし、本出願のイベントは、これに限定されるものではなく、例えば、デバイスが実行する１つの動作であってもよいし、１つの起こったイベントであってもよい。イベントのメッセージは、イベントに関する任意のデータであってもよく、同じイベントのメッセージには、キーワード、名前、識別などの該イベントのキー値が含まれ、キー値によって同じイベントのすべてのメッセージを識別できる。例えば、ネットワーク管理のアラームメッセージの場合、キー情報はネットワークエレメントであり、説明情報はアラーム発生の時間と説明などであり、ニュースイベントに対し、キー情報をニュースが発生した時間と定義してもよく、説明情報はニュースに関する人物と説明などである。具体的なキー情報の定義は、アプリケーションが実際のアプリケーションシーンに基づいて定義すべきである。
【００２２】
本実施例では、前処理ノードおよび処理ノードは、いずれも論理ノードであり、ルールインスタンスは、処理ルールに従って作成され、処理ノード上で動作すると、該処理ルールの業務処理ロジックを実行する。１つのインスタンスにおいて、前処理ノードおよび処理ノードは、プロセスまたはスレッドなどの処理能力を有するリソースユニットで実現されてもよく、ルールインスタンスは、処理ノードで動作するプログラムである。
【００２３】
１つのルールインスタンスは、業務処理ロジックが必要であることに加え、該ルールインスタンスの処理対象も定義する必要がある。例えば、アラームイベントのメッセージに対して関連分析を行う１つのルールインスタンスでは、ネットワークエレメント識別およびアラームコードを指定することにより、指定されたネットワークエレメントで生成された特定のアラームコードを有するアラームイベントに、処理対象を定義するなど、条件を限定することによって処理対象を定義してもよい。本実施例は、前処理ノードにおいて、上述した限定条件などのシステムで作成されたルールインスタンスの処理対象情報を保存し、さらに、ルールインスタンスの識別、パラメータ、タイプなどの他の情報を保存してもよい。他の１つの実施例では、これらの情報は他のノードに保存されてもよく、前処理ノードは使用が必要なときに他のノードからこれらの情報を読み出す。
【００２４】
本実施例では、前記作成されたルールインスタンスは、少なくとも１つの処理ルールに従って作成され、各処理ルールは、１つの業務シーンに対応し、異なる業務処理ロジックを有する。１つの処理ルールに従って少なくとも１つのルールインスタンスを作成することができ、異なるルールインスタンスの処理対象、パラメータは異なってもよい。本実施例では、１つの処理ノードで少なくとも１つのルールインスタンスを実行でき、複数のルールインスタンスがある場合、処理ノードは、メッセージに書き込まれたルールインスタンスの識別に基づいてどのルールインスタンスを実行して処理するかを決定してもよい。本実施例では、異なる処理ルールに従って作成されたルールインスタンスが所在する処理ノードは異なる。
【００２５】
本実施例では、処理ルールに従って作成されたルールインスタンスを少なくとも１つのグループに分けてもよく、同じ処理ルールに従って作成されたルールインスタンスは、１つのグループに分けられる。システムで作成されたルールインスタンスにおいて処理対象を検索し、前記処理対象は、前記最初のメッセージのルールインスタンスを含む場合、グループを分けて検索する方式を採用し、かつ各グループは、前記１つのイベントのルールインスタンスを含む、最大１つの処理対象を見つけ、すなわち、該グループのルールインスタンスで１つのルールインスタンスを見つけると、該グループのルールインスタンスに対する検索を終了することができる。このように、同じ処理ルールに従って作成された複数のルールインスタンスにおいて、１つのルールインスタンスのみによって１つのイベントを処理するため、１つのイベントは１つの分岐のない関連分析経路のみがあり、１つの処理結果のみがある。しかし、これは必須ではない。
【００２６】
ステップ１２０において、前記前処理ノードは、検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立する。
【００２７】
本実施例では、検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、該ルールインスタンスを一意に識別することができる情報によって表される。例えば、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、前記検索されたルールインスタンスの識別を含み、または、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、前記検索されたルールインスタンスの識別とタイプを含み、作成されたルールインスタンスは、少なくとも１つの処理ルールに従って作成され、同じ処理ルールに従って作成されたルールインスタンスのタイプは同じであり、異なる処理ルールに従って作成されたルールインスタンスのタイプは異なる。システムには、各ルールインスタンスが所在する処理ノードが設定されているため、ルールインスタンスを一意に識別することができる情報は、アドレス指定情報としてもよく、アドレス指定の結果が毎回同じであることを保証する。具体的なアドレス指定方法は、例えば、ルールインスタンスの識別およびタイプをハッシュ演算し、得られたハッシュ値に基づいてハッシュ値と処理ノードとの対応関係を検索することにより、ルールインスタンスが所在する処理ノードを確定するなど、複数の種類があってもよい。これらのアドレス指定方法は、ストリーム処理フレームワークによって提供されるメカニズムを利用して実現されてもよい。
【００２８】
ステップ１３０において、前記検索されたルールインスタンスによって前記最初のメッセージを処理するために、前記前処理ノードは、前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信する。
【００２９】
１つのインスタンスにおいて、前記最初のメッセージを処理することは、前記最初のメッセージに対して関連分析を行うことを含むが、本出願はこれに限定されず、他の様々な処理であってもよい。
【００３０】
本ステップにおいて、ルールインスタンスにパラメータが定義されている場合、前記前処理ノードが、前記最初のメッセージを前記処理ノードに送信する際に、前記検索されたルールインスタンスのパラメータと識別を前記最初のメッセージに書き込み、最初のメッセージを前記処理ノードに送信し、前記検索されたルールインスタンスのパラメータおよび識別は、前記最初のメッセージを処理する際に使用されてもよい。
【００３１】
本ステップにおいて、処理ノードが複数ある場合、前処理ノードは、ブロードキャスト方式を使用し、前記最初のメッセージを前記複数の処理ノードにそれぞれ送信し、必要に応じてルールインスタンスのパラメータを同時に送信してもよい。本実施例では、シリアル配信方式を採用し、すなわち、前処理ノードは、処理経路の１つ目の処理ノードに最初のメッセージを送信し、処理経路の各処理ノードは、次の処理ノードに再送信する。
【００３２】
例えば、前記前処理ノードは、前記最初のメッセージと前記処理経路の１つ目の処理ノードの後の全ての処理ノードのアドレス指定情報を前記１つ目の処理ノードに送信し、前記最初のメッセージを受信した各処理ノードは、各処理ノードでの前記検索されたルールインスタンスを利用して前記最初のメッセージを処理し、各処理ノードが前記複数の処理ノードの最後の１つの処理ノードではないと確定することに応答し、前記最初のメッセージと前記処理経路の次の処理ノードの後の全ての処理ノードのアドレス指定情報を前記次の処理ノードに送信する。
【００３３】
上述した前処理ノードおよび処理ノードが送信したアドレス指定情報は、次の処理ノードが送信を継続するために必要であるが、これらのアドレス指定情報のみを送信することができると理解すべきではなく、例えば、前処理ノードは、処理経路の全ての処理ノードのアドレス指定情報を上述した１つ目の処理ノードに送信してもよく、上述した１つ目の処理ノードが自分のアドレス指定情報をその中から見つけると、後続の処理ノードのアドレス指定情報を確定できるため、メッセージの送信の継続を実現する。
【００３４】
本実施例では、前記前処理ノードは、検索されたルールインスタンスに従い、処理経路を確立した後、前記前処理ノードは、前記処理経路を保存し、前記データソースが送信した前記１つのイベントの後続メッセージの受信に応答し、保存された前記処理経路に従い、前記後続メッセージを前記処理ノードに送信する。具体的な送信方式は、最初のメッセージの送信方式と類似するが、処理ノードは、関連分析を行う際に、これらの後続イベントを処理しなくてもよい。勿論、他の業務処理ロジックである場合、後続のイベントを処理してもよい。本実施例では、ストリーム処理フレームワークがサポートするメカニズムを利用し、１つのイベントの全てのメッセージが、同じデータソースで収集され、同じ前処理ノードに配信される。
【００３５】
本出願は、メッセージの処理経路を確立し、処理経路に従って配信することにより、ストリーム処理において、作成されたルールインスタンスに従ってメッセージの処理を実現することができる。
【００３６】
図３に示すように、本実施例は、
データソースが送信したメッセージを受信するように設定されるメッセージ受信モジュール１０と、
前記メッセージ受信モジュールが１つのイベントの最初のメッセージを受信した後、システムで作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索するように設定されるインスタンス検索モジュール２０と、
検索されたルールインスタンスに従い、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報を含む処理経路を確立するように設定される経路確立モジュール３０と、
前記処理経路に従い、前記最初のメッセージを前記処理ノードに送信して処理するように設定されるメッセージ送信モジュール４０と、を含む、メッセージ前処理ノードをさらに提供する。
【００３７】
本実施例では、前記経路確立モジュールは、前記処理経路を確立した後、前記処理経路を保存するように設定され、前記メッセージ送信モジュールは、前記データソースが送信した前記１つのイベントの後続メッセージを前記メッセージ受信モジュールが受信した後、保存された前記処理経路に従い、前記後続メッセージを前記処理ノードに送信するようにさらに設定される。
【００３８】
本実施例では、前記作成されたルールインスタンスは、少なくとも１つの処理ルールに従って作成されたものであり、異なる処理ルールに従って作成されたルールインスタンスが所在する処理ノードは異なる。
【００３９】
本実施例では、前記作成されたルールインスタンスは、少なくとも１つのグループに分けられ、同じ処理ルールに従って作成されたルールインスタンスは、１つのグループに分けられ、前記インスタンス検索モジュールが、作成されたルールインスタンスにおいて、前記最初のメッセージのルールインスタンスを含む処理対象を検索することは、前記前処理ノードが、各グループにおいてルールインスタンスを検索し、各グループにおいて前記１つのイベントのルールインスタンスを含む最大１つの処理対象を検索する。
【００４０】
本実施例では、前記経路確立モジュールが確立した前記処理経路において、前記検索されたルールインスタンスが所在する処理ノードのアドレス指定情報は、前記検索されたルールインスタンスの識別を含み、または、前記検索されたルールインスタンスの識別とタイプを含み、作成されたルールインスタンスは、少なくとも１つの処理ルールに従って作成され、同じ処理ルールに従って作成されたルールインスタンスのタイプは同じであり、異なる処理ルールに従って作成されたルールインスタンスのタイプは異なる。
【００４１】
本実施例では、前記メッセージ送信モジュールが、前記最初のメッセージを前記処理ノードに送信することは、前記検索されたルールインスタンスのパラメータと識別を前記最初のメッセージに書き込み、最初のメッセージを前記処理ノードに送信すること、を含む。
【００４２】
本実施例では、前記経路確立モジュールが確立した前記処理経路は、複数の処理ノードのアドレス指定情報を含み、前記メッセージ送信モジュールは、前記検索されたルールインスタンスのパラメータと識別を携帯する前記最初のメッセージと、前記処理経路の１つ目の処理ノードの後の全ての処理ノードのアドレス指定情報と、を前記１つ目の処理ノードに送信するように設定される。
【００４３】
本実施例では、前記ルールインスタンスは、関連分析ルールに従って作成されたルールインスタンスを含む。
【００４４】
図４に示すように、本実施例は、ステップ２１０とステップ２２０を含む、処理ノードが実行するメッセージ処理方法をさらに提供する。
【００４５】
ステップ２１０において、処理ノードは、前処理ノードまたは１つ前の処理ノードが送信した１つのイベントのメッセージを受信する。
【００４６】
ステップ２２０において、前記処理ノードは、前記メッセージを前記１つのイベントの最初のメッセージとして確定することに応答し、前記処理ノードでの対応するルールインスタンスを利用して前記最初のメッセージを処理する。
【００４７】
本ステップの前記処理ノードでの「対応するルールインスタンス」は、すなわち上記の前処理ノードによって検索されたルールインスタンスであり、すなわち処理対象に含まれる１つのイベントのルールインスタンスである。本実施例では、１つのイベントはアラームイベントであり、ルールインスタンスは１つのイベントの最初のメッセージのみに対して関連分析を行う必要があり、１つのイベントの他のメッセージは配信のみを行う。しかし、本出願は、これに限定されるものではない。
【００４８】
本実施例では、シリアル配信方式を使用してメッセージを送信し、前記処理ノードは、前記１つのイベントのメッセージの受信に応答し、前記１つのイベントの処理経路の後続処理ノード（前記処理ノードの後の処理ノードを指す）のアドレス指定情報を受信し、前記処理ノードは、前記アドレス指定情報を受信した後、保存を行い、前記アドレス指定情報に基づいて前記後続処理ノードに前記最初のメッセージを送信し、前記処理ノードは、前記１つのイベントの後続メッセージを受信すると、保存された前記アドレス指定情報に基づき、前記後続処理ノードに前記後続メッセージを送信する。
【００４９】
本実施例では、前記処理ノードは、前記処理ノードでの対応するルールインスタンスを利用して前記最初のメッセージを処理した後、前記メッセージ処理方法は、前記最初のメッセージを処理する際に前記１つのイベントの新しいメッセージを生成することに応答し、その業務処理ロジックに基づき、前記新しいメッセージを前記１つのイベントのメッセージの収集を担当するデータソースに送信してもよいこと、をさらに含む。このように、１つのイベントのメッセージは、引き続き、元のデータソース、前処理ノード、および処理経路の処理ノードによって順番に処理される。
【００５０】
本実施例は、データソースと、前処理ノードと、処理ノードと、を含む、メッセージ処理システムであって、前記データソースは、１つのイベントの全てのメッセージを同じ前処理ノードに送信するように設定され、前記前処理ノードは、上述したいずれか１つの種類の前処理ノードであり、前記処理ノードは、前記前処理ノードが送信した前記１つのイベントのメッセージを受信し、前記メッセージを前記１つのイベントの最初のメッセージとして確定することに応答し、前記処理ノードでの前記検索されたルールインスタンスを利用して前記最初のメッセージを処理する、メッセージ処理システムをさらに提供する。
【００５１】
本実施例では、前記処理ノードは、前記１つのイベントのメッセージの受信に応答し、前記１つのイベントの処理経路の後続処理ノードのアドレス指定情報を受信し、前記メッセージが前記１つのイベントの最初のメッセージであると確定した後、前記処理ノードは、後続処理ノードのアドレス指定情報を保存し、前記アドレス指定情報に基づいて後続処理ノードに前記最初のメッセージを送信し、および、前記１つのイベントの後続メッセージの受信に応答し、保存された前記アドレス指定情報に基づき、前記後続処理ノードに前記後続メッセージを送信するようにさらに設定される。
【００５２】
本実施例では、前記処理ノードは、前記処理ノードでの対応するルールインスタンスを利用して前記最初のメッセージを処理した後、前記メッセージ処理方法は、前記最初のメッセージを処理する際に前記１つのイベントの新しいメッセージを生成することに応答し、前記新しいメッセージを前記１つのイベントのメッセージの収集を担当するデータソースに送信すること、をさらに含む。
【００５３】
本実施例では、前記ルールインスタンスは、関連分析ルールに従って作成されたルールインスタンスを含む。
【００５４】
本実施例は、メモリと、プロセッサと、前記メモリに記憶された前記プロセッサで動作可能なコンピュータプログラムと、を含むメッセージ処理装置であって、前記プロセッサが前記コンピュータプログラムを実行すると、本実施例のメッセージ処理方法の任意の処理を実現できることを特徴とする、メッセージ処理装置をさらに提供する。
【００５５】
本実施例のメッセージ処理は、ストリーム処理を使用し、メッセージの配信のためにメッセージの処理経路を動的に生成する。また、同じイベントのメッセージは、同じ処理経路に従って配信されるため、同じイベントの全てのメッセージの順番に従った処理が保証できる。
【００５６】
実施例２
本実施例は、メッセージの関連分析方法に関する。ストリーム処理方式で、メッセージの関連分析経路を動的に計算し、関連分析経路に従ってメッセージ配信に対して関連分析を行い、また、同じイベントの他の全てのメッセージを順番に従って処理することを保証する方法を提供する。
【００５７】
本実施例は、ネットワーク管理をアプリケーションシーンとし、該シーンは大量のアラームイベントに関連し、各アラームイベントは、複数のメッセージを生成し、これのメッセージは、イベント発生時に生成される発生メッセージと、例えばイベントの変更メッセージやクリアメッセージなどのイベント発生後に生成される後続メッセージとに分けてもよい。
【００５８】
同じイベントの異なるメッセージは同じキー値（ｋｅｙ）を有し、順番に従って処理される必要がある。
【００５９】
本実施例では、ユーザが迅速に有益な情報を得るために、イベントの最初のメッセージに対して関連分析を行い、すなわち、複数のイベントの間の関係を分析する。実際の応用では、さまざまな応用シーンが存在し、それぞれのシーンにおいて、関連ルールとして定義される独自の関連分析方法があってもよいため、異なるシーンは異なる関連ルールに対応してもよい。
【００６０】
本実施例では、１つのルールインスタンスは、以下の内容を定義する。
【００６１】
限定条件：ルールの処理対象を定義するために使用され、ルールの有効範囲を定義することであると言ってもよく、限定条件はどのイベントにルールが有効になるかを定義するが、ユーザが指定してもよく、例えば、ユーザが少なくとも１つのネットワークエレメント、少なくとも１つのアラームコード、少なくとも１つのアラームレベルなどをルールインスタンスの限定条件として定義してもよい。
【００６２】
業務処理ロジック：限定条件に該当するメッセージに対して関連分析を行う場合の処理ロジックを指す。
【００６３】
パラメータ：すなわち、ルールインスタンスが関連分析を実行する入力パラメータであり、ユーザによって指定されてもよく、例えば、アラーム遅延の時間であってもよい。
【００６４】
ユーザは、１つの関連ルールに従って少なくとも１つのルールインスタンスを作成してもよく、各ルールインスタンスの限定条件およびパラメータはユーザによって指定される。本実施例の方法により、あるルールインスタンスの限定条件に適合するメッセージ（すなわち、該メッセージは該ルールインスタンスの処理対象である）が、該ルールインスタンスが所在する関連分析ノードに配信されて一緒に分析され、イベントの間の関係が得られ、最後にユーザに示される。
【００６５】
図５を参照し、本実施例のメッセージの関連分析方法は２つの段階に分けられる。
【００６６】
前処理段階において、イベントの最初のメッセージが、システムにおいて作成された少なくとも１つのルールインスタンスの限定条件に適合するか否かを判断する。イベントの最初のメッセージは、システムにおいて作成された少なくとも１つのルールインスタンスの限定条件に適合するとの判断結果に基づき、関連分析経路を作成し、関連分析経路に従ってイベントの最初のメッセージとルールインスタンスのパラメータを対応する関連分析ノードに配信して第２段階の処理を行う。イベントの最初のメッセージは、システムにおいて作成された少なくとも１つのルールインスタンスの限定条件に適合しないとの判断結果に基づき、イベントはルールインスタンスによって処理されない。
【００６７】
関連分析処理において、関連分析ノードのルールインスタンスは、業務処理ロジックおよびパラメータに基づいて受信したイベントの最初のメッセージに対して関連分析を行う。
【００６８】
本実施例のメッセージの関連分析方法は、図６に示すように、ユーザが関連分析を行うための複数のルールインスタンスをシステムにおいて作成したと仮定すると、前記方法はステップ３１０からステップ３９０を含む。
【００６９】
ステップ３１０において、データソースは、イベントのメッセージを収集し、前処理ノードに送信する。
【００７０】
本実施例は、ストリーム処理フレームワークを基礎とし、イベントは複数のデータソースで収集され、同じイベントの全てのメッセージは同じデータソースで収集と配信が行われる。
【００７１】
ステップ３２０において、前処理ノードは、メッセージのタイプを判断し、メッセージのタイプはイベントの発生メッセージであるとの判断結果に基づき、ステップ３４０に移行し、メッセージのタイプはイベントの発生メッセージではないとの判断結果に基づき、ステップ３３０に移行する。
【００７２】
ステップ３３０において、メッセージのキー値に基づいてキャッシュからイベントの関連分析経路を取得し、ステップ３６０に移行する。
【００７３】
ステップ３４０において、作成されたルールインスタンスを取得し、これらのルールインスタンスは、対応する関連ルールに従って複数のグループに分けられ、同じ関連ルールに従って作成されたルールインスタンスは１つのグループに分けられ、メッセージを各グループのルールインスタンスの限定条件と順次比較し、各グループのルールインスタンスにおいて、前記メッセージのルールインスタンスを含む最大１つの処理対象を検索し、検索された全てのルールインスタンスの識別およびタイプを順番に並べ、関連分析経路を確立し、ルールインスタンスのパラメータとルールインスタンスの識別などの基本情報をメッセージに書き込む。
【００７４】
本ステップでは、処理対象が前記メッセージのルールインスタンスを含むことは、前記メッセージが該ルールインスタンスの限定条件に適合することを意味する。本ステップにおいて合計で複数のルールインスタンスを見つけた場合、該複数のルールインスタンスの識別およびタイプ（例えば、ルールインスタンスＡの識別およびタイプ、ルールインスタンスＢの識別およびタイプ、ルールインスタンスＣの識別およびタイプ）は、予め設定された並べ替え方法に従って並べられてもよい。１つのルールインスタンスの識別およびタイプは、該ルールインスタンスが所在する関連分析ノードのアドレス指定情報とし、具体的なアドレス指定プロセスは、ストリーム処理フレームワークが提供するメカニズムによって実現されてもよい。
【００７５】
本ステップでは、ルールインスタンスのパラメータは、送信される情報のフォーマットに依存し、個別の情報として送信されてもよい。
【００７６】
ステップ３５０において、前処理ノードは、関連分析経路とメッセージのキー値を関連付け、キャッシュに保存し、後続のメッセージに使用する。
【００７７】
ステップ３６０において、関連分析経路の次の関連分析ノードにメッセージを送信し、同時に関連分析経路の次の関連分析ノードの後の全ての関連分析ノードのアドレス指定情報をメッセージとともに送信する。
【００７８】
本ステップは、前処理ノードによって実行される場合、前記次の関連分析ノードは、すなわち関連分析経路の１つ目の関連分析ノードである。本ステップは、関連分析経路の１つの関連分析ノードによって実行される場合、前記次の関連分析ノードは、すなわち関連分析経路の該関連分析ノードの後の１つ目の関連分析ノードである。
【００７９】
ステップ３７０において、メッセージを受信した関連分析ノードは、メッセージのタイプを判断し、メッセージのタイプはイベントの発生メッセージであるとの判断結果に基づき、ステップ３８０に移行し、メッセージのタイプはイベントの発生メッセージではないとの判断結果に基づき、ステップ３９０に移行する。
【００８０】
ステップ３８０において、メッセージを受信した関連分析ノードは、メッセージに携帯されるルールインスタンスのパラメータを取得し、そのノードで動作されているルールインスタンスを用いてメッセージに対して関連分析を行う。
【００８１】
ステップ３９０において、メッセージを受信した関連分析ノードは、関連分析経路にさらに次の分析ノードのアドレス指定情報があるか否かを判断し、次のノードのアドレス指定情報がないとの判断結果に基づき、処理を終了し、次のノードのアドレス指定情報がまだあるとの判断結果に基づき、ステップ３６０に戻る。
【００８２】
実施例３
複数のアラームメッセージがレポートされる場合、いずれも同じ関連ルールの限定条件に適合すると、同じ関連分析ノードに配信され、以下、複数のアラームメッセージが同じ関連ルールの限定に適合する例で、該状況における関連分析処理を説明する。
【００８３】
図７を参照し、システムでは、同じ関連ルールに従って複数のルールインスタンスが作成されており、タイプの関連ルールとレポートされたアラームメッセージがいずれもそのうちの１つのルールインスタンスに適合し、処理フローはステップ１からステップ１２を含む。
【００８４】
ステップ１において、データソースＳ１は、アラームメッセージＡ１を受信する。
【００８５】
データソースはネットワークエレメントのアラーム収集モジュールであってもよい。
【００８６】
ステップ２において、データソースＳ１は、アラームメッセージＡ１のネットワークエレメント情報に基づいてアラームメッセージＡ１を前処理ノードＰ２に配信して処理する。
【００８７】
ステップ３において、前処理ノードＰ２は、アラームメッセージＡ１を受信した後、関連分析の前処理により、アラームメッセージＡ１がルールインスタンスＭ１の限定条件に適合することを見出し、関連分析経路［Ｍ１］を生成する。
【００８８】
関連分析経路［Ｍ１］は、関連分析ノードＭ１のアドレス指定情報を表し、具体的には、ルールインスタンスの識別およびタイプで表してもよく、Ｍはタイプを表し、１はＩＤを表し、後続の他の実施例はこれと同様である。
【００８９】
ステップ４において、前処理ノードＰ２は、関連分析経路に従ってアラームメッセージＡ１を関連分析ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【００９０】
上述した関連分析ノードとそのルールインスタンスは、例えば、ルールインスタンスＭ１が所在する関連分析ノードは、関連分析ノードＭ１と表すように、同じ識別を使用する。関連分析ノードＭ１に配信して処理することは、すなわち、関連分析ノードＭ１のルールインスタンスＭ１によってアラームメッセージＡ１に対して関連分析を行うことである。他の実施例はこれと同様である。
【００９１】
ステップ５において、データソースＳ２は、アラームメッセージＡ２を受信する。
【００９２】
ステップ６において、データソースＳ２は、アラームメッセージＡ２のネットワークエレメント情報に基づいてアラームメッセージＡ２を前処理ノードＰ３に配信して処理する。
【００９３】
ステップ７において、前処理ノードＰ３は、アラームメッセージＡ２を受信した後、関連分析の前処理により、アラームメッセージＡ２がルールインスタンスＭ１の限定条件に適合することを見出し、アラームメッセージＡ２の関連分析経路［Ｍ１］を生成する。
【００９４】
ステップ８において、前処理ノードＰ３は、関連分析経路に従ってアラームメッセージＡ２を関連分析ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【００９５】
ステップ９において、データソースＳ１は、アラームメッセージＡ３を受信する。
【００９６】
ステップ１０において、データソースＳ１は、アラームメッセージＡ３のネットワークエレメント情報に基づいてアラームメッセージＡ３を前処理ノードＰ１に配信して処理する。
【００９７】
ステップ１１において、前処理ノードＰ１は、アラームメッセージＡ３を受信した後、関連分析の前処理により、アラームメッセージＡ３がルールインスタンスＭ１の限定条件に適合することを見出し、アラームメッセージＡ３の関連分析経路［Ｍ１］を生成する。
【００９８】
ステップ１２において、前処理ノードＰ１は、関連分析経路に従ってアラームメッセージＡ３を関連分析ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【００９９】
実施例４
複数のアラームが複数の関連ルールに適合する場合、アラームメッセージは、それぞれ自身の関連分析経路に従って処理され、本実施例は、該シーンにおけるメッセージの関連分析方法を説明する。
【０１００】
図８を参照し、システムでは、複数の関連ルールに従って複数のグループのルールインスタンスが作成されており、図中のＭ１〜Ｍ３は１つのグループであり、Ｒ１〜Ｒ３は１つのグループであり、Ｃ１〜Ｃ３は１つのグループであり、レポートされたアラームメッセージがいずれもそのうちの少なくとも１つのルールインスタンスの限定条件に適合し、処理フローはステップ１からステップ１２を含む。
【０１０１】
ステップ１において、データソースＳ１は、アラームメッセージＡ１を受信する。
【０１０２】
ステップ２において、データソースＳ１は、アラームメッセージＡ１のネットワークエレメント情報に基づいてアラームメッセージＡ１を前処理ノードＰ２に配信して処理する。
【０１０３】
ステップ３において、前処理ノードＰ２は、アラームメッセージＡ１を受信した後、関連分析の前処理により、アラームメッセージＡ１がルールインスタンスＭ１、Ｒ２、Ｃ２の限定条件に適合することを見出し、アラームメッセージＡ１の関連分析経路［Ｍ１、Ｒ２、Ｃ２］を生成する。
【０１０４】
ステップ４において、前処理ノードＰ２は、関連分析経路に従ってアラームメッセージＡ１を関連分析ノードＭ１に送信して処理し、Ｍ１は関連分析ノードＲ２にメッセージをさらに送信して処理し、Ｒ２は関連分析ノードＣ２にさらに送信して処理し、その後、後続の処理フローを継続する。
【０１０５】
ステップ５において、データソースＳ２は、アラームメッセージＡ２を受信する。
【０１０６】
ステップ６において、データソースＳ２は、アラームメッセージＡ２のネットワークエレメント情報に基づいてアラームメッセージＡ２を前処理ノードＰ３に配信して処理する。
【０１０７】
ステップ７において、前処理ノードＰ３は、アラームメッセージＡ２を受信した後、関連分析の前処理により、アラームメッセージＡ２がルールインスタンスＭ２、Ｒ２、Ｃ１の限定条件に適合することを見出し、アラームメッセージＡ２の関連分析経路［Ｍ２、Ｒ２、Ｃ１］を生成する。
【０１０８】
ステップ８において、前処理ノードＰ３は、関連分析経路に従ってアラームメッセージＡ２を関連分析ノードＭ２に送信して処理し、Ｍ２は関連分析ノードＲ２にメッセージをさらに送信して処理し、Ｒ２は関連分析ノードＣ１にメッセージをさらに送信して処理し、その後、後続の処理フローを継続する。
【０１０９】
ステップ９において、データソースＳ１は、アラームメッセージＡ３を受信する。
【０１１０】
ステップ１０において、データソースＳ１は、アラームメッセージＡ３のネットワークエレメント情報に基づいてアラームメッセージＡ３を前処理ノードＰ１に配信して処理する。
【０１１１】
ステップ１１において、前処理ノードＰ１は、アラームメッセージＡ３を受信した後、関連分析の前処理により、アラームメッセージＡ３がルールインスタンスＭ１、Ｃ２の限定条件に適合することを見出し、アラームメッセージＡ３の関連分析経路［Ｍ１、Ｃ２］を生成する。
【０１１２】
ステップ１２において、前処理ノードＰ１は、関連分析経路に従ってアラームメッセージＡ３を関連分析ノードＭ１に送信して処理し、Ｍ１は関連分析ノードＣ２にメッセージをさらに送信して処理し、その後、後続の処理フローを継続する。
【０１１３】
実施例５
１つのアラームのレポートメッセージについて、関連分析経路を生成した後、該アラームの後続の全てのメッセージは、該関連分析経路に従って処理され、この例は同じ１つのアラームの異なるメッセージを例にしてメッセージの関連分析を説明する。
【０１１４】
図９を参照し、システムでは、複数のルールインスタンスが作成されており、レポートされたアラームがそのうちの１つのルールインスタンスに適合し、処理フローはステップ１からステップ１２を含む。
【０１１５】
ステップ１において、データソースＳ１は、アラームメッセージＡ１を受信する。
【０１１６】
ステップ２において、データソースＳ１は、アラームメッセージＡ１を生成したネットワークエレメントの情報に基づいてアラームメッセージＡ１を前処理ノードＰ２に送信して処理する。
【０１１７】
ステップ３において、前処理ノードＰ２は、関連分析の前処理により、アラームメッセージＡ１がルールインスタンスＭ１の限定条件に適合することを見出し、アラームメッセージＡ１の関連分析経路［Ｍ１］を生成する。
【０１１８】
ステップ４において、前処理ノードＰ２は、関連分析経路に従ってアラームメッセージＡ１を関連分析ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【０１１９】
ステップ５において、データソースＳ１は、アラームメッセージＡ１が属するアラームの変更メッセージＣ１を受信する。
【０１２０】
ステップ６において、データソースＳ１は、Ｃ１を生成したネットワークエレメントの情報に基づいてＣ１を前処理ノードＰ２に送信して処理する。
【０１２１】
ステップ７において、前処理ノードＰ２は、クエリにより、アラームメッセージＡ１の関連分析経路［Ｍ１］を取得する。
【０１２２】
ステップ８において、前処理ノードＰ２は、関連分析経路に従ってＣ１を関連処理ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【０１２３】
ステップ９において、データソースＳ１は、アラームメッセージＡ１が属するアラームのクリアメッセージＤ１を受信する。
【０１２４】
ステップ１０において、データソースＳ１は、Ｄ１を生成したネットワークエレメントの情報に基づいてＤ１を前処理ノードＰ２に送信して処理する。
【０１２５】
ステップ１１において、前処理ノードＰ２は、クエリにより、アラームメッセージＡ１の関連分析経路［Ｍ１］を取得する。
【０１２６】
ステップ１２において、前処理ノードＰ２は、関連分析経路に従ってＤ１を関連分析ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【０１２７】
実施例６
アラームメッセージに対して関連分析を行う処理過程において、新しいメッセージが生成される可能性があり、この例では、このような状況について関連する処理過程を説明する。
【０１２８】
図１０を参照し、システムでは、関連分析に使用される複数のルールインスタンスが作成されており、レポートされたアラームがそのうちの１つのルールインスタンスに適合すると仮定し、関連する処理フローはステップ１からステップ８を含む。
【０１２９】
ステップ１において、データソースＳ１は、アラームメッセージＡ１を受信する。
【０１３０】
ステップ２において、データソースＳ１は、アラームメッセージＡ１を生成したネットワークエレメントの情報に基づいてアラームメッセージＡ１を前処理ノードＰ２に送信して処理する。
【０１３１】
ステップ３において、前処理ノードＰ２は、関連分析の前処理により、アラームメッセージＡ１がルールインスタンスＭ１の限定条件に適合することを見出し、アラームメッセージＡ１の関連分析経路［Ｍ１］を生成する。
【０１３２】
ステップ４において、前処理ノードＰ２は、関連分析経路に従ってアラームメッセージＡ１を関連分析ノードＭ１に送信して処理し、アラームメッセージＡ１は、関連分析ノードＭ１の処理を経て、アラームメッセージＡ１が属するアラームの１つの新しい変更メッセージＣ１を生成する。
【０１３３】
ステップ５において、関連分析ノードＭ１は、変更メッセージＣ１をデータソースＳ１に送信して処理する。
【０１３４】
ステップ６において、データソースＳ１は、アラームメッセージＡ１を生成したネットワークエレメントの情報に基づいて変更メッセージＣ１を配信し、変更メッセージＣ１を前処理ノードＰ２に送信して処理する。
【０１３５】
ステップ７において、前処理ノードＰ２は、検索により、アラームメッセージＡ１の関連分析経路［Ｍ１］を得る。
【０１３６】
ステップ８において、前処理ノードＰ２は、検索された関連分析経路に従って変更メッセージＣ１を関連分析ノードＭ１に送信して処理し、その後、後続の処理フローを継続する。
【０１３７】
ストリーム処理フレームワークにおいて、各関連分析ノードは、いずれもメッセージ指向ミドルウェア（ＭＯＭ：Ｍｅｓｓａｇｅ  Ｏｒｉｅｎｔｅｄ  Ｍｉｄｄｌｅｗａｒｅ）を介してデータソースにメッセージを送信してもよい。
【０１３８】
実施例７
本実施例のメッセージはニュースデータであり、本実施例はニュースデータの関連分析に関する。
【０１３９】
図１１を参照し、この例では、システムの複数のデータソースは、いずれもニュースデータを取得してもよく、各ニュースデータは、異なるイベントに属し、異なるキー値で識別され、処理フローは、ステップ１からステップ１２を含む。
【０１４０】
ステップ１において、データソースＳ１は、ニュースデータＮ１を取得する。
【０１４１】
ステップ２において、データソースＳ１は、ニュースデータＮ１のキー値に基づいてニュースデータＮ１を前処理ノードＰ２に配信して処理する。
【０１４２】
ステップ３において、前処理ノードＰ２は、関連分析の前処理により、ニュースデータＮ１がルールインスタンスＭ１、Ｅ３の限定条件に適合することを見出し、ニュースデータＮ１の関連分析経路［Ｍ１、Ｅ３］を生成する。
【０１４３】
ステップ４において、前処理ノードＰ２は、関連分析経路に従ってニュースデータＮ１を関連分析ノードＭ１に送信して処理し、関連分析ノードＭ１は関連分析ノードＥ３にメッセージをさらに送信して処理し、その後、後続の処理フローを継続する。
【０１４４】
ステップ５において、データソースＳ３は、ニュースデータＮ２を取得する。
【０１４５】
ステップ６において、データソースＳ３は、ニュースデータＮ２のキー値に基づいて前処理ノードＰ１に配信して処理する。
【０１４６】
ステップ７において、前処理ノードＰ１は、関連分析の前処理により、ニュースデータＮ２がルールインスタンスＭ２、Ｅ３の限定条件に適合することを見出し、ニュースデータＮ１の関連分析経路［Ｍ２、Ｅ３］を生成する。
【０１４７】
ステップ８において、前処理ノードＰ１は、関連分析経路に従ってニュースデータＮ２を関連分析ノードＭ２に送信して処理し、関連分析ノードＭ２は関連分析ノードＥ３にニュースデータＮ２をさらに送信して処理し、その後、後続の処理フローを継続する。
【０１４８】
ステップ９において、データソースＳ２は、ニュースデータＮ３を取得する。
【０１４９】
ステップ１０において、データソースＳ２は、ニュースデータＮ３のキー値に基づいてニュースデータＮ３を前処理ノードＰ１に配信して処理する。
【０１５０】
ステップ１１において、前処理ノードＰ１は、関連分析の前処理により、ニュースデータＮ３がルールインスタンスＭ１、Ｅ１の限定条件に適合することを見出し、ニュースデータＮ３の関連分析経路［Ｍ１、Ｅ１］を生成する。
【０１５１】
ステップ１２において、前処理ノードＰ１は、関連分析経路に従ってニュースデータＮ３を関連分析ノードＭ１に送信して処理し、関連分析ノードＭ１は関連分析ノードＥ１にニュースデータＮ３をさらに送信して処理し、その後、後続の処理フローを継続する。
【０１５２】
同じイベントのニュースデータについて、メッセージを変更することに相当する、後続の追加記事が存在する可能性があり、この場合、上述した実施例と同様な方式に従って処理してもよい。
【０１５３】
当業者であれば、上記で開示された方法の全てまたはいくつかのステップ、システム、装置内の機能モジュール／ユニットは、ソフトウェア、ファームウェア、ハードウェア、およびそれらの適切な組み合わせによって実施されてもよいことを理解できる。ハードウェアの実施形態では、上述した説明で述べた機能モジュール／ユニット間の区分は、必ずしも物理的コンポーネントの区分に対応していなく、例えば、１つの物理的コンポーネントは、複数の機能を有してもよく、または、１つの機能またはステップは、いくつかの物理的コンポーネントによって共同で実行されてもよい。いくつかの物理的コンポーネントまたは全ての物理的コンポーネントは、例えば、中央プロセッサ、デジタル信号プロセッサまたはマイクロプロセッサなどのプロセッサによって実行されるソフトウェアとして実施されてもよく、またはハードウェアとして実施されてもよく、または専用集積回路のような集積回路として実施されてもよい。このようなソフトウェアは、コンピュータ可読媒体に分布してもよく、コンピュータ可読媒体は、コンピュータ記憶媒体（または非一時的媒体）および通信媒体（または一時的媒体）を含んでもよい。当業者に知られているように、用語のコンピュータ記憶媒体は、情報（例えば、コンピュータ可読命令、データ構造、プログラムモジュールまたは他のデータ）を格納するための任意の方法または技術で実施される揮発性および不揮発性、リムーバブルおよび非リムーバブルの媒体を含む。コンピュータ記憶媒体は、ランダムアクセスメモリ（Ｒａｎｄｏｍ  Ａｃｃｅｓｓ  Ｍｅｍｏｒｙ、ＲＡＭ）、読み取り専用メモリ（Ｒｅａｄ  Ｏｎｌｙ  Ｍｅｍｏｒｙ、ＲＯＭ）、電気的消去可能プログラマブル読取り専用メモリ（Ｅｌｅｃｔｒｉｃａｌｌｙ  Ｅｒａｓａｂｌｅ  Ｐｒｏｇｒａｍｍａｂｌｅ  Ｒｅａｄ−Ｏｎｌｙ  Ｍｅｍｏｒｙ、ＥＥＰＲＯＭ）、フラッシュメモリまたは他のメモリ技術、コンパクトディスク読み取り専用メモリ（Ｃｏｍｐａｃｔ  Ｄｉｓｃ  Ｒｅａｄ−Ｏｎｌｙ  Ｍｅｍｏｒｙ、ＣＤ−ＲＯＭ）、デジタルビデオディスク（Ｄｉｇｉｔａｌ  Ｖｉｄｅｏ  Ｄｉｓｃ、ＤＶＤ）または他の光ディスク記憶、磁気カートリッジ、磁気テープ、磁気ディスク記憶または他の磁気記憶装置、または所望の情報を記憶するために使用されてコンピュータによってアクセスできる他の任意の媒体を含むが、これらに限定されない。さらに、当業者に知られているように、通信媒体は、一般に、コンピュータ可読命令、データ構造、プログラムモジュール、または搬送波または他の伝送機構のような変調データ信号の他のデータを含み、任意の情報配信媒体を含むことができる。
【図１】
2021524085.tif 000003
【図２】
2021524085.tif 000004
【図３】
2021524085.tif 000005
【図４】
2021524085.tif 000006
【図５】
2021524085.tif 000007
【図６】
2021524085.tif 000008
【図７】
2021524085.tif 000009
【図８】
2021524085.tif 000010
【図９】
2021524085.tif 000011
【図１０】
2021524085.tif 000012
【図１１】
2021524085.tif 000013
【国際調査報告】
2021524085.tif 000014
2021524085.tif 000015
2021524085.tif 000016
2021524085.tif 000017