JP7193035B1 - データ処理システム、データ提供システム、イベント情報生成装置、データ処理装置、データ処理方法、及びプログラム - Google Patents

Abstract

データ処理システムにおいて、複数の端末から収集されたデータを受信し、当該データからイベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、当該イベント情報に対応するデータを送信する送信手段と、を備えるイベント情報生成装置と、特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得手段と、前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応するデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段と、を備えるデータ処理装置と、を備える。

Description

本発明は、複数の端末から収集されたデータに対する処理を実行する技術に関連するものである。

近年、あらゆるセンサ情報等のデータが収集され、そのデータを分析することにより、犯罪防止、事故防止、混雑、需要予測といった様々な社会課題の解決に利用されている。

例えば、非特許文献１には、監視カメラ映像をリアルタイムに解析して、混雑を高精度に予測する技術が開示されている。

https://monoist.atmarkit.co.jp/mn/articles/1608/18/news119.html、ＮＴＴ東日本ギガらくカメラ

以下、発明が解決しようとする課題について説明する。

多数のセンサ情報を収集して分析するサービスを提供するシステムに関して、従来技術では、特定の限られた目的のために設計・構築される。そのため、ある目的のためのサービスを提供したい場合には、その目的に応じてカメラ等のインフラを構築し、取得した映像等のセンサデータの分析を行うシステムをそのサービスのために個別に構築する必要があった。

例えば、アプリケーションサーバにより、社会の動向に応じて、新たなサービスを提供しようとする場合には、データ収集・分析のシステムから構築しなければならなかった。すなわち、従来技術では、複数の端末から収集されたデータを利用して、多様な任意のサービスを提供することが難しいという課題があった。

本発明は上記の課題に鑑みてなされたものであり、複数の端末から収集されたデータを利用して、多様な任意のサービスを容易に提供することを可能とする技術を提供することを目的とする。

開示の技術によれば、端末から収集されたデータを受信し、当該データに対する分析を行い、分析結果に基づいて、イベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、前記分析結果に基づいて当該イベント情報に対応づけられたデータを送信する送信手段と、を備えるイベント情報生成装置と、
特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得手段と、前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応づけられたデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段と、を備えるデータ処理装置と、
を備えるデータ処理システムが提供される。

開示の技術によれば、複数の端末から収集されたデータを利用して、多様な任意のサービスを容易に提供することを可能とする技術が提供される。

ＲＤＭＡの概要を説明するための図である。 ＲＤＭＡの概要を説明するための図である。 ＲＤＭＡの概要を説明するための図である。 ＲＤＭＡの概要を説明するための図である。 ＲＤＭＡの概要を説明するための図である。 ＲＤＭＡの概要を説明するための図である。 ＲＤＭＡの概要を説明するための図である。 第１実施形態における通信システムの全体構成例を示す図である。 実施イメージを説明するための図である。 課題を説明するための図である。 実現モデルを説明するための図である。 第１実施形態における通信システムの機能構成例を示す図である。 第１実施形態における通信システムの機能構成例を示す図である。 第１実施形態における通信システムの動作例を説明するための図である。 第２実施形態におけるデータ処理システムの全体構成例を示す図である。 エッジノード装置の構成図である。 メッセージブローカ装置の構成図である。 データハブノード装置の構成図である。 ＡＩアプリノード装置の構成図である。 第２実施形態におけるデータ処理システムの動作例を説明するための図である。 第２実施形態におけるデータ処理システムの具体例を説明するための図である。 装置のハードウェア構成例を示す図である。

以下、図面を参照して本発明の実施の形態を説明する。以下で説明する実施の形態は一例に過ぎず、本発明が適用される実施の形態は、以下の実施の形態に限られるわけではない。

以下、第１実施形態と第２実施形態を説明する。

第１実施形態と第２実施形態ともに、データ通信方式としてＲＤＭＡを使用していることから、まず、ＲＤＭＡの概要を説明する。なお、以下のＲＤＭＡの概要について、ＲＤＭＡの説明のための便宜上、従来技術を示しているが、本実施の形態で用いるＲＤＭＡが以下で説明する従来のＲＤＭＡと同一である必要はない。メモリ間でＣＰＵを介さずに直接に通信を行うことができる方式であれば、以下のＲＤＭＡの概要で説明する方式以外の方式を使用してもよい。

（ＲＤＭＡの概要）
ＲＤＭＡでは、イーサネット等のＮＩＣに相当するハードウェア（本実施の形態ではＲＤＭＡ－ＮＩＣと呼ぶ）を使用する。

送信側のＲＤＭＡ－ＮＩＣは、予め確保されたメモリ領域からＤＭＡでデータを読み込んで、受信側のＲＤＭＡ－ＮＩＣに転送する。受信側のＲＤＭＡ－ＮＩＣは、同様に予め確保されたメモリ領域に対して受信したデータをＤＭＡで書き込む。これにより、異なるノードのユーザ空間アプリケーション同士がゼロコピーでの通信を行うことが可能となる。ＲＤＭＡでは、ネットワークのプロトコルはＲＤＭＡ－ＮＩＣ（ハードウェア）に実装されており、これによりノードに設置された通信装置におけるＯＳ層のＣＰＵリソースの消費が抑えられるとともに、低レイテンシの通信を実現している。

また、従来のＯＳ層のネットワークスタックを利用したＴＣＰやＵＤＰの通信ではソケットによって通信を行うのに対し、ＲＤＭＡではＱｕｅｕｅ Ｐａｉｒ（ＱＰ）によって通信を行う。

ＱＰは、ＲＤＭＡ－ＮＩＣによって提供される仮想的なインタフェースであり、Ｓｅｎｄ Ｑｕｅｕｅ（ＳＱ）とＲｅｃｅｉｖｅ Ｑｕｅｕｅ（ＲＱ）のペアからなる。ＳＱやＲＱには、それぞれデータ送信、データ受信に関わるデータが格納されている。これには、データを格納するメモリ領域のアドレスや、その長さの情報などが含まれる。メモリ領域としては、仮想メモリアドレスや物理メモリアドレスが使用される。

図１に示すように、ＲＤＭＡ－ＮＩＣを使用する場合には、ＲＤＭＡ－ＮＩＣにアクセスさせるメモリ領域をＭｅｍｏｒｙ ＲｅｇｉｏｎとしてＯＳに登録する。また、Ｍｅｍｏｒｙ ｒｅｇｉｏｎの登録時に仮想メモリアドレスと物理メモリアドレスの変換表を作り、これをＲＤＭＡ－ＮＩＣに渡すことで、ＲＤＭＡ－ＮＩＣは、ユーザプログラム（ＡＰＰ）の仮想メモリアドレス空間の一部を認識できるようになる。ＲＤＭＡ－ＮＩＣは送信時と受信時においてこの変換表を参照して、アクセスすべき物理メモリアドレスを決定できる。そのため、ノードに設置された通信装置におけるＯＳ層のＣＰＵの使用を最小限に抑えたデータ転送が可能である。

なお、上記のようにメモリ領域として仮想メモリアドレスを使用することは一例である。メモリ領域として物理メモリアドレスを使用することとしてもよい。物理メモリアドレスを使用したメモリ領域はＰＡ－ＭＲ（Physical Address Memory Region）と呼ばれる。ＰＡ－ＭＲを使用する場合、データを格納するメモリ領域の物理メモリアドレスやその長さの情報を含む送信要求／受信要求がＳＱ／ＲＱに格納され、当該送信要求／受信要求に基づいて物理メモリアドレスにアクセスすることができる。

＜Ｔｒａｎｓｐｏｒｔ Ｌａｙｅｒの基本モデル＞
次に、ＬｏｃａｌノードとＲｅｍｏｔｅノードの間でのＲＤＭＡにおけるＴｒａｎｓｐｏｒｔ Ｌａｙｅｒの通信モデルについて、図２を参照して説明する。図２に示すように、ＲＤＭＡのＴｒａｎｓｐｏｒｔ Ｌａｙｅｒでは、ＬｏｃａｌとＲｅｍｏｔｅの間でＱＰ（Ｑｕｅｕｅ Ｐａｉｒ）を構成する。前述したとおり、ＱＰはＳＱ（Ｓｅｎｄ Ｑｕｅｕｅ）とＲＱ（Ｒｅｃｅｉｖｅ Ｑｕｅｕｅ）のセットである。

ＲＤＭＡの通信単位はＷＲ（Ｗｏｒｋ Ｒｅｑｕｅｓｔ）と呼ばれる通信要求であり、ＷＱＥ（Ｗｏｒｋ Ｑｕｅｕｅ Ｅｌｅｍｅｎｔ）という単位でＳＱ／ＲＱに積まれる。このＷＱを積む動作は、ユーザプログラム（図１に示すＡＰＰ）からの命令により行われる。通信要求に対する送信／受信の動作は、ＲＤＭＡ－ＮＩＣにより、ＷＱを積む動作とは非同期に行われる。

ＷＲには、送信要求であるＳｅｎｄ ＷＲ、受信要求であるＲｅｃｅｉｖｅ ＷＲがある。Ｓｅｎｄ ＷＲでは、送信したいデータのメモリ領域をＷＱＥに指定してＳＱへ積む。Ｒｅｃｅｉｖｅ ＷＲでは、データを受信したいメモリ領域をＷＱＥに指定してＲＱへ積む。ＷＱＥはＳＱ／ＲＱのＱｕｅｕｅ ｄｅｐｔｈの数だけＦＩＦＯ（Ｆｉｒｓｔ－Ｉｎ－Ｆｉｒｓｔ－Ｏｕｔ）で積むことができる。

ＱＰの間でＷＲの処理が正常に完了すると、ＳＱ／ＲＱのそれぞれに対応したＣＱ（Ｃｏｍｐｌｅｔｉｏｎ Ｑｕｅｕｅ）に、正常完了を示すＣＱＥ（Ｃｏｍｐｌｅｔｉｏｎ Ｑｕｅｕｅ Ｅｎｔｒｙ）が積まれる。ＱＰの間でＷＲの処理がエラーで終了すると、ＣＱにはエラーを示すＣＱＥが積まれる。正常完了のＣＱＥを確認すると、ＳＱ／ＲＱのＷＱＥは削除され、次のＷＲの受け入れが可能になる。

＜ＲＤＭＡにおけるサービスタイプ、オペレーションタイプ＞
ＲＤＭＡにおけるサービスタイプは、Ｒｅｌｉａｂｌｅ／Ｕｎｒｅｌｉａｂｌｅ、Ｃｏｎｎｅｃｔｉｏｎ／Ｄａｔａｇｒａｍの区分により、Ｒｅｌｉａｂｌｅ Ｃｏｎｎｅｃｔｉｏｎ（ＲＣ）、Ｒｅｌｉａｂｌｅ Ｄａｔａｇｒａｍ（ＲＤ）、Ｕｎｒｅｌｉａｂｌｅ Ｃｏｎｎｅｃｔｉｏｎ（ＵＣ）、Ｕｎｒｅｌｉａｂｌｅ Ｄａｔａｇｒａｍ（ＵＤ）の４つのサービスタイプに大別される。一般に使用されるのは、このうちＲＣとＵＤである。

ＲＣは、ＡＣＫ／ＮＡＫによる通信の成功・異常の確認と再送の仕組みによって、メッセージの順序性と到達性を保証するものである。また、Ｃｏｎｎｅｃｔｉｏｎ型でもあり、Ｌｏｃａｌ－ＲｅｍｏｔｅのＱＰ間で１対１の通信を行う。

ＵＤには、確認応答や再送の仕組みはないものの、ＲＣと異なり、通信ごとに宛先を指定して複数のＱＰへの送信や複数のＱＰからの受信といった多対多の通信が可能である。

ＲＤＭＡにおけるオペレーションタイプは、ＳＥＮＤ、ＲＤＭＡ ＷＲＩＴＥ（ｗｉｔｈ Ｉｍｍｅｄｉａｔｅ）、ＲＤＭＡ ＲＥＡＤ、ＡＴＯＭＩＣ Ｏｐｅｒａｔｉｏｎｓの４つのオペレーションタイプに大別される。ＲＣではこれら全てが使用でき、ＵＤではＳＥＮＤのみ使用できる。同じオペレーションタイプでも、サービスタイプによってＷＱＥやＣＱＥの積まれ方が異なる。

本実施の形態（第１実施形態、第２実施形態）におけるＲＤＭＡ通信においては、いずれのサービスタイプ及びオペレーションタイプでも使用可能である。以下、各オペレーションタイプを説明する。

＜ＳＥＮＤ動作方式（ＲＣ）＞
図３にＳＥＮＤ動作方式（ＲＣ）の動作概要を示す。ＳＥＮＤ動作方式（ＲＣ）は、ＲＤＭＡの基本的な送受信モデルであり、Ｌｏｃａｌ側がＲｅｍｏｔｅ側へデータを送信するモデルである。

図３に示すとおり、Ｌｏｃａｌ側はＳＱ、Ｒｅｍｏｔｅ側はＲＱを用意し、それぞれＷＱＥを積む。Ｌｏｃａｌ側は、ＳＱのＷＱＥを先頭から取り出して、その中に指定されたメモリ領域のデータをＳＥＮＤ Ｏｎｌｙで送信する。

Ｒｅｍｏｔｅ側で受信したデータについては、ＲＱのＷＱＥを先頭から取り出して、その中に指定されたメモリ領域に格納する。受信が成功すると、ＲＱに対応したＣＱにＣＱＥが積まれ、Ｌｏｃａｌ側へＡＣＫを返す。Ｌｏｃａｌ側がＡＣＫを受信すると、ＣＱＥが積まれ、ＳＱのＷＱＥが解放される。

＜ＳＥＮＤ動作方式（ＵＤ）＞
図４は、ＳＥＮＤ動作方式（ＵＤ）の動作概要を示す。ＳＥＮＤ動作方式（ＵＤ）は、ＲＣのＳＥＮＤと異なり、確認応答を行わない方式である。図４に示すとおり、Ｌｏｃａｌ側はＳＱ、Ｒｅｍｏｔｅ側はＲＱを用意し、それぞれＷＱＥを積む。通信の準備ができると、Ｌｏｃａｌ側はＳＥＮＤ Ｏｎｌｙでデータを送信する。データを送信完了すると、ＳＱに対応するＣＱにＣＱＥが積まれる。Ｒｅｍｏｔｅ側で受信が成功すると、ＲＱに対応したＣＱにＣＱＥが積まれる。

＜ＲＤＭＡ ＷＲＩＴＥ動作方式（ＲＣ）＞
図５は、ＲＤＭＡ ＷＲＩＴＥ動作方式（ＲＣ）の動作概要を示す。ＲＤＭＡ ＷＲＩＴＥ動作方式（ＲＣ）は、ＳＥＮＤと同様にＬｏｃａｌ側がＲｅｍｏｔｅ側へデータを送信する方式であるが、Ｒｅｍｏｔｅのメモリ領域へ直接転送する点がＳＥＮＤと異なる。

Ｌｏｃａｌ側はＳＱを用意しＷＱＥを積む。この時、ＷＱＥには送信したいデータのメモリ領域に加えて、書き込みを行いたいＲｅｍｏｔｅ側のメモリ領域も指定する。Ｒｅｍｏｔｅ側はＲＤＭＡ用のメモリ領域（Ｍｅｍｏｒｙ Ｒｅｇｉｏｎ）を確保するが、ＲＱにＷＱＥを積む必要はない。

通信の準備ができると、Ｌｏｃａｌ側はＲＤＭＡ Ｗｒｉｔｅでデータを送信する。データはＲｅｍｏｔｅ側のメモリ領域へ直接書き込まれる。Ｒｅｍｏｔｅ側で受信が成功すると、Ｌｏｃａｌ側へＡＣＫが返る。Ｌｏｃａｌ側がＡＣＫを受信すると、ＣＱＥが積まれ、ＳＱのＷＱＥが解放される。

＜ＲＤＭＡ ＷＲＩＴＥ ｗ／Ｉｍｍ動作方式（ＲＣ）＞
図６は、ＲＤＭＡ ＷＲＩＴＥ ｗ／Ｉｍｍ動作方式（ＲＣ）の動作概要を示す。図５を参照して説明したＲＤＭＡ ＷＲＩＴＥには、データ受信時にＲｅｍｏｔｅ側がメモリ領域の変更を検知できない不都合がある。

これに対して、図６に示すＲＤＭＡ ＷＲＩＴＥ ｗ／Ｉｍｍ（ＲＤＭＡ ＷＲＩＴＥ ｗｉｔｈ Ｉｍｍｅｄｉａｔｅ）方式では、Ｒｅｍｏｔｅ側でＲＱとＷＱＥを設定し、ＲＤＭＡ ＷＲＩＴＥの受信成功時のＣＱＥを待つことで対処する。

Ｌｏｃａｌ側のＳＱのＷＱＥには、送信したいデータのメモリ領域、書き込みを行いたいＲｅｍｏｔｅ側のメモリ領域に加え、特殊フィールドｉｍｍ＿ｄａｔａを設定する。Ｒｅｍｏｔｅ側で受信が成功した時、ＲＱに対応したＣＱにはｉｍｍ＿ｄａｔａを含んだＣＱＥが積まれる。これを用いて任意のメモリ領域の変更を検知することが可能である。

＜ＲＤＭＡ ＲＥＡＤ動作方式（ＲＣ）＞
図７は、ＲＤＭＡ ＲＥＡＤ動作方式（ＲＣ）の概要を示す。図７に示すように、ＲＤＭＡ ＲＥＡＤ動作方式（ＲＣ）は、Ｒｅｍｏｔｅ側からＬｏｃａｌ側へデータを引き込む方式である。

Ｌｏｃａｌ側はＳＱを用意しＷＱＥを積む。この時、ＷＱＥにはデータを受信したいメモリ領域を指定する。さらに、読み込みを行いたいＲｅｍｏｔｅ側のメモリ領域も指定する。Ｒｅｍｏｔｅ側はＲＤＭＡ用のメモリ領域（Ｍｅｍｏｒｙ Ｒｅｇｉｏｎ）を確保するが、ＲＱにＷＱＥを積む必要はない。

通信の準備ができると、Ｌｏｃａｌ側はＲＤＭＡ Ｒｅａｄ Ｒｅｑｕｅｓｔでデータ読み込みを要求する。Ｒｅｍｏｔｅ側がこれを受信すると、設定されたＬｏｃａｌ側のメモリ領域に対してＲｅｍｏｔｅ側のメモリ領域のデータをＲＤＭＡ Ｒｅａｄ Ｒｅｓｐｏｎｓｅで直接送る。ＲＤＭＡ Ｒｅａｄ ＲｅｓｐｏｎｓｅのパケットにはＡＣＫ拡張ヘッダが含まれており、Ｌｏｃａｌ側がこのＡＣＫを受信すると、ＣＱＥが積まれ、ＳＱのＷＱＥが解放される。

以下、第１実施形態と第２実施形態について説明する。

（第１実施形態）
まず、第１実施形態を説明する。図８に、第１実施形態における通信システムの全体構成図を示す。

図８に示すように、本通信システムは、複数の端末を接続するローカル集約ノード（ＬＡ）、複数のローカル集約ノード（ＬＡ）を接続する地域エッジノード（ＲＥ）、及び、アプリノード（ＡＰ）を有する。

第１実施形態では、端末はカメラであることを想定している。地域エッジノード（ＲＥ）は、東京、大阪といった各地域に設置されることを想定している。地域毎に複数のローカル集約ノード（ＬＡ）が存在し、各ローカル集約ノード（ＬＡ）が複数の端末（例えばカメラ）を収容している。各ノード間は、例えば、光ネットワークにより接続される。

＜動作概要、課題等＞
第１実施形態では、図８に示すシステム構成により、例えば、多カメラ多目的ＡＩプラットフォームを構成することを想定している。なお、このような想定は第２実施形態でも同様である。

具体的には、当該プラットフォームにおいて、商業ビルやオフィスビルに多数のカメラを設置して、カメラから収集された画像データを分析する。分析の内容としては、例えば、エリアに存在する人数をカウントし、混雑回避、避難誘導等に役立てる。また、属性も含めて人数をカウントすることで、需要予測、在庫・店員配置最適化、イベント等の効果の分析、及びイベント・広告の立案等を行うことができる。また、怪しい行動の人間を検出することで、防犯に役立てることができる。

また、次世代の街づくりという観点で、道に多数のカメラを設置することで、Ｍｉｃｒｏｍｏｂｉｌｉｔｙ車両の自動制御、交差点での出会い衝突防止、人が多いところにＭｉｃｒｏｍｏｂｉｌｉｔｙ車両を自動配車する等を実現することも可能になる。

より具体的には、例えば図９に示すように、５０ｍ幅で格子状に道がある５００ｍ×５００ｍの街区を想定し、１０ｍおきにカメラを下記の仕様で設置する。

・接続方式：有線イーサネット（登録商標）
・解像度：フルＨＤ（Ｒａｗで２ＭＢ）
・フレームレート：１５ＦＰＳ
・符号化：Ｍｏｔｉｏｎ ＪＰＥＧ ６０Ｍｂｐｓ
２０本の道があり、１本の道に５０個のカメラが設置されるので、カメラの総数は約１０００台になる。全てのカメラからの出力をマージすると、６０Ｇｂｐｓ、１５０００ＦＰＳとなる。なお、総レート６０Ｇｂｐｓは、１フレーム５００ｋＢ×カメラ１０００台×１５ＦＰＳにより計算される。

このデータが、例えば、図８に示した１つのローカル集約ノード（ＬＡ）への入力となる。図１０は、上記のデータが、カメラから、ローカル集約ノード（ＬＡ）及び地域エッジノード（ＲＥ）を経由して、アプリノード（ＡＰ）に到達するまでのデータの流れのイメージを示している。図１０に示すとおり、６０ＭｂｐｓのＴＣＰデータ転送を同時に１０００台のカメラ分だけ実行することになる。

例えば、ＯＳ層のＴＣＰ／ＩＰサービスを利用しながらデータを送受信するプログラムをＣＰＵで動作させる情報通信装置をＬＡとＲＥに設置することで上記のデータ転送を実現することが考えられる。しかし、ＯＳ層のＴＣＰ／ＩＰサービスは、転送対象のデータのサイズや更新レートに応じた通信の最適化をせずに、ＯＳ層で自律的にフロー制御を行い、データのバッファリングを行う。

このため、図１０に示すようなデータ転送の例において、転送データが膨大になるとＣＰＵ負荷が大きくなり、フロー制御のためにデータ転送に時間がかかってしまうことになる。

負荷分散の層を構築することで負荷分散を図ることも考えられるが、負荷分散の層に相当数のサーバが必要となり、システム全体としてのＣＰＵ負荷が増大するとともに、負荷分散の層の分だけレイテンシが大きくなる。

そこで、第１実施形態では、ＬＡとＲＥとの間の通信方式として、メモリ間で直接にデータ通信を行うことが可能なＲＤＭＡを使用する。つまり、ローカル集約ノード（ＬＡ）と地域エッジノード（ＲＥ）のそれぞれに、ＲＤＭＡ－ＮＩＣを備えた情報通信装置を備える。また、情報通信装置において、収集データのサイズにあわせてＲＤＭＡの仮想メモリ領域を確保（登録）し、この仮想メモリ領域のサイズと更新レートに合わせてネットワーク帯域を割り当てることとしている。この割り当ては動的に行うことができる。動的にネットワーク帯域の割り当てを行う方法として、例えば以下のような方法がある。なお、以下の方法は例であり、以下の方法以外の方法を用いることとしてもよい。

・光の物理層のレイヤでは、光の波長数を動的に変更する。

・伝送装置のレイヤ（レイヤ１）では、ＯＴＮにおけるフレーム変更やＯＤＵＦｌｅｘによるより細かい粒度での帯域変更、ＳＯＮＥＴ／ＳＤＨにおける速度階梯変更や、ＶＣ（ＶｉｒｔｕａｌＣｏｎｃａｔｅｎａｔｉｏｎ）によるより細かい粒度でのレート変更を行う。

・より上位のレイヤでは、ＭＰＬＳ－ＴＥ、ＲＳＶＰ―ＴＥによる、トラヒックエンジニアリング機能による帯域制御を行う。

・同時並列のストリーム数で伝送速度を高速化しているプロトコルでは、データ転送における並列度調整を行う。

・ネットワークでの帯域制御ではなく、転送ノードでは、トラヒックシェーパなどにより、帯域制御などを行う。

図１１に、上述したカメラ配置の想定の下での、ローカル集約ノード（ＬＡ）と地域エッジノード（ＲＥ）との間におけるＲＤＭＡを用いた通信の例を示す。図１１には、ローカル集約ノード（ＬＡ）と地域エッジノード（ＲＥ）のそれぞれにおいて、ＲＤＭＡにより使用されるメモリが示されている。

前述したとおり、総レート６０Ｇｂｐｓは、１フレーム５００ｋＢ×カメラ１０００台×１５ＦＰＳであり、カメラ１０００台は５００ＭＢにおさまる。そこで、ローカル（グラウンド）側の情報通信装置において、５００ＭＢのメモリ領域を確保する。ただし、ローカル側では、データ転送中に次フレームの画像データをメモリに書き込む必要があるので、メモリを書き込む為の領域と、メモリを転送するための領域、合わせて２領域を生成する。つまり、図１１に示すように、Ｇ１領域として５００ＭＢのメモリ領域と、Ｇ２領域として５００ＭＢのメモリ領域との２つのメモリ領域を生成する。各メモリ領域は、１５Ｈｚで更新される。なお、メモリ領域の数は少なくても２つ以上確保すればよい。

リモート（クラウド）側の地域エッジノード（ＲＥ）の情報通信装置においては、アプリノードへのデータの転送に際して、データ分析等のために、ある時間だけデータを保持しておくことが想定される。

そのため、地域エッジノード（ＲＥ）の情報通信装置においては、データ保持時間に応じて必要な数のメモリ領域を生成する。例えば、データ保持時間が１秒であるならば、１６（＝１５＋１）個のメモリ領域を確保する。図１１の例では、Ｃ１領域～Ｃ４領域の４領域が確保されている。

また、ＬＡとＲＥとの間のネットワークにおいて、データの総レート６０Ｇｂｐｓに合わせて、ネットワーク帯域（６０Ｇｂｐｓ＋α）が割り当てられる。なお、αは余裕を持って帯域を割り当てることを表現しており、カプセリングするプロトコルによるヘッダオーバーヘッドや、その他の制御メッセージを含める程度、例えば１０％程度を割り当てればよい。

なお、１対のＲＤＭＡノードにおいて６０ＧｂｐｓのＲＤＭＡ通信を実現できない場合には、メモリ領域を分けて複数のメモリ同期を並列に走らせればよい。この際、例えば、ラベル多重等を行うことにより光パスを共用してもよい。

＜装置構成＞
図１２は、ＬＡ側の情報通信装置１００とＲＥ側の情報通信装置２００の機能構成を示す図である。情報通信装置１００と情報通信装置２００との間は光ネットワーク３００により接続されている。

図１２に示すとおり、ＬＡ側の情報通信装置１００は、データ送信部１１０、制御部１２０、ＲＤＭＡ通信部１３０を有する。データ送信部１１０と制御部１２０は、ＣＰＵ、ＦＰＧＡ、物理メモリ、及びユーザプログラム等により実現される機能部である。ＲＤＭＡ通信部１３０は、ＲＤＭＡ－ＮＩＣに相当する。

データ送信部１１０は、端末側からのデータを受信し、当該データを物理メモリに格納するとともに、ＲＤＭＡ通信部１３０に送信命令を出す。送信命令を出すことは、ＲＤＭＡ通信部１３０における送信キューに送信要求を積むことに相当する。

制御部１２０は、データ送信部１１０を監視することで、あるいは、端末側に関する情報を取得することで、転送すべきデータのサイズ及び更新レートを把握する。制御部１２０は、データのサイズに基づいて、ＲＤＭＡ通信部１３０が使用するメモリ領域のサイズ（このサイズ単位で更新されるため更新サイズと呼ぶ）を決定してメモリ領域の確保を行うとともに、データのサイズ及び更新レートに基づいて、ＬＡとＲＥとの間においてＲＤＭＡ通信によりデータ通信を行うためのネットワークパスの帯域を決定し、当該帯域の確保を行う。

すなわち、制御部１２０には、複数の端末から送信されるデータに関する情報に基づいて、当該データを保持するために使用されるメモリ領域の更新サイズを決定する第１レイヤで動作する決定手段と、前記更新サイズ、及び、前記データの更新レートに基づいて、受信側との間で通信に必要な第２レイヤのネットワークパスの帯域の設定を行う設定手段とを含む。なお、サイズ決定処理のレイヤ、ＲＤＭＡ通信に係る処理のレイヤは異なるため、第１レイヤ、第２レイヤと呼んでいる。

ＬＡ側の制御部１２０が把握した情報（データのサイズ及び更新レート等）は、ＲＥ側の情報通信装置２００の制御部２２０に通知され、制御部２２０は、ＲＤＭＡ通信部２３０に対して、メモリ領域の確保等の処理を行う。

データのサイズ及び更新レートの把握に関しては、例えば、制御部１２０が、受信データに基づいて、端末数、及び、各端末から更新レートで送信されてくるデータの量を把握することにより把握することができる。また、図１３に示すように、オペレーションシステム２５０を備え、制御部１２０と制御部２２０のそれぞれが、オペレーションシステム２５０から、端末数、及び、各端末から送信されるデータの更新レートとデータサイズ等の明示的な情報を受信して、データのサイズ及び更新レートを把握することとしてもよい。

図１２、図１３に示すとおり、ＲＥ側の情報通信装置２００は、データ受信部２１０、制御部２２０、ＲＤＭＡ通信部２３０を有する。データ受信部２１０と制御部２２０は、ＣＰＵ、ＸＰＵ、物理メモリ、及びユーザプログラム等により実現される機能部である。ＲＤＭＡ通信部２３０は、ＲＤＭＡ－ＮＩＣに相当する。ここではＧＰＵなど、様々なプロセッサユニットを総称的にＸＰＵと呼ぶこととする。

データ受信部２１０は、ＬＡ側からのデータを、ＲＤＭＡ通信部２３０を介して受信し、当該データを物理メモリに格納するとともに、例えばＸＰＵによるデータ処理を実行する。

また、データ受信部２１０は、ＲＤＭＡ ＲＥＡＤ動作を実行することで、ＬＡ側からデータを取得して、物理メモリに格納することとしてもよい。これにより、機器構成上、ＬＡ側が比較的非力な場合にも対応可能となる。

以上のように、データの受信は、ＬＡ側もしくは、ＲＥ側のどちら側が主体になって実行してもよい。

制御部２２０は、ＲＥ側の制御部１２０又はオペレーションシステム２５０から受信する情報に基づいて、データのサイズ及び更新レート等を把握し、把握した情報に基づいて、ＲＤＭＡ通信部２３０が使用するメモリ領域の確保、及びネットワーク帯域の確保を行う。また、制御部２２０は、データ処理時間等に基づいて、ＲＥにおいてデータを保持する時間を算出し、データ保持時間に応じた数のメモリ領域を確保する。

＜詳細例＞
次に、図１４を参照して、第１実施形態における詳細構成と詳細動作の例を説明する。図１４に示す通信システムにおいて、ＬＡ側に情報通信装置１００が備えられ、ＲＥ側に情報通信装置２００が備えられる。なお、図１４の例では、ＲＥに１つのＬＡが接続されているが、これは例であり、ＲＥは、複数のＬＡを接続することが可能である。また、ＬＡにおける情報通信装置１００をプロキシサーバと呼んでもよい。情報通信装置１００は、端末（カメラ等）がＲＤＭＡをサポートしていない場合でもネットワーク上でＲＤＭＡ通信を可能とする機能を有するからである。

また、情報通信装置１００には光パケットトランスポンダ１４が接続され、情報通信装置２００には、光パケットトランスポンダ２６が接続される。光パケットトランスポンダ１４と光パケットトランスポンダ２６との間は光ネットワーク３００により接続される。ＬＡ側の光パケットトランスポンダ１４は、情報通信装置１００のＲＤＭＡ－ＮＩＣ１２から出力された電気信号を光信号に変換し、当該光信号を送出する。ＲＥ側の光パケットトランスポンダ２６は、光ネットワーク３００から受信した光信号を電気信号に変換し、当該電気信号を情報通信装置２００のＲＤＭＡ－ＮＩＣ２４へ送出する。

また、ＬＡ側の情報通信装置１００には、ＬＡＮを介して８０台のカメラが接続されている。なお、カメラからのデータ転送はＴＣＰ／ＩＰにしても、たかだか数百メートルの通信であると想定されるので、高速なデータ転送が可能と想定している。

図１４では、メモリ領域の状態を説明し易くするために、情報通信装置１００と情報通信装置２００のそれぞれについて、物理的な実装に近い構成を示している。

すなわち、情報通信装置１００には、制御部１２０、スマートＮＩＣ１１、ＲＤＭＡ－ＮＩＣ１２が備えられ、スマートＮＩＣ１１とＲＤＭＡ－ＮＩＣ１２は、ＣＩ（Component Interconnect）１３により接続されている。

スマートＮＩＣ１１は、ＦＰＧＡと物理メモリを備える。ＦＰＧＡはＴＣＰサービス機能を有し、カメラ１～８０から出力されたデータを受信し、物理メモリにおいて制御部１２０により確保されたメモリ領域に当該データが格納される。

ＲＤＭＡ－ＮＩＣ１２は、前述したようなＲＤＭＡ通信を行うハードウェアである。図１４には、物理メモリの写像である仮想メモリのメモリ領域が示されている。

制御部１２０により、メモリ領域に対応する仮想メモリアドレスが指定されることにより、情報通信装置１００においてＲＤＭＡ－ＮＩＣ１２によるアクセス対象となるメモリ領域が確保される。仮想メモリは物理メモリの写像であるため、制御部１２０により確保されるメモリ領域は、仮想メモリでのメモリ領域でもあり、物理メモリでのメモリ領域でもある。

情報通信装置２００には、制御部２２０、ＸＰＵカード２１、ＣＰＵカード２２、中央メモリカード２３、及びＲＤＡＭ－ＮＩＣ２４が備えられ、ＸＰＵカード２１、ＣＰＵカード２２、中央メモリカード２３、及びＲＤＡＭ－ＮＩＣ２４は、ＣＩ２５により接続されている。

ＸＰＵカード２１は、例えば画像分析を行うＸＰＵと物理メモリを備える。ＣＰＵカード２２は、分析結果の活用処理等を行うＣＰＵと物理メモリを備える。中央メモリカード２３は、物理メモリを備える。

中央メモリカード２３は、ＰＣアーキテクチャにおけるいわゆるマザーボード上の高速ストレージでもよいし、ＮＶＭＥ Ａｒｒａｙのような独立したストレージでもよい。ＲＤＭＡ－ＮＩＣ２４から中央メモリカード２３（マザーボード）上の物理メモリに対してＣＰＵを介在させずにデータをＤＭＡ転送することで、ＣＰＵ負荷を高めずに物理メモリを使用することができる。また、複数の中央メモリカードをＲＡＩＤ構成にして、高性能化・ＨＡ化させることとしてもよい。

なお、中央メモリカード２３としてＮＶＭＥ Ａｒｒａｙを使用する場合には、コンピューティング系の機能部とインターコネクトで高速に接続することとしてもよい。

ＲＤＭＡ－ＮＩＣ２４は、前述したようなＲＤＭＡ通信を行うハードウェアである。図１４には、物理メモリの写像である仮想メモリのメモリ領域が示されている。前述したように、制御部２２０により、メモリ領域に対応する仮想メモリアドレスが指定されることにより、情報通信装置２００においてＲＤＭＡ－ＮＩＣ１２によるアクセス対象となるメモリ領域が確保される。仮想メモリは物理メモリの写像であるため、制御部２２０により確保されるメモリ領域は、仮想メモリでのメモリ領域でもあり、物理メモリでのメモリ領域でもある。

ＬＡ側の情報通信装置１００における制御部１２０は、情報通信装置１００に接続しているカメラの台数が増えた場合、ＲＤＭＡ－ＮＩＣ１２のアクセス対象とするメモリ領域、及び、ＬＡとＲＥとの間のコネクション帯域も同じ割合で増やすなど、逆にカメラの台数が減った場合は、同じ割合減らすなど、カメラの台数の増減に応じて、ＲＤＭＡ－ＮＩＣ１２のアクセス対象とするメモリ領域、及び、ＬＡとＲＥとの間のコネクション帯域を増減させる。制御部１２０において決定されたメモリ領域の量、及びコネクション帯域の情報は、ＲＥ側の情報通信装置２００における制御部２２０にも通知され、制御部２２０は、通知された情報に基づいて、ＲＥ側の情報通信装置２００において、ＲＤＭＡ－ＮＩＣ２４のアクセス対象とするメモリ領域、及び、ＬＡとＲＥとの間のコネクション帯域を増減させる。

また、ＬＡ側の情報通信装置１００における制御部１２０及びＲＥ側の情報通信装置２００における制御部２２０は、転送データの発生レート、即ち、画像データの取得端末となるカメラの台数（データ"発生元"）増減などの変動に応じて、メモリ領域・コネクション帯域を増減させることとしてもよい。

各端末（カメラ）とメモリ領域との関係に関しては、１対１の関係で紐付けられていればよく、指定するメモリ領域が固定化されている必要はない。詳細は後述するが、指定するメモリ領域は、確定的に割り当てても良いし、空きメモリ領域の中から動的に割り当てても良い。またその都度、必要に応じて割り当て領域を増やすこともできる。

このために、ＲＥへの転送待ち又は転送中状態、書き込み中状態、新たに書き込み可能状態、の三状態で各メモリ領域の状態を管理する。ＬＡにおいて、新たに書き込み可能状態の領域が減ってきたらこの領域を増やし、ＲＥに対してもメモリ領域の増加を要求する。

具体的には、図１４の例において、ＬＡ－ＲＥ転送中のデータを保持する状態のメモリ領域、ＬＡで受信中のデータを保持する状態のメモリ領域、ＲＥで処理中のデータを保持する状態のメモリ領域が示されている。

上記のメモリ割り当て制御及びメモリ状態管理については、制御部１２０が行う。ただし、これは例であり、制御部１２０以外の手段（例：スマートＮＩＣ１１、ＲＤＭＡ－ＮＩＣ１２、外部にある装置等）が行ってもよい。以下、図１４に示す通信システムの動作例を説明する。

図１４に示すとおり、８０台のカメラがＬＡに接続されている。各カメラは各フレームを最大５００ｋＢで符号化する。フレームレートは１５ＦＰＳである。８０台のカメラが接続されていて、各カメラが各フレームを最大５００ｋＢで符号化し、１５ＦＰＳで画像データを出力するという情報は、カメラ自身あるいはオペレーションシステムからＬＡ側の制御部１２０に通知される。なお、制御部１２０は受信データから当該情報を推定してもよい。

制御部１２０は、通知された情報に基づいて、ＲＤＭＡ－ＮＩＣ１２がアクセスするメモリ領域（つまり、スマートＮＩＣ１１の物理メモリのメモリ領域）として、５００ｋＢ×８０台分の大きさのメモリ領域を２領域分確保するとともに、確保したメモリ領域を５００ｋＢごとの領域に分ける。なお、５００ｋＢ×８０台分は、更新サイズである。

図１４のＬＡ側のメモリ領域の図において、「０００」の領域は、０番地～１９番地の２０個の領域を示し、各領域の大きさが５００ｋＢである。他の領域も同様である。つまり、各メモリ領域に、カメラの台数分の８０個の５００ｋＢ領域が確保されている。

ＲｅａｄとＷｒｉｔｅの競合を防ぐために、各カメラに二つの領域が割り当てられる。例えば、カメラ１には０番地の領域と８０番地の領域が割り当てられ、カメラ２には１番地の領域と８１番地の領域が割り当てられる。

また、各カメラの画像のフレームレートは１５ＦＰＳであるので、８０台のカメラの総レート（＝ＬＡからＲＥへのデータ転送レート）は、０．５ＭＢ×８×１５×８０＝６０Ｍｂｐｓ×８０＝４．８Ｇｂｐｓとなる。そのため、制御部１２０及び制御部２２０により、ＬＡとＲＥ間のＲＤＭＡ－ＮＩＣ対に、６０Ｍｂｐｓ×８０台＋βの帯域を割り当てる。β（ベータ）は、余裕を持って帯域を割り当てることを表現しており、カプセリングするプロトコルによるヘッダオーバーヘッドや、その他の制御メッセージを含める程度、例えば１０％程度を割り当てればよい。

また、ＲＥの情報通信装置２００における中央メモリ（中央メモリカード２３の物理メモリ）は画像５フレーム分のデータを保持することとしている。そのため、制御部２１０は、５００ｋＢ×８０台分の大きさのメモリ領域（更新サイズ）を５領域分確保するとともに、確保したメモリ領域を５００ｋＢごとの領域に分ける。図１４のＲＥ側のメモリ領域の図において、「０００」の領域は、０番地～１９番地の２０個の領域を示し、各領域の大きさが５００ｋＢである。他の領域も同様である。

各カメラへの領域の割り当てに関しては、例えば、カメラ１には領域０、８０、１６０、２４０、３２０が割り当てられ、カメラ２には領域１、８１、１６１、２４１、３２１が割り当てられるといったようにして、各カメラに領域を割り当てる。

ＬＡからＲＥへメモリコピーする際にコピー先の領域をローテーションさせることとする。このようなローテーションは、例えば、送信側の制御部１２０が、送信要求を送信キューに積む際に、コピー先の領域を指定することにより実現してもよいし、ＲＤＭＡ－ＮＩＣ１２自身が、ローテーションの制御を行ってもよい。また、ＲＥ側の制御部２２０が、ＲＤＭＡ ＲＥＡＤオペレーションにより、メモリ領域を指定した受信要求を受信キューに積む際に、コピー先の領域を指定することにより実現してもよいし、ＲＤＭＡ－ＮＩＣ２４自身が、ローテーションの制御を行ってもよい。

スマートＮＩＣ１１におけるＴＣＰサービスは、各カメラから受信した画像データを当該カメラの領域に交互に書き込む。例えば、カメラ１から受信したフレーム１の画像データを０番地の領域に書き込み、カメラ１から受信したフレーム２の画像データを８０番地の領域に書き込む。フレーム２の画像データを８０番地の領域に書き込む間に、０番地の領域の画像データは、ＲＤＭＡ－ＮＩＣ１２により読み出され、ＲＥ側へ転送される。そのため、カメラ１から受信したフレーム３の画像データを０番地の領域に書き込む。このような処理がカメラ毎に実行される。

ＲＤＭＡ－ＮＩＣ１２からＲＥ側へ転送されたデータは、ＲＥ側のＲＤＭＡ－ＮＩＣ２４により、中央メモリにおける、データの送信元のカメラに対応した領域に格納される。図１４の例では、「０８０」～「１４０」の領域が、ＬＡ－ＲＥ転送中のデータ、すなわち、書き込み中のデータであることが示されている。

ＲＥ側の情報通信装置２００においては、目的に応じた複数のプログラムをＣＰＵカード及びＸＰＵカードで走行させている。各プログラムは、中央メモリカードのデータに、ＤＭＡでアクセスするか、コピー転送する。図１４の例では、転送中のデータの前に格納済みである「０００」のデータが、ＤＭＡ転送によりＸＰＵの物理メモリに格納され、ＸＰＵにより処理が実行される。

なお、ＲＥのＲＤＭＡ－ＮＩＣ２４における仮想メモリアドレスと物理メモリアドレスとは、１対１の関係で紐づけられていればよく、指定するメモリ領域が固定化されている必要はない。時系列データを保存するために、時間の経過とともに仮想メモリアドレスに指定される物理メモリアドレスを変化させてもよい。

例えば、時刻が１、２、３、４、...のように経過することに対応して、仮想メモリアドレス＝１に対応する物理メモリアドレスを８１、８２、８３、８４、...のように変化させる。これにより、仮想メモリアドレス＝１を指定して順次送信されてくる時系列データを、時系列の順に物理メモリに格納することができ、処理効率を向上できる。この制御は、ＲＤＭＡ－ＮＩＣ２４が行ってもよいし、制御部２２０が行ってもよい。

また、ＲＥにおいて、ＲＤＭＡ－ＮＩＣ２４からの転送先の物理デバイス（ＸＰＵと物理メモリを備えるカード等）が複数存在する場合において、物理デバイスの負荷が均等になるように仮想メモリアドレスと物理メモリデバイス関係を調整することとしてもよい。例えば、負荷があがってきたら、別の物理デバイスに対応先を変えることとしてもよい。この制御は、ＲＤＭＡ－ＮＩＣ２４が行ってもよいし、制御部２２０が行ってもよい。

また、ＲＥにおいて、ある物理デバイスが機能しなくなった場合に、別の物理デバイスに対応先を変えることにより、物理デバイスの高信頼化を図ってもよい。この制御は、ＲＤＭＡ－ＮＩＣ２４が行ってもよいし、制御部２２０が行ってもよい。

また、ＲＥにおいて、データの高信頼化のためにＮコピーを実施してもよい。すなわち、一つの仮想メモリアドレスに対して複数の物理メモリアドレスをマッピングさせて、ＲＤＭＡ－ＮＩＣ２４が当該仮想メモリアドレスに対して受信した値を当該複数の物理アドレスに書き込むこととしてもよい。このとき、複数の物理アドレスに同じ値を書く代わりにＲＳＥ（Ｒｅｅｄ Ｓｏｌｏｍｏｎ Ｅｒａｓｕｒｅ）等の演算を行った結果を書き込むこととしてもよい。また、データ高信頼化の変換処理において、秘密分散で安全性を確保できる関数を用いることとしてもよい。

また、データの高信頼化のために光マルチキャストによるＮコピーを行ってもよい。すなわち、１つのＬＡから光マルチキャストで複数のＲＥに同時にコピーして高信頼化を実現してもよい。

＜第１実施形態の効果＞
第１実施形態に係る技術により、ローカル集約ノード（ＬＡ）における情報通信装置のＣＰＵ稼働の軽減を図ることができるとともに、ローカル集約ノード（ＬＡ）と遠隔地にあるＮＷ上のサーバ側（ＲＥ）との間で大容量データの転送を高速かつ低遅延で実現できる。

また、端末から収集したデータの転送にＣＰＵが介在しないので、より少ない装置の台数で多数の端末を収容することができる。また、ＴＣＰのようなフロー制御がなくデータ転送にかかる時間が短くて済むので、例えば、瞬間的な分析、反応が必要なＡＩアプリを実現できる。

（第２実施形態）
次に、第２実施形態を説明する。

多数のセンサ情報を収集して分析するサービスを提供するシステムに関して、従来技術では、特定の限られた目的のために設計・構築される。そのため、ある目的のためのサービスを提供したい場合には、その目的に応じてカメラ等のインフラを構築し、取得した映像等のセンサデータの分析を行うシステムをそのサービスのために個別に構築する必要があった。また、多数のセンサやカメラのデータを収集して他ノードに転送する集約ノードに設置された通信装置におけるＯＳ層のＴＣＰ／ＩＰサービスを、データ受信プログラムとともにＣＰＵで動作させることに伴い、転送データが膨大になると、ＣＰＵ負荷が大きくなってしまうという課題もあった。

例えば、アプリケーションサーバにより、社会の動向に応じて、新たなサービスを提供しようとする場合には、データ収集・分析のシステムから構築しなければならなかった。すなわち、従来技術では、複数の端末から収集されたデータを利用して、多様な任意のサービスを提供することが難しいという課題があった。以下、これらの課題を解決する第２実施形態について説明する。

＜システム構成例＞
図１５に、第２実施形態におけるデータ処理システムの構成例を示す。第２実施形態は、第１実施形態の技術をベースとしており、図１５は、図８に示したシステム構成における地域エッジノード（ＲＥ）からアプリノード（ＡＰ）までの構成をより詳細に記載したものに相当する。なお、第２実施形態では、アプリノードで動作するアプリとしてＡＩアプリを想定していることから、アプリノードの具体例として、ＡＩアプリノードを記載している。

図１５に示すように、地域エッジノード（ＲＥ）、メッセージブローカノード（ＭＢ）、データハブノード（ＤＨ）、ＡＩアプリノード（ＡＰ）がそれぞれ複数存在する。地域エッジノード（ＲＥ）とデータハブノード（ＤＨ）との間、及びデータハブノード（ＤＨ）とＡＩアプリノード（ＡＰ）との間はそれぞれ例えば光ネットワークで接続される。なお、メッセージブローカノード（ＭＢ）とデータハブノード（ＤＨ）は、まとめて１つのノード（１つの装置）で構成することとしてもよい。

また、第２実施形態は、メモリの割り当てをユースケースの特性に応じて予め固定することで、ＣＰＵの介在を極力削減し、ＬＡ＜－＞ＲＥ転送＆ＡＩのサービスを低負荷に実行する事例である。ここでは地域エッジノード（ＲＥ）とデータハブノード（ＤＨ）との間、及びデータハブノード（ＤＨ）とＡＩアプリノード（ＡＰ）との間はそれぞれＲＤＭＡを用いて通信を行うことを例に説明する。なお、ＲＤＭＡを用いることは必須では無いが、ＲＤＭＡを併用することで、地域エッジノード（ＲＥ）とＡＩアプリノード（ＡＰ）との間の通信の低遅延化が可能になるとともに、各ノードでの負荷低減、それに伴う、ノード集約効果の向上、ひいては、全体システムの低消費電力化が図れる。以下、ＲＤＭＡ以外の通信方式を使用しても同様の効果が期待できる。

地域エッジノード（ＲＥ）とメッセージブローカノード（ＭＢ）との間、及びメッセージブローカノード（ＭＢ）とＡＩアプリノード（ＡＰ）との間の通信については、どのような通信方式を使用してもよい。例えばＲＤＭＡでもよいし、一般的なＩＰ通信（インターネット等）でもよい。

図１５に示す例において、地域エッジノード（ＲＥ）は、東京、大阪、名古屋、福岡、横浜に設置されている。

メッセージブローカノード（ＭＢ）とデータハブノード（ＤＨ）は、トピック毎に分散して配置されている。なお、「トピック」を「イベント」と呼んでもよい。図１５の例では、ＭＢ１とＤＨ１が「トピック=防犯・安全管理」に対応し、ＭＢ２とＤＨ２が「トピック=人数カウント」に対応し、ＭＢ３とＤＨ３が「トピック=顧客行動分析」に対応する。

ＡＩアプリノード（ＡＰ）は、アプリプロバイダの都合で散在している。図１５の例では、「不審者検知」、「事故発生率予測」、「混雑緩和」、「需要予測・在庫最適化」、「マイクロ交通運行最適化」、「棚割最適化」、「キャンペーン提案」などを行う複数のＡＩアプリノード（ＡＰ）が配置されている。

各ＡＩアプリノード（ＡＰ）により提供されるサービスは固定されているわけではない。第２実施形態では、サービス提供に必要な所望のデータを容易に取得することが可能であるため、任意のサービスを容易に提供することが可能である。

ローカル集約ノード（ＬＡ）の配下には、第１実施形態と同様に、ＬＡＮを介して複数の端末が接続されている。端末は例えばカメラ（スマートカメラ）である。

スマートカメラはいわゆるセンサ情報を収集する装置としての例であり、イメージセンサ、ＤＳＰを搭載し、カメラ映像を符号化して圧縮しＬＡＮに送信する機能を有する。なお、ローカル集約ノード（ＬＡ）の配下に備えられる端末は、センサ情報を収集するセンサ機器であればどのような機器であってもよい。

＜装置構成例＞
以下、各ノードに配置される装置の機能構成例を説明する。ＬＡに配置される情報通信装置１００の構成は、第１実施形態の図１２（及び図１３）に示した情報通信装置１００の構成と同じである。

図１６に、地域エッジノード（ＲＥ）に備えられるエッジノード装置４００の構成例を示す。エッジノード装置４００の機能は、第１実施形態の図１２（図１３）に示したＲＥ側の情報通信装置２００の機能と基本的に同じであるが、第２実施形態では、イベント情報生成・送信、及びデータのデータハブノードへの送信を行うことから、図１６に示す構成ではその点に係る機能を含めている。なお、エッジノード装置４００をイベント情報生成装置と呼んでもよい。

図１６に示すとおり、エッジノード装置４００は、データ送受信部４１０、制御部４４０、ＲＤＭＡ通信部４３０、イベント情報生成部４２０を有する。データ送受信部４１０と制御部４４０とイベント情報生成部４２０は、ＣＰＵ、ＸＰＵ、物理メモリ、及びユーザプログラム（アプリケーション）等により実現される機能部である。ＲＤＭＡ通信部４３０は、ＲＤＭＡ－ＮＩＣに相当する。

データ送受信部４１０は、ＬＡ側から送信されたデータを、ＲＤＭＡ通信部４３０を介して受信し、当該データを物理メモリに格納する。また、データ送受信部４１０は、ＲＤＭＡ通信部４３０を用いて、イベント情報に対応するデータハブノード装置へのデータ送信を行う。

データハブノード装置へのデータ送信の際には、送信するデータに対応するイベント情報（トピック）に対応するデータハブノード装置へデータを送信する。また、当該データハブノード装置におけるデータ格納先のメモリ領域のアドレスとして、データ送信元のエッジノード装置４００が属する地域に対応するメモリ領域のアドレスを指定する。

イベント情報生成部４２０は、ＬＡ側から受信したデータに対して、ＸＰＵ等によるデータ分析を行って、分析の結果に基づいて、イベント情報を生成し、イベント情報に対応するメッセージブローカ装置にイベント情報を送信する。イベント情報には、トピックを示す情報、分析結果の情報、当該イベント情報の格納先（格納先のデータハブノード装置とそのメモリ領域）を識別する情報（アドレス等）等が含まれる。

すなわち、イベント情報生成部４２０は、複数の端末から収集されたデータを受信し、当該データからイベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段を含む。

また、データ送受信部４１０及びＲＤＭＡ通信部４３０は、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、当該イベント情報に対応するデータを送信する送信手段を含む。

制御部４４０は、ＬＡ側の制御部１２０又はオペレーションシステム２５０から受信する情報に基づいて、データのサイズ及び更新レートを把握して、データのサイズ及び更新レートに基づいて、ＲＤＭＡ通信部４３０が使用するメモリ領域の確保、及びネットワーク帯域の確保を行う。また、制御部４４０は、データ処理時間等に基づいて、ＲＥにおいてデータを保持する時間を算出し、データ保持時間に応じた数のメモリ領域を確保する。

図１７に、メッセージブローカノード（ＭＢ）に備えられるメッセージブローカ装置５００の機能構成例を示す。メッセージブローカ装置５００をブローカ装置と呼んでもよい。第２実施形態におけるメッセージブローカ装置５００は、Ｐｕｂｌｉｓｈｅｒ／Ｓｕｂｓｃｒｉｂｅｒモデルにおけるブローカの機能を有することを想定している。

図１７に示すように、メッセージブローカ装置５００は、メッセージ受信部５１０、メッセージ格納部５２０、メッセージ配信部５３０を有する。メッセージ受信部５１０は、あるトピックについてのメッセージ（具体的にはイベント情報）を配信者（ＲＥ）から受信し、受信したメッセージをメッセージ格納部５２０に格納する。メッセージ配信部５３０は、あるトピックを購読する購読者（ここではＡＩアプリノード）に対し、当該トピックのメッセージを送信する。

図１８は、データハブノード（ＤＨ）に備えられるデータハブノード装置６００の機能構成例を示す。図１８に示すように、データハブノード装置６００は、データ送受信部６１０、制御部６３０、ＲＤＭＡ通信部６２０を有する。データ送受信部６１０と制御部６３０は、ＣＰＵ、物理メモリ、及びユーザプログラム（アプリケーション）等により実現される機能部である。ＲＤＭＡ通信部６２０は、ＲＤＭＡ－ＮＩＣに相当する。

データ送受信部６１０は、エッジノード装置４００からのデータを、ＲＤＭＡ通信部６２０を介して受信し、当該データを物理メモリに格納する。また、データ送受信部６１０は、ＲＤＭＡ通信部６２０に対し、ＡＩアプリノード装置７００へのデータ送信を行うための送信命令を出し、ＲＤＭＡによるデータ送信を行う。制御部６３０は、ＲＤＭＡ通信部６２０が使用するメモリ領域の確保、及びネットワーク帯域の確保等を行う。

図１９は、ＡＩアプリノード（ＡＰ）に備えられるＡＩアプリノード装置７００の機能構成例を示す。図１９に示すように、ＡＩアプリノード装置７００は、イベント情報処理部７１０、データ処理部７２０、ＲＤＭＡ通信部７３０、制御部７４０を有する。イベント情報処理部７１０、データ処理部７２０、制御部７４０は、ＸＰＵ、ＣＰＵ、物理メモリ、及びユーザプログラム（アプリケーション）等により実現される機能部である。ＲＤＭＡ通信部７３０は、ＲＤＭＡ－ＮＩＣに相当する。なお、ＡＩアプリノード装置７００をデータ処理装置と呼んでもよい。

イベント情報処理部７１０は、メッセージブローカ装置５００からイベント情報を取得し、イベント情報に対する処理を行う。すなわち、イベント情報処理部７１０は、特定のサービスに対応するイベント情報をメッセージブローカ装置から取得する取得手段を含む。

データ処理部７２０は、データハブノード装置６００からＲＤＭＡ通信部７３０を介してデータを受信し、当該データを物理メモリに格納するとともに、ＸＰＵ等による処理を実行する。制御部７４０は、ＲＤＭＡ通信部７３０が使用するメモリ領域の確保、及びネットワーク帯域の確保等を行う。

すなわち、データ処理部７２０及びＲＤＭＡ通信部７３０は、前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応するデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段を含む。

また、ＡＩアプリノード装置７００において、データ処理部７２０を構成するプロセッサのプールが備えられ、当該プール又は当該プールの一部がユーザに割り当てられることとしてもよい。

例えば、ＡＩアプリノード装置７００において、複数のＸＰＵを備え、当該複数のＸＰＵをＸＰＵプールとする。例えば、ＸＰＵプールを複数に分割し、分割したプールを各ユーザに割り当てる。

また、複数のＸＰＵを備えるＸＰＵプールを複数個備えてもよい。例えば、ＸＰＵプール１、ＸＰＵプール２、ＸＰＵプール３がある場合に、ＸＰＵプール１をユーザＡに割り当て、ＸＰＵプール２をユーザＢに割り当て、ＸＰＵプール３をユーザＣに割り当てるといった割り当てを行うことができる。

ＸＰＵプールが割り当てられたユーザに関して、例えば、ユーザ自身が用意したデータ収集システム（又は本実施の形態のデータハブノード装置６００）から処理対象のデータがＡＩアプリノード装置７００に送信される。ＡＩアプリノード装置７００では、当該ユーザに割り当てられたＸＰＵプールに当該ユーザのデータが転送され、当該ユーザのデータに対する計算処理が実行される。このように、ＸＰＵプールをユーザに割り当てることで、計算処理のロジックをサービスとして提供することができる。

＜処理シーケンス例＞
第２実施形態に係るデータ処理システムにおける処理の流れの例を図２０のシーケンス図を参照して説明する。ここでは、一例として、分析対象データがカメラから送出された画像データ（映像データ）であるものとして説明を行う。

なお、エッジノード装置４００（イベント情報生成装置）とデータハブノード装置６００とを有する構成により、ＡＩアプリノード装置７００（データ処理装置）に対してデータを提供するプラットフォームが構成される。エッジノード装置４００とデータハブノード装置６００とを有するプラットフォームをデータ提供システムと呼んでもよい。このデータ提供システムからデータを取得してデータ処理を行う装置は、ＡＩアプリノード装置７００に限られない。例えば、ユーザが用意したアプリケーションサーバがデータ提供システムからデータを取得してデータ処理を行うこととしてもよい。

Ｓ１０１において、エッジノード装置４００のイベント情報生成部４２０は、ＬＡから受信した画像データを分析することにより得られた物体検出情報からイベントを検出し、当該イベントに関するイベント情報を生成する。Ｓ１０２において、イベント情報生成部４２０は、生成したイベント情報を、当該イベント情報に関するトピックのメッセージブローカ装置５００に送信する。

例えば、イベント情報生成部４２０は、物体検出情報として、新規に認識された人物像を得た場合には「人数カウント」をトピックとして有するイベント情報を生成する。また、例えば、イベント情報生成部４２０は、物体検出情報として、特定の要監視エリアで検出された人物像を得た場合には「防犯」をトピックとして有するイベント情報を生成する。また、例えば、イベント情報生成部４２０は、物体検出情報として、店舗やショップエリアで検出された人物像を得た場合には、「顧客行動分析」をトピックとして有するイベント情報を生成する。

イベント情報には、トピックとともに、分析により得られた情報が含まれていてもよい。例えば、「人数カウント」をトピックに持つイベント情報に、人数のカウント結果が含まれていてもよい。

データ送受信部４１０は、イベント情報に付帯した物体画像データを、ＲＤＭＡ通信部４３０を介して、該当のイベント情報に対応するデータハブノード装置６００に転送する（Ｓ１０３）。この場合、イベント情報生成部４２０は、転送先のデータハブノード装置６００の仮想メモリアドレスを、Ｓ１０２で送信するイベント情報に含める。

ＡＩアプリノード装置７００のイベント情報処理部７１０は、Ｓ１０４において、イベント情報をイベントブローカ装置５００から取得する。このイベント情報は、例えば、当該ＡＩアプリノード装置７００が提供する特定のサービスに対応するイベント情報である。

イベント情報処理部７１０は、当該イベント情報が処理すべきイベント情報であれば、当該イベントを処理すると判断し、データ処理部７２０に処理を依頼する。例えば、イベント情報処理部７１０は、前回のイベント情報と今回のイベント情報を比較して、情報に変化があった場合に、イベントを処理すると判断する。

イベントを処理する場合において、データ処理部７２０は、イベント情報とともに画像データが必要である場合、イベント情報に含まれるアドレス情報を用いて、イベント情報に対応する画像データをデータハブノード装置６００から取得して、処理を実行する（Ｓ１０５、Ｓ１０６）。

以下ではより具体的な構成例について説明する。

＜ローカル集約ノード（ＬＡ）と地域エッジノード（ＲＥ）の接続構成例＞
ローカル集約ノード（ＬＡ）と地域エッジノード（ＲＥ）の接続構成例は、第１実施形態での接続構成例と同じであり、図１４に示したとおりである。その動作も基本的に第１実施形態において説明したとおりである。

すなわち、ＬＡにおける情報通信装置１００は、いわゆるプロキシサーバの機能を有し、スマートカメラ等がＲＤＭＡをサポートしていない場合でもネットワーク上でＲＤＭＡ通信を可能とする。

前述したとおり、ＬＡにおける情報通信装置１００内にはＴＣＰサービスを終端し物理メモリに書き込むスマートＮＩＣ１１と、ＲＤＭＡに対応し光パケットトランスポンダ１４にデータを転送するＲＤＭＡ－ＮＩＣ１２が搭載されている。スマートカメラから送られてきた画像データは情報通信装置１００内でＴＣＰ終端され、スマートＮＩＣ１１内の物理メモリを経由してＲＤＭＡ－ＮＩＣ１２内の仮想メモリに転写され、光パケットとなってネットワーク側に送られる。

ＲＥにおけるエッジノード装置４００（第１実施形態での情報通信装置２００に相当）は、ＬＡからデータを受信し、各種データ処理を行って、イベント情報生成等を行う。

＜地域エッジノード（ＲＥ）～ＡＩアプリノードの接続構成例＞
エッジノード装置４００、メッセージブローカ装置５００、データハブノード装置６００、ＡＩアプリノード装置７００の具体例を、図２１を参照して説明する。図２１に示す各装置は、メモリ領域に格納されるデータの状況を示すために、メモリカード等の実装に近い構成を示している。

ＲＥにおけるエッジノード装置４００には、ＬＡからデータを受信するＲＤＭＡ－ＮＩＣ４４、中央メモリカード４３、ＣＰＵカード４２、及び各種データ処理のためのＸＰＵカード４１（ＧＰＵカード等）が含まれる。

エッジノード装置４００は、ＬＡからデータを受信するとＲＤＭＡ－ＮＩＣ４４を介して中央メモリカード４３の物理メモリにデータを書き込む。当該データは、ＤＭＡ転送により例えばＸＰＵカード４１の物理メモリに格納される。ここでは対象データがカメラで取得した画像データとして説明すると、ＸＰＵ（例えばＧＰＵ）は物理メモリの画像データを映像に組み上げ、画像解析を行う。

ここでは画像にうつる人間の人数、顧客行動分析、防犯目的でおかしな挙動をしている人間がいないか、といった解析を行う。解析手法については既存技術を用いることが可能である。

また、ＧＰＵではデータを解析したうえで、解析した画像に応じたイベント情報を生成する。イベント情報には対応した画像データの送信先のデータハブノード装置６００に記憶されるメモリのアドレス情報が含められる。

なお、イベント情報生成はＣＰＵが行ってもよい。図２１には、イベント情報生成をＣＰＵが行う場合の例が示されている。

ＲＥのエッジノード装置４００におけるイベント情報生成部４２０（上記のＧＰＵやＣＰＵ、及びプログラムに相当）は、画像解析によって生成したイベント情報に対応するメッセージブローカ装置５００にイベント情報を送信する。イベント情報の送信は、ＲＤＭＡである必要はなく、ＴＣＰ／ＩＰなどの方法でも良い。また、ＲＤＭＡ－ＮＩＣ４４により、イベント情報に対応するデータハブノード装置６００に画像データが送信される。

なお、イベント情報に対応する宛先のデータハブノード装置６００の決定に関しては、例えば、エッジノード装置４００において、イベント情報に対応する光パスアドレスを記憶したテーブルを用意しておき、データ送受信部４１０が、そのテーブルを参照することで宛先のデータハブノード装置６００を決定する。

データハブノード装置６００は、中央メモリカード６１、及びＲＤＭＡ－ＮＩＣ６２を含む。データハブノード装置６００のＲＤＭＡ－ＮＩＣ６２は、複数のＲＥから特定イベントごとの画像データを受信し、ＲＥ（地域）に対応したメモリ領域にデータを格納する。また、データハブノード装置６００において、ＲＤＭＡ－ＮＩＣ６２は、物理メモリからデータを読み出して、当該データをＡＩアプリノード装置７００に送信する。

メッセージブローカ装置５００は、ＲＥのエッジノード装置４００からイベント情報を受信し、当該イベント情報に対応するＡＩアプリノード装置７００にイベント情報を送信する。

ＡＩアプリノード装置７００は、各種画像データから例えば混雑状況と人数の情報を取得してレストランの混雑予測やタクシー配車管理などのサービスを提供する装置である。図２１に示すように、ＡＩアプリノード装置７００の構成は、エッジノード装置４００の構成と同様であり、ＸＰＵカード７１、ＣＰＵカード７２、中央メモリカード７３、ＲＤＭＡ－ＮＩＣ７４を含む。

なお、図２１の例では１つのＸＰＵカードが示されているが、これは例である。複数のＸＰＵカードを備えることで、前述したような１つ又は複数のＸＰＵプールを構成してもよい。

ＡＩアプリノード装置７００は、事前にどのイベント情報を取得するかを記憶しておき、当該記憶情報に基づいて、該当するイベント情報に対応するメッセージブローカ装置５００のアドレスに新規イベント情報の有無を問い合わせる。

例えばＡＩアプリノード装置７００が、人数と顧客動向分析のイベント情報を取得することを記憶している場合において、ＡＩアプリノード装置７００は、人数に関するメッセージブローカ装置５００Ａと、顧客動向分析に関するメッセージブローカ装置５００Ｂに、画像データのアップデート（つまり、イベント情報のアップデート）を問い合わせる。

メッセージブローカ装置５００は、ＡＩアプリノード装置７００からの問い合わせに応じて、アップデートしたイベント情報がある場合に、保有するイベント情報を問い合わせ元のＡＩアプリノード装置７００に送信する。

ＡＩアプリノード装置７００は、例えば、今回取得したイベント情報と以前に受信していたイベント情報との比較を行い、差分がある場合はイベント処理を実行する。このとき、差分に対応する画像データを、当該画像データが格納されているデータハブノード装置６００から取得する。

イベント情報には、画像データが格納されているメモリのアドレス情報が含まれているので、ＡＩアプリノード装置７００は、当該アドレス情報に基づいて、当該画像データが格納されているデータハブノード装置６００のメモリの特定の領域にアクセスすることができる。

ＡＩアプリノード装置７００において、ＲＤＭＡ－ＮＩＣ７４が、データハブノード装置６００から受信した画像データを、中央メモリカード７３の物理メモリに書き込む。当該画像データは、例えばＸＰＵカード７１に送られて画像分析処理が行われる。また、例えば、ＣＰＵによって分析結果の活用処理を行う。

＜第２実施形態の効果＞
第２実施形態に係る技術によれば、ＡＩアプリノード装置が提供したいサービスに応じて必要な情報だけを取得することができるので、多様な任意のサービスを容易に提供することが可能となる。

また、データの送受信にＲＤＭＡを使用する場合には、ＣＰＵ負荷を軽減し、高速かつ低遅延で転送のデータ転送を実現できる。

（ハードウェア構成例）
第１、第２の実施の形態で説明した情報通信装置１００、２００、エッジノード装置４００、メッセージブローカ装置５００、データハブノード装置６００、ＡＩアプリノード装置７００はいずれも、例えば、コンピュータにプログラムを実行させることにより実現することもできる。このコンピュータは、物理的なコンピュータであってもよいし、クラウド上の仮想マシンであってもよい。情報通信装置１００、２００、エッジノード装置４００、メッセージブローカ装置５００、データハブノード装置６００、ＡＩアプリノード装置７００を総称して「装置」と呼ぶ。

すなわち、当該装置は、コンピュータに搭載されるＣＰＵやＸＰＵ、ＲＤＭＡ－ＮＩＣ、メモリ等のハードウェア資源を用いて、当該装置で実施される処理に対応するプログラムを実行することによって実現することが可能である。上記プログラムは、コンピュータが読み取り可能な記録媒体（可搬メモリ等）に記録して、保存したり、配布したりすることが可能である。また、上記プログラムをインターネットや電子メール等、ネットワークを通して提供することも可能である。

図２２は、上記コンピュータのハードウェア構成例を示す図である。図２２のコンピュータは、それぞれバスＢで相互に接続されているドライブ装置１０００、補助記憶装置１００２、メモリ装置１００３、ＣＰＵ（あるいはＸＰＵ）１００４、インタフェース装置１００５（例：ＲＤＭＡ－ＮＩＣ）、表示装置１００６、入力装置１００７、出力装置１００８等を有する。なお、これらのうち、一部の装置を備えないこととしてもよい。例えば、表示を行わない場合、表示装置１００６を備えなくてもよい。

当該コンピュータでの処理を実現するプログラムは、例えば、ＣＤ－ＲＯＭ又はメモリカード等の記録媒体１００１によって提供される。プログラムを記憶した記録媒体１００１がドライブ装置１０００にセットされると、プログラムが記録媒体１００１からドライブ装置１０００を介して補助記憶装置１００２にインストールされる。但し、プログラムのインストールは必ずしも記録媒体１００１より行う必要はなく、ネットワークを介して他のコンピュータよりダウンロードするようにしてもよい。補助記憶装置１００２は、インストールされたプログラムを格納すると共に、必要なファイルやデータ等を格納する。

メモリ装置１００３は、プログラムの起動指示があった場合に、補助記憶装置１００２からプログラムを読み出して格納する。ＣＰＵ（ＸＰＵ）１００４は、メモリ装置１００３に格納されたプログラムに従って、当該装置に係る機能を実現する。インタフェース装置１００５は、ネットワークに接続するためのインタフェースとして用いられる。表示装置１００６はプログラムによるＧＵＩ（Ｇｒａｐｈｉｃａｌ Ｕｓｅｒ Ｉｎｔｅｒｆａｃｅ）等を表示する。入力装置１００７はキーボード及びマウス、ボタン、又はタッチパネル等で構成され、様々な操作指示を入力させるために用いられる。出力装置１００８は演算結果を出力する。

（実施の形態のまとめ）
本明細書には、第１実施形態及び第２実施形態に対応して、少なくとも下記の各項に記載した装置、方法、及びプログラム等が記載されている。

＜第１実施形態に対応する項＞
（第１項）
複数の端末から送信されたデータを集約して受信側に送信する情報通信装置であって、
前記複数の端末から送信されるデータに関する情報に基づいて、前記データを保持するために使用されるメモリ領域の更新サイズを決定する第１レイヤで動作する決定手段と、
前記更新サイズ、及び、前記データの更新レートに基づいて、前記受信側との間での通信に必要な第２レイヤのネットワークパスの帯域の設定を行う設定手段と、
を備える情報通信装置。
（第２項）
前記決定手段は、前記複数の端末の数、及び各端末から前記更新レートで送信されるデータの量に基づいて、前記更新サイズを決定する
第１項に記載の情報通信装置。
（第３項）
前記決定手段は、前記メモリ領域として、前記更新サイズの少なくとも２倍のメモリ領域を確保する
第１項又は第２項に記載の情報通信装置。
（第４項）
前記ネットワークパスにおける通信をＲＤＭＡで行うＲＤＭＡ通信手段
を更に備える第１項ないし第３項のうちいずれか１項に記載の情報通信装置。
（第５項）
前記ＲＤＭＡ通信手段は、前記受信側のノード装置から実行されるＲＤＭＡ ＲＥＡＤオペレーションに基づいて、データ送信を行う
第４項に記載の情報通信装置。
（第６項）
前記受信側のノード装置において、前記情報通信装置から受信するデータの保持時間に応じて、複数の前記更新サイズのメモリ領域が確保され、前記ＲＤＭＡ通信手段は、前記受信側のノード装置におけるデータの格納先のメモリ領域をローテーションさせる
第４項又は第５項に記載の情報通信装置。
（第７項）
複数の端末から送信されたデータを集約して受信側に送信する情報通信装置において実行される情報通信方法であって、
前記複数の端末から送信されるデータに関する情報に基づいて、前記データを保持するために使用されるメモリ領域の更新サイズを決定する第１レイヤで動作する決定手段によるステップと、
前記更新サイズ、及び、前記データの更新レートに基づいて、前記受信側との間での通信に必要な第２レイヤのネットワークパスの帯域の設定を行うステップと、
を備える情報通信方法。
（第８項）
コンピュータを、第１項ないし第６項のうちいずれか１項に記載の情報通信装置における各手段として機能させるためのプログラム。

＜第２実施形態に対応する項＞
（第１項）
複数の端末から収集されたデータを受信し、当該データからイベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、当該イベント情報に対応するデータを送信する送信手段と、を備えるイベント情報生成装置と、
特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得手段と、前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応するデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段と、を備えるデータ処理装置と、
を備えるデータ処理システム。
（第２項）
前記イベント情報は、当該イベント情報に対応するデータを格納するメモリのアドレス情報を含む
第１項に記載のデータ処理システム。
（第３項）
前記生成手段は、前記収集されたデータに対する画像分析を実施することにより前記イベント情報を生成する
第１項又は第２項に記載のデータ処理システム。
（第４項）
前記イベント情報生成装置は、前記データハブノード装置に対してＲＤＭＡを用いてデータを送信し、前記データ処理装置は、前記データハブノード装置からＲＤＭＡを用いてデータを取得する
第１項ないし第３項のうちいずれか１項に記載のデータ処理システム。
（第５項）
複数の端末から収集されたデータを受信し、当該データからイベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、当該イベント情報に対応するデータを送信する送信手段と、を備えるイベント情報生成装置と、
前記生成手段により生成した前記イベント情報に対応する前記データを受信する受信手段と、前記イベント情報を取得したデータ処理装置に対して、前記データを送信する送信手段と、を備えるデータハブノード装置と、
を備えるデータ提供システム。
（第６項）
複数の端末から収集されたデータを受信し、当該データからイベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、
イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、当該イベント情報に対応するデータを送信する送信手段と、
を備えるイベント情報生成装置。
（第７項）
特定のサービスに対応するイベント情報をブローカ装置から取得する取得手段と、
前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応するデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段と、
を備えるデータ処理装置。
（第８項）
前記データ処理装置において、前記処理手段を構成するプロセッサのプールが備えられており、当該プール又は当該プールの一部がユーザに割り当てられる
第７項に記載のデータ処理装置。
（第９項）
イベント情報生成装置とデータ処理装置とを有するデータ処理システムにおいて実行されるデータ処理方法であって、
前記イベント情報生成装置が、複数の端末から収集されたデータを受信し、当該データからイベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成ステップと、
前記イベント情報生成装置が、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成ステップにより生成したイベント情報に対応するデータハブノード装置に対して、当該イベント情報に対応するデータを送信する送信ステップと、
前記データ処理装置が、特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得ステップと、
前記データ処理装置が、前記取得ステップにより取得したイベント情報に基づいて、当該イベント情報に対応するデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理ステップと
を備えるデータ処理方法。
（第１０項）
コンピュータを、第６項に記載のイベント情報生成装置における各手段として機能させるためのプログラム。
（第１１項）
コンピュータを、第７項又は第８項に記載のデータ処理装置における各手段として機能させるためのプログラム。

以上、本実施の形態について説明したが、本発明はかかる特定の実施形態に限定されるものではなく、特許請求の範囲に記載された本発明の要旨の範囲内において、種々の変形・変更が可能である。

ＬＡ ローカル集約ノード
ＲＥ 地域エッジノード
ＡＰ アプリノード
ＭＢ メッセージブローカノード
ＤＢ データハブノード
１００ 情報通信装置
１１０ データ送信部
１２０ 制御部
１３０ ＲＤＭＡ通信部
２００ 情報通信装置
２１０ データ受信部
２２０ 制御部
２３０ ＲＤＭＡ通信部
２５０ オペレーションシステム
３００ 光ネットワーク
４００ エッジノード装置
４１０ データ送受信部
４２０ イベント情報生成部
４３０ ＲＤＭＡ通信部
４４０ 制御部
５００ メッセージブローカ装置
５１０ メッセージ受信部
５２０ メッセージ格納部
５３０ メッセージ配信部
６００ データハブノード装置
６１０ データ送受信部
６２０ ＲＤＭＡ通信部
６３０ 制御部
７００ ＡＩアプリノード装置
７１０ イベント情報処理部
７２０ データ処理部
７３０ ＲＤＭＡ通信部
７４０ 制御部
１０００ ドライブ装置
１００１ 記録媒体
１００２ 補助記憶装置
１００３ メモリ装置
１００４ ＣＰＵ
１００５ インタフェース装置
１００６ 表示装置
１００７ 入力装置
１００８ 出力装置

Claims (11)

1. 端末から収集されたデータを受信し、当該データに対する分析を行い、分析結果に基づいて、イベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、前記分析結果に基づいて当該イベント情報に対応づけられたデータを送信する送信手段と、を備えるイベント情報生成装置と、
   特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得手段と、前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応づけられたデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段と、を備えるデータ処理装置と、
   を備えるデータ処理システム。
2. 前記イベント情報は、当該イベント情報に対応するデータを格納するメモリのアドレス情報を含む
   請求項１に記載のデータ処理システム。
3. 前記生成手段は、前記収集されたデータに対する画像分析を実施することにより前記イベント情報を生成する
   請求項１又は２に記載のデータ処理システム。
4. 前記イベント情報生成装置は、前記データハブノード装置に対してＲＤＭＡを用いてデータを送信し、前記データ処理装置は、前記データハブノード装置からＲＤＭＡを用いてデータを取得する
   請求項１ないし３のうちいずれか１項に記載のデータ処理システム。
5. 端末から収集されたデータを受信し、当該データに対する分析を行い、分析結果に基づいて、イベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、前記分析結果に基づいて当該イベント情報に対応づけられたデータを送信する送信手段と、を備えるイベント情報生成装置と、
   前記生成手段により生成した前記イベント情報に対応づけられた前記データを受信する受信手段と、前記イベント情報を取得したデータ処理装置に対して、前記データを送信する送信手段と、を備えるデータハブノード装置と、
   を備えるデータ提供システム。
6. 端末から収集されたデータを受信し、当該データに対する分析を行い、分析結果に基づいて、イベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成手段と、
   イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成手段により生成したイベント情報に対応するデータハブノード装置に対して、前記分析結果に基づいて当該イベント情報に対応づけられたデータを送信する送信手段と、
   を備えるイベント情報生成装置。
7. イベント情報生成装置とデータ処理装置とを備えるデータ処理システムにおける前記データ処理装置であって、
   前記イベント情報生成装置は、端末から収集されたデータを受信し、当該データに対する分析を行い、分析結果に基づいて、イベント情報を生成し、生成したイベント情報をブローカ装置に送信し、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成したイベント情報に対応するデータハブノード装置に対して、前記分析結果に基づいて当該イベント情報に対応づけられたデータを送信し、
   特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得手段と、
   前記取得手段により取得したイベント情報に基づいて、当該イベント情報に対応づけられたデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理手段と、
   を備えるデータ処理装置。
8. 前記データ処理装置において、前記処理手段を構成するプロセッサのプールが備えられており、当該プール又は当該プールの一部がユーザに割り当てられる
   請求項７に記載のデータ処理装置。
9. イベント情報生成装置とデータ処理装置とを有するデータ処理システムにおいて実行されるデータ処理方法であって、
   前記イベント情報生成装置が、端末から収集されたデータを受信し、当該データに対する分析を行い、分析結果に基づいて、イベント情報を生成し、生成したイベント情報をブローカ装置に送信する生成ステップと、
   前記イベント情報生成装置が、イベント情報毎に異なる複数のデータハブノード装置のうちの、前記生成ステップにより生成したイベント情報に対応するデータハブノード装置に対して、前記分析結果に基づいて当該イベント情報に対応づけられたデータを送信する送信ステップと、
   前記データ処理装置が、特定のサービスに対応するイベント情報を前記ブローカ装置から取得する取得ステップと、
   前記データ処理装置が、前記取得ステップにより取得したイベント情報に基づいて、当該イベント情報に対応づけられたデータを格納するデータハブノード装置から当該データを取得し、当該データを用いた処理を実行する処理ステップと
   を備えるデータ処理方法。
10. コンピュータを、請求項６に記載のイベント情報生成装置における各手段として機能させるためのプログラム。
11. コンピュータを、請求項７又は８に記載のデータ処理装置における各手段として機能させるためのプログラム。

Images