(57)【要約】  データ処理装置（１）は、データを受信するデータ受信部（１１）と、データ受信部（１１）が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元のデータを格納する複数の入力キュー（１２１−１〜１２１−Ｎ）と、複数の入力キュー（１２１−１〜１２１−Ｎ）の各々に格納された各データを入力キュー（１２１−１〜１２１−Ｎ）ごとに読み出し、優先度が高いデータが先に処理されるように出力キュー（１４１−１）に格納するデータソート部（１３）と、を備える。
2019186920.tif 000002
【特許請求の範囲】
【請求項１】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備えることを特徴とするデータ処理装置。
【請求項２】
前記出力キューは、前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから前記データソート部によって読み出されたデータを格納する複数の出力キューであり、
前記複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部、
を備えることを特徴とする請求項１に記載のデータ処理装置。
【請求項３】
前記データ受信部は、データを受信すると、受信したデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、前記アラートフラグが立っているデータを前記出力キューに格納し、前記アラートフラグが立っていないデータを前記入力キューに格納する、
ことを特徴とする請求項２に記載のデータ処理装置。
【請求項４】
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認するフラグ確認部と、
前記アラートフラグが立っていないデータを一時的に保持するデータ保持部と、
を備え、
前記フラグ確認部は、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とする請求項１または２に記載のデータ処理装置。
【請求項５】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項４に記載のデータ処理装置。
【請求項６】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項４に記載のデータ処理装置。
【請求項７】
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認する複数のフラグ確認部と、
各々が前記複数のフラグ確認部の１つと１対１で対応付けられ、対応付けられているフラグ確認部から前記アラートフラグが立っていないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のフラグ確認部の各々は、対応付けられている入力キューからデータを読み出し、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを対応付けられている前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とする請求項１または２に記載のデータ処理装置。
【請求項８】
前記データソート部は、
データを解析して前記優先度が高いデータに該当するか否かを判定するデータ解析部と、
前記優先度が高いデータに該当しないデータを一時的に保持するデータ保持部と、
を備え、
前記データ解析部は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とする請求項１から３のいずれか一つに記載のデータ処理装置。
【請求項９】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項８に記載のデータ処理装置。
【請求項１０】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項８に記載のデータ処理装置。
【請求項１１】
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して前記優先度が高いデータに該当するか否かを判定する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が高いデータに該当しないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のデータ解析部の各々は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とする請求項１から３のいずれか一つに記載のデータ処理装置。
【請求項１２】
前記データソート部は、
データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とする請求項１から３のいずれか一つに記載のデータ処理装置。
【請求項１３】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１２に記載のデータ処理装置。
【請求項１４】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１２に記載のデータ処理装置。
【請求項１５】
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とする請求項１から３のいずれか一つに記載のデータ処理装置。
【請求項１６】
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っている場合は前記データを外部へ出力し、アラートフラグが立っていない場合には前記データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とする請求項１から３のいずれか一つに記載のデータ処理装置。
【請求項１７】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１６に記載のデータ処理装置。
【請求項１８】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１６に記載のデータ処理装置。
【請求項１９】
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っているデータを外部へ出力し、アラートフラグが立っていないデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とする請求項１から３のいずれか一つに記載のデータ処理装置。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、生産現場で収集されるデータの管理システムを構成するデータ処理装置に関する。
【背景技術】
【０００２】
近年、複数の生産現場の各々で収集される各種データをインターネットなどのネットワークを介して取得し、データを一元管理するシステムが普及している。一元管理しているデータを確認することにより、各生産現場の状況を把握することができる。また、トラブルの発生時にはデータを有効活用して原因の特定などを効率的に行うことが可能となる。【０００３】
ここで、ネットワークを介してデータを送受信する場合、１回の処理で送信可能なデータのサイズの上限は通信プロトコルなどによって決まっており、上限よりも大きいサイズのデータは分割して送信されることになる。分割されたデータは、受信された後に一纏めにされ、結合されて元の状態に戻される。また、生産現場で収集されたデータを管理する場合、各データがどの生産現場で収集されたデータであるかを容易に把握できるよう、生産現場が同じもの同士をまとめて管理するのが望ましい。そのため、各生産現場からデータを取得して管理するシステムにおいてデータを処理するデータ処理装置では、送られてくるデータを送信元が同じもの同士でまとめて保持できるよう、例えば、生産現場ごとにバッファを設け、各バッファには同じ生産現場で収集されたデータが格納されるようにする。このようにすることで、分割された状態のデータを結合する場合に都合がよく、また、同じ生産現場で得られたデータの管理が容易となる。【０００４】
例えば、特許文献１には、複数のクライアントからのデータであるリクエストを処理する情報処理装置が記載されている。特許文献１に記載の情報処理装置は、各クライアントと対応付けられたキューを準備し、リクエストを受け取ると、リクエストに含まれる識別情報が示すクライアントと対応付けられているキューにリクエストを格納する。特許文献１の構成を適用することにより、送信元が同じデータ同士をまとめて保持し、処理することができる。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特開２０１４−１０６７２８号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
生産現場から送られるデータには様々な種類のデータが存在し、その中には他のデータよりも優先して処理することが望ましいデータが存在する。例えば、機器の故障を示すデータが送られてきた場合、故障発生を管理者に通知する処理を逸早く実行することが要求される。しかしながら、特許文献１に記載の発明では、送信元が同じデータ同士をまとめて保持することができるが、保持しているデータ受け取った順番に処理するだけであり、処理するデータの順番を変更することはできない。【０００７】
本発明は、上記に鑑みてなされたものであって、優先的に処理するのが望ましいデータの処理順序を変更することが可能なデータ処理装置を得ることを目的とする。
【課題を解決するための手段】
【０００８】
上述した課題を解決し、目的を達成するために、本発明にかかるデータ処理装置は、データを受信するデータ受信部と、データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元のデータを格納する複数の入力キューと、を備える。また、データ処理装置は、複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部を備える。
【発明の効果】
【０００９】
本発明にかかるデータ処理装置は、優先的に処理するのが望ましいデータを受け取った場合に処理順序を変更することができる、という効果を奏する。
【図面の簡単な説明】
【００１０】
【図１】実施の形態１にかかるデータ処理装置を備えるデータ処理システムの構成例を示す図
【図２】実施の形態１にかかるデータ処理装置の構成例を示す図
【図３】実施の形態１にかかるデータ処理装置が受信するデータの構成例を示す図
【図４】実施の形態１にかかるデータ処理装置が備えるデータソート部の構成例を示す図
【図５】実施の形態１にかかるデータ処理装置が備えるデータソート部の動作の一例を示すフローチャート
【図６】実施の形態１にかかるデータ処理装置のデータソート部がデータを並び替える動作の一例を示すフローチャート
【図７】実施の形態１にかかるデータ処理装置が備えるデータソート部の動作の一例を示す図
【図８】実施の形態２にかかるデータ処理装置の構成例を示す図
【図９】実施の形態２にかかるデータ処理装置が備えるデータソート部の他の構成例を示す図
【図１０】実施の形態３にかかるデータ処理装置が備えるデータソート部の構成例を示す図
【図１１】実施の形態３にかかるデータ処理装置が備えるデータソート部がデータを並び替える動作の一例を示すフローチャート
【図１２】実施の形態４にかかるデータ処理装置の構成例を示す図
【図１３】実施の形態４にかかるデータ処理装置が備えるデータ受信部の動作の一例を示すフローチャート
【図１４】実施の形態５にかかるデータ処理装置が備えるデータソート部の構成例を示す図
【図１５】実施の形態５にかかるデータ処理装置が備えるデータソート部の他の構成例を示す図
【図１６】実施の形態５にかかるデータ処理装置のデータソート部がデータを並び替える動作の一例を示すフローチャート
【図１７】実施の形態５にかかるデータ処理装置のデータソート部が使用するテーブルの構成例を示す図
【図１８】実施の形態６にかかるデータ処理装置が備えるデータソート部の構成例を示す図
【図１９】実施の形態６にかかるデータ処理装置が備えるデータソート部の他の構成例を示す図
【図２０】実施の形態６にかかるデータ処理装置のデータソート部がデータを並び替える動作の一例を示すフローチャート
【図２１】各実施の形態にかかるデータ処理装置を実現するハードウェアの構成例を示す図
【発明を実施するための形態】
【００１１】
以下に、本発明の実施の形態にかかるデータ処理装置を図面に基づいて詳細に説明する。なお、この実施の形態によりこの発明が限定されるものではない。
【００１２】
実施の形態１．
図１は、本発明の実施の形態１にかかるデータ処理装置を備えるデータ処理システムの構成例を示す図である。データ処理システム１００は、データ処理装置１、データベース２、端末装置３およびアプリケーション４を含んで構成される。アプリケーション４は１つ以上存在する。端末装置３は複数であってもよい。
【００１３】
データ処理システム１００は、複数の工場のそれぞれに設置されたゲートウェイ（ＧＷ：Gate  Way）５とネットワーク７を介して接続されている。複数の工場のそれぞれには、データを生成して出力するデータ出力機器６が設置され、各データ出力機器６はゲートウェイ５と通信する機能を有する。なお、図１では、工場＃１に設けられているデータ出力機器６のみを記載し、工場＃１以外の工場に設けられているデータ出力機器６については記載を省略している。データ出力機器６は、例えばセンサであり、具体的には、温度センサ、湿度センサ、光センサ、音センサ、電圧センサ、電流センサ、赤外線センサなどである。また、複数のデータ出力機器６には、センサによるセンシングで得られたセンサ値に基づいて、産業用機器および制御装置といった各種装置の異常動作、故障発生などの判定を行い、判定結果を示すデータを生成して出力する機器が含まれる。また、複数のデータ出力機器６には、産業用機器などを非常停止させるためのスイッチが操作された場合にこれを検知し、検知結果を示すデータを生成して出力する機器が含まれる。また、複数のデータ出力機器６には、産業用機器および産業用機器を制御する制御装置も含まれる。
【００１４】
データ処理システム１００は、複数の工場のそれぞれに設置されているデータ出力機器６が出力するデータを取得して処理する。ここでの処理には、取得したデータをデータベース２に登録する処理、取得したデータを解析する処理、データの解析結果をデータベース２に登録する処理、取得したデータまたはデータの解析結果を利用してサービスを提供する処理など、取得したデータを用いて行う様々な処理が含まれる。
【００１５】
データ処理装置１は、各工場のデータ出力機器６から出力されるデータをゲートウェイ５経由で受信する。また、データ処理装置１は、受信したデータをストリーミング解析する。データ処理装置１によるストリーミング解析では、受信したデータが優先的に処理するのが望ましい特定のデータに該当するか否かを解析する処理、解析結果に基づいてデータを並べ替える処理などを行う。また、データ処理装置１は、受信したデータの解析結果に基づいてデータの出力先を決定し、決定した出力先へデータを出力する。
【００１６】
データベース２は、データ処理装置１から出力されるデータを受け取って蓄積する。
【００１７】
端末装置３は、パーソナルコンピュータ、携帯通信端末などであり、データ処理装置１と通信する機能を有する。端末装置３は、アラートを表すデータをデータ処理装置１から受信した場合にアラートをユーザに報知する。端末装置３によるユーザへの報知は、例えば、表示および音の双方、または、これらのうちの一方により行う。
【００１８】
アプリケーション４は、コンピュータでアプリケーションプログラムが実行されることにより実現される。すなわち、アプリケーション４は、アプリケーションプログラムを実行中のコンピュータである。アプリケーション４は、データベース２に蓄積されているデータのうち、必要な種類のデータを使用して処理を行う。アプリケーション４の例は、機械学習ツール、ビジネスインテリジェンスツールなどである。アプリケーション４は、例えば、データベース２に蓄積されているデータを解析することにより産業用機器を構成する各部品の劣化の状態を推測し、部品の交換時期を決定して利用者に通知する。
【００１９】
図２は、実施の形態１にかかるデータ処理装置の構成例を示す図である。実施の形態１にかかるデータ処理装置１は、データ受信部１１、入力バッファ１２、データソート部１３、出力バッファ１４およびデータ出力部１５を備える。入力バッファ１２は、複数の入力キュー１２１−１〜１２１−Ｎにより構成される。以下の説明では、入力キュー１２１−１〜１２１−Ｎの各々を区別する必要が無い場合、入力キュー１２１と記載する。
【００２０】
複数の入力キュー１２１の各々は、図１に示した各工場のゲートウェイ５のいずれか１つと１対１で対応付けられている。本実施の形態では、入力キュー１２１−１が工場＃１のゲートウェイ５と対応付けられ、入力キュー１２１−２が工場＃２のゲートウェイ５と対応付けられ、…、入力キュー１２１−Ｎが工場＃Ｎのゲートウェイ５と対応付けられているものとする。なお、入力バッファ１２を構成する入力キュー１２１の数は、各工場のゲートウェイ５の数以上であればよく、同じ数とする必要はない。出力バッファ１４は、出力キュー１４１−１により構成される。
【００２１】
データ処理装置１のデータ受信部１１は、各工場のゲートウェイ５から送信されたメッセージ形式のデータを受信し、受信したデータを送信元のゲートウェイ５に対応する入力キュー１２１に格納する。データ受信部１１は、例えば、工場＃１のゲートウェイ５から送信されたデータを受信すると、入力キュー１２１−１に格納する。
【００２２】
ここで、データ処理装置１が各ゲートウェイ５から受信するメッセージ形式のデータの構成について説明する。図３は、実施の形態１にかかるデータ処理装置が受信するデータの構成例を示す図である。図３に示したように、データ処理装置１が受信するメッセージ形式のデータは、ヘッダ部およびデータ部により構成される。ヘッダ部は、送信元のゲートウェイ５の識別情報であるゲートウェイＩＤ１０１、データの宛先の識別情報、データが分割された状態で送信されたか否かを示す情報などを含む。なお、図３ではゲートウェイＩＤを「ＩＤ」と記載している。図３ではゲートウェイＩＤ以外の情報の記載を省略している。データ部は、「Ｆ」と記載されたアラートフラグ１０２と、データ列１０３とを含む。アラートフラグ１０２は、産業用機器の故障など、異常が発生したことを通知するために使用するデータである。例えば、アラートフラグ１０２が「０」の場合は「異常なし」、アラートフラグが「１」の場合は「異常あり」を示す。アラートフラグが立っている場合、すなわち、アラートフラグ１０２に「１」が設定されている場合、優先的に処理するのが望ましいデータに該当する。優先的に処理するのが望ましいデータとは、優先度が高いデータである。データ列１０３は、アラートフラグ以外のデータであり、例えば、データ出力機器６がセンサの場合、センシング結果を表すデータと、データ出力機器６であるセンサの情報とを含む。センサの情報には、センサの種類、設置場所、識別情報、センシング結果の単位など、センシング結果を管理するために必要な情報およびセンシング結果を各種アプリケーションが利用する際に必要な情報が含まれる。なお、図３に示したゲートウェイＩＤ１０１、アラートフラグ１０２およびデータ列１０３の配置は一例であり、図示した配置に限定するものではない。アラートフラグの設定は、例えば、データ出力機器６が行うようにしてもよいし、データ出力機器６が出力するデータを判定する判定装置をデータ出力機器６とゲートウェイ５の間に設け、判定装置が設定するようにしてもよい。アラートフラグは、予め定められたフラグ設定条件が満たされた場合に設定される。例えば、データ出力機器６から出力されるデータが異常な値を示す場合にアラートフラグが設定される。
【００２３】
データ受信部１１は、メッセージ形式のデータを受信すると、ゲートウェイＩＤ１０１を確認し、ゲートウェイＩＤ１０１の値と対応する入力キューにデータを格納する。
【００２４】
データ処理装置１のデータソート部１３は、複数の入力キュー１２１の各々に格納されているデータを入力キュー１２１ごとに順番に読み出して解析し、解析結果に従った順番で各データを出力キュー１４１−１に格納する。より詳細には、データソート部１３は、読み出したデータの中にアラートフラグが立っているものがあるか否かを確認し、アラートフラグが立っているデータがあれば、それを先に出力キュー１４１−１に格納する。
【００２５】
図４は、実施の形態１にかかるデータ処理装置が備えるデータソート部の構成例を示す図である。データソート部１３は、フラグ確認部１３１およびデータ保持部１３２を備える。
【００２６】
フラグ確認部１３１は、入力キュー１２１から読み出したデータのアラートフラグの状態を確認し、フラグが立っていればデータを外部へ出力する、すなわち、出力キュー１４１−１に格納する。また、フラグ確認部１３１は、フラグが立っていない場合、データをデータ保持部１３２へ出力する。データ保持部１３２は、フラグ確認部１３１からデータを受け取るとこれを保持し、フラグ確認部１３１から出力の指示を受けると保持しているデータを外部へ出力する、すなわち、出力キュー１４１−１に格納する。フラグ確認部１３１は、読み出しを行う対象の１つの入力キュー１２１から全てのデータを読み出して入力キュー１２１が空になると、データ保持部１３２に対して、保持しているデータを出力するよう指示する。
【００２７】
図５は、実施の形態１にかかるデータ処理装置が備えるデータソート部の動作の一例を示すフローチャートである。
【００２８】
データソート部１３は、まず、パラメータｎを初期化して０に設定し（ステップＳ１）、さらに、パラメータｎに１を加算する（ステップＳ２）。データソート部１３は、次に、ｎ番目の入力キュー１２１からデータを読み出して解析し、解析結果に従った順番で出力キュー１４１−１に格納する（ステップＳ３）。例えば、入力キュー１２１−１を１番目の入力キュー、入力キュー１２１−２を２番目の入力キュー、…、入力キュー１２１−ＮをＮ番目の入力キューとした場合、データソート部１３は、ｎ＝１であれば入力キュー１２１−１に格納されている各データを読み出して解析する。
【００２９】
データソート部１３は、次に、ｎ＝Ｎであるか否かを確認し（ステップＳ４）、ｎ＝Ｎではない場合（ステップＳ４：Ｎｏ）、ステップＳ２に戻り、ｎ＝Ｎの場合（ステップＳ４：Ｙｅｓ）、ステップＳ１に戻る。
【００３０】
ここで、上記のステップＳ３の処理の詳細について、図６を用いて説明する。図６は、実施の形態１にかかるデータ処理装置のデータソート部がデータを並び替える動作の一例を示すフローチャートである。図６は、上記のステップＳ３の処理の詳細を示している。
【００３１】
ここでは、ｎ＝１の場合、すなわち、データソート部１３が入力キュー１２１−１からデータを読み出し、データを並べ替えて出力キュー１４１−１に格納する場合について、説明を行う。
【００３２】
データソート部１３のフラグ確認部１３１は、入力キュー１２１−１から先頭のデータを読み出し（ステップＳ１１）、アラートフラグがあるか否か、すなわち、アラートフラグが立った状態か否かを確認する（ステップＳ１２）。
【００３３】
アラートフラグがある場合（ステップＳ１２：Ｙｅｓ）、フラグ確認部１３１は、データを出力キュー１４１−１に出力する（ステップＳ１３）。アラートフラグがない場合（ステップＳ１２：Ｎｏ）、フラグ確認部１３１は、データをデータ保持部１３２に出力する（ステップＳ１４）。
【００３４】
フラグ確認部１３１は、ステップＳ１３またはステップＳ１４を実行後、入力キュー１２１−１にデータがあるかどうかを確認する（ステップＳ１５）。入力キュー１２１−１にデータがある場合（ステップＳ１５：Ｙｅｓ）、フラグ確認部１３１は、ステップＳ１１に戻る。入力キュー１２１−１にデータがない場合（ステップＳ１５：Ｎｏ）、フラグ確認部１３１は、データ保持部１３２に対してデータの出力を指示し、この指示を受けたデータ保持部１３２は、保持しているデータを出力キュー１４１−１に出力する（ステップＳ１６）。
【００３５】
一例として、入力キュー１２１−１にＤ１、Ｄ２およびＤ３の３つのデータが先頭から順番に格納され、データＤ３はアラートフラグ有り、データＤ１およびＤ２はアラートフラグ無しの場合、図７に示した動作となる。図７は、実施の形態１にかかるデータ処理装置が備えるデータソート部の動作の一例を示す図である。この場合、データソート部１３では、フラグ確認部１３１は、アラートフラグが無いデータＤ１およびＤ２を読み出したときにはデータ保持部１３２に出力してこれをデータ保持部１３２が保持し、アラートフラグが有るデータＤ３を読み出したときにはそのまま出力キュー１４１−１に出力する。そして、フラグ確認部１３１は、入力キュー１２１−１に格納されていた全てのデータを読み出した後、データ保持部１３２に対してデータの出力を指示する。この指示を受けたデータ保持部１３２は、保持しておいたデータを出力する。この結果、出力キュー１４１−１に格納されているデータの先頭がアラートフラグ有りのデータＤ３となり、データ処理装置１からデータＤ３、Ｄ１、Ｄ２の順番で出力されるようになる。
【００３６】
データ処理装置１のデータ出力部１５は、出力キュー１４１−１に格納されているデータを読み出して出力する。このとき、データ出力部１５は、アラートフラグが立っているデータについては端末装置３へ出力し、アラートフラグが立っていないデータについてはデータベース２へ出力する。これにより、アラートフラグが立っているデータである優先度が高いデータを受信してからデータを処理するまでの時間、すなわち、ユーザにアラートを報知するまでの所要時間を短縮することが可能となる。
【００３７】
なお、データ処理装置１は、入力キュー１２１の各々に格納されている各データを解析してアラートフラグが立っているか否かを判別し、順番を並べ替える処理を行うこととしたが、この処理に加えて、データが分割された状態で送信されてきたときに結合する処理も行うようにしてもよい。この場合、結合処理は出力キュー１４１−１の後段で行う。例えば、データ出力部１５が結合処理を行う。
【００３８】
以上のように、本実施の形態にかかるデータ処理装置は、データを受信すると送信元のデートウェイに対応する入力キューに格納して送信元が同じデータに分類する。また、データ処理装置１は、各入力キューに格納されているデータを解析して優先度が高いデータか否か、すなわち、アラートフラグが立っているか否かを判別し、優先度が高いデータが先に処理されるように並べ替えて出力する。実施の形態１にかかるデータ処理装置によれば、優先度が高いデータを受け取った場合に処理順序を変更することができ、優先度が高いデータを受け取ってから処理するまでの所要時間を短縮することができる。
【００３９】
なお、本実施の形態では、データ処理装置１のデータソート部１３が、複数の入力キュー１２１に対する処理（データを読み出して解析し、並べ替えて出力する処理）を予め決められた固定の順番で行うこととした。例えば、データソート部１３は、最初に入力キュー１２１−１に対する処理を行い、次に入力キュー１２１−２に対する処理を行い、以下、同様にて、入力キュー１２１−Ｎに対する処理までを行い、次に、処理対象を入力キュー１２１-１に戻して（入力キューを１２１−１に対する処理を再度行い）、同様の処理を繰り返し行うこととした。しかし、データソート部１３が処理を行う順番は固定されていなくてもよい。
【００４０】
例えば、データソート部１３は、まず、各入力キュー１２１に格納されているデータの数を確認し、格納されているデータの数が多い入力キュー１２１から順番に処理を行うようにしてもよい。この場合、データソート部１３は、Ｎ個の入力キュー１２１の全てに対して処理が終了するごとに、各入力キュー１２１に格納されているデータの数を確認し、処理を行う順番を決定する（第１の順番決定方法）。この第１の順番決定方法を使用する場合、各入力キュー１２１にデータが格納されてから出力されるまでの滞留時間すなわち処理遅延を平均的に小さくすることができる。
【００４１】
上記第１の順番決定方法とは逆に、データソート部１３は、格納されているデータの数が少ない入力キュー１２１から順番に処理を行うようにしてもよい（第２の順番決定方法）。この第２の順番決定方法を使用する場合、アラートフラグが立っていないデータ（以下、「フラグ無しデータ」とする）については処理遅延時間が大きくなる場合があるが、最後に処理される入力キュー１２１に格納されている、アラートフラグが立っているデータ（以下、「フラグ有データ」とする）については処理遅延時間を小さくできる。例えば、データ処理装置が入力キューＡ、ＢおよびＣの３つの入力キューを備え、入力キューＡには３つのデータが格納され、入力キューＢには１つのデータが格納され、入力キューＣには２つのデータが格納され、かつ各入力キューに格納されているデータにはフラグ有データが１つずつ含まれている状態とする。この場合、上記の第１の順番決定方法に従った動作では、データソート部１３は、入力キューＡ、入力キューＣ、入力キューＢの順番でデータを読み出す。そのため、入力キューＡに格納されているフラグ有データが全体の１番目にデータソート部１３から出力され、入力キューＣに格納されているフラグ有データが全体の４番目にデータソート部１３から出力され、入力キューＢに格納されているフラグ有データが全体の６番目にデータソート部１３から出力される。これに対して、上記の第２の順番決定方法に従った動作では、データソート部１３は、入力キューＢ、入力キューＣ、入力キューＡの順番でデータを読み出す。そのため、入力キューＢに格納されているフラグ有データが全体の１番目にデータソート部１３から出力され、入力キューＣに格納されているフラグ有データが全体の２番目にデータソート部１３から出力され、入力キューＡに格納されているフラグ有データが全体の４番目にデータソート部１３から出力される。第１の順番決定方法に従った動作では、３つのフラグ有データのうちの３つ目（最後に処理される入力キューＢに格納されているフラグ有データ）が全体の６番目に出力されることになるが、第２の順番決定方法に従った動作では、３つのフラグ有データのうちの３つ目（最後に処理される入力キューＡに格納されているフラグ有データ）が全体の４番目に出力されるようになり、処理遅延を小さくできる。
【００４２】
実施の形態２．
図８は、実施の形態２にかかるデータ処理装置の構成例を示す図である。なお、実施の形態２にかかるデータ処理装置を備えるデータ処理システムの構成は実施の形態１と同様である。
【００４３】
本実施の形態にかかるデータ処理装置１ａは、実施の形態１にかかるデータ処理装置１のデータソート部１３、出力バッファ１４およびデータ出力部１５を、それぞれ、データソート部１３ａ、出力バッファ１４ａおよびデータ出力部１５−１〜１５−Ｎに置き換えたものである。出力バッファ１４ａは、出力キュー１４１−１〜１４１−Ｎを備える。出力キュー１４１−１〜１４１−Ｎおよびデータ出力部１５−１〜１５−Ｎは、入力キュー１２１−１〜１２１−Ｎと対応付けられている。具体的には、出力キュー１４１−ｎおよびデータ出力部１５−ｎは、入力キュー１２１−ｎと対応付けられている（ｎ＝１，２，…，Ｎ）。なお、以下の説明では、出力キュー１４１−１〜１４１−Ｎの各々を区別する必要が無い場合、出力キュー１４１と記載する。同様に、データ出力部１５−１〜１５−Ｎを区別する必要が無い場合、データ出力部１５と記載する。また、本実施の形態では、データ処理装置１と異なる構成および動作について説明を行う。
【００４４】
データソート部１３ａは、実施の形態１にかかるデータ処理装置１のデータソート部１３と同様に、複数の入力キュー１２１の各々に格納されているデータを入力キュー１２１ごとに順番に読み出して解析し、解析結果に従った順番で各データを出力する。ただし、データソート部１３ａは、データの読み出し元の入力キュー１２１と対応付けられている出力キュー１４１に出力する。すなわち、データソート部１３ａは、入力キュー１２１−ｎから読み出したデータを出力キュー１４１−ｎに出力する（ｎ＝１，２，…，Ｎ）。データソート部１３ａの構成は、図４に示したデータソート部１３の構成と同様である。ただし、上述したように、データソート部１３ａは、データの出力先が出力キュー１４１−１〜１４１−Ｎとなる。データソート部１３ａのフラグ確認部１３１は、データ保持部１３２にデータの出力を指示する際、出力先を指定する。データソート部１３ａのデータ保持部１３２は、フラグ確認部１３１から指定された出力キューに対して保持しているデータを出力する。
【００４５】
データ出力部１５−１〜１５−Ｎは、それぞれ、出力キュー１４１−１〜１４１−Ｎに格納されているデータを読み出して出力する。データ出力部１５−１〜１５−Ｎの動作は、実施の形態１にかかるデータ処理装置１のデータ出力部１５の動作と同様であり、フラグ有データについては端末装置３へ出力し、フラグ無しデータについてはデータベース２へ出力する。各データ出力部１５は、対応付けられている出力キュー１４１からデータを読み出す。
【００４６】
図８に示した構成のデータ処理装置１ａは、入力キュー１２１と同じ数の出力キュー１４１およびデータ出力部１５を備えるため、データ処理装置１ａにデータが入力されてから出力されるまでの処理遅延時間を実施の形態１にかかるデータ処理装置１よりも小さくすることができる。すなわち、図８に示した構成のデータ処理装置１ａは、優先度が高いデータを受け取ってから処理するまでの所要時間を、実施の形態１にかかるデータ処理装置１よりもさらに短縮することができる。
【００４７】
データソート部１３ａの構成を図９に示したものとしてもよい。図９は、実施の形態２にかかるデータ処理装置が備えるデータソート部の他の構成例を示す図である。図９に示したデータソート部１３ａは、フラグ確認部１３１−１〜１３１−Ｎと、データ保持部１３２−１〜１３２−Ｎと、を備える。フラグ確認部１３１−１〜１３１−Ｎは、それぞれ、入力キュー１２１−１〜１２１−Ｎと対応付けられ、対応付けられている入力キューからデータを読み出す。具体的には、フラグ確認部１３１−ｎは、入力キュー１２１−ｎと対応付けられている（ｎ＝１，２，…，Ｎ）。さらに、フラグ確認部１３１−１〜１３１−Ｎは、それぞれ、出力キュー１４１−１〜１４１−Ｎと対応付けられ、対応付けられている出力キューにデータを格納する。具体的には、フラグ確認部１３１−ｎは、出力キュー１４１−ｎと対応付けられている。また、データ保持部１３２−ｎは、出力キュー１４１−ｎと対応付けられている。
【００４８】
フラグ確認部１３１−１〜１３１−Ｎは、実施の形態１にかかるデータソート部１３のフラグ確認部１３１と同様の動作を行う。また、データ保持部１３２−１〜１３２−Ｎは、実施の形態１にかかるデータソート部１３のデータ保持部１３２と同様の動作を行う。ただし、フラグ確認部１３１−１〜１３１−Ｎおよびデータ保持部１３２−１〜１３２−Ｎは、対応付けられている入力キュー１２１−１〜１２１−Ｎに格納されているデータを対象として、解析および並べ替えを行う。具体的には、フラグ確認部１３１−１〜１３１−Ｎおよびデータ保持部１３２−１〜１３２−Ｎは、図６に示したフローチャートに従った動作を予め定められた一定の周期が経過するごとに繰り返し実行する。例えば、フラグ確認部１３１−１およびデータ保持部１３２−１は、入力キュー１２１−１に格納されているデータを対象として、図６に示したフローチャートに従った動作を予め定められた一定の周期で繰り返し実行する。
【００４９】
実施の形態１にかかるデータソート部１３は、入力キュー１２１−１〜１２１−Ｎの各々に対する処理、具体的には、データを読み出して解析し、並べ替える処理を、入力キュー１２１−１〜１２１−Ｎに対して順番に行う。これに対して、図９に示した構成のデータソート部１３ａは、入力キュー１２１−１〜１２１−Ｎの各々に対する処理を、一定の周期で並列に行う。
【００５０】
以上のように、図９に示した構成のデータソート部１３ａを備えるデータ処理装置１ａは、各入力キュー１２１に格納されているデータを解析して優先度が高いデータか否か、すなわち、アラートフラグが立っているデータであるフラグ有データか否かを判別し、フラグ有データが先に処理されるように並べ替えて出力する処理を並列に行う。これにより、データ処理装置１ａは、各入力キュー１２１に格納されているデータに対する処理を順番に行う場合と比較して、優先度が高いデータを受け取ってから処理するまでの所要時間をさらに短縮することができる。
【００５１】
実施の形態３．
実施の形態１，２では、工場から送信されてくるデータに予めアラートフラグが設定されていたが、本実施の形態では、データ処理装置がデータを解析してアラートフラグを設定する。実施の形態３にかかるデータ処理装置を備えるデータ処理システムの構成は実施の形態１と同様である。各工場のゲートウェイ５からデータ処理システムに送信されてくるデータにはアラートフラグが設定されていないものとする。
【００５２】
本実施の形態にかかるデータ処理装置は、実施の形態１にかかるデータ処理装置のデータソート部１３を図１０に示したデータソート部１３ｂに置き換えたものとなる。なお、図１０は、実施の形態３にかかるデータ処理装置が備えるデータソート部の構成例を示す図である。
【００５３】
本実施の形態にかかるデータ処理装置のデータソート部１３ｂは、データ解析部１３３およびデータ保持部１３２を備える。データ保持部１３２は、実施の形態１にかかるデータソート部１３のデータ保持部１３２と同じものである。
【００５４】
データ解析部１３３は、入力キュー１２１から読み出したデータが正常な値か否かを判定し、データが異常な値の場合、データにアラートフラグを設定して外部へ出力する、すなわち、出力キュー１４１に格納する。データ解析部１３３は、例えば、読み出したデータを予め定められた閾値と比較して異常な値か否かを判定する。判定に用いるしきい値は、データ送信元のデータ出力機器６の種類およびデータ出力機器６の設置場所といった条件に応じて適宜切り替える。また、データ解析部１３３は、読み出したデータが正常な値の場合、データをデータ保持部１３２へ出力する。データ解析部１３３は、読み出しを行う対象の１つの入力キュー１２１から全てのデータを読み出して入力キュー１２１が空になると、データ保持部１３２に対して、保持しているデータを出力するよう指示する。
【００５５】
本実施の形態にかかるデータ処理装置が備えるデータソート部１３ｂの全体の動作は、実施の形態１にかかるデータ処理装置の説明で用いた図５のフローチャートに従ったものとなる。ただし、ステップＳ３の処理の詳細が異なる。本実施の形態にかかるデータ処理装置が備えるデータソート部１３ｂによるステップＳ３の処理の詳細は図１１に示したものとなる。図１１は、実施の形態３にかかるデータ処理装置が備えるデータソート部がデータを並び替える動作の一例を示すフローチャートである。
【００５６】
データソート部１３ｂがデータを並び替える動作の詳細について図１１を参照しながら説明する。ここでは、ｎ＝１の場合、すなわち、データソート部１３ｂが入力キュー１２１−１からデータを読み出して出力する場合について、説明を行う。
【００５７】
データソート部１３ｂのデータ解析部１３３は、入力キュー１２１−１から先頭のデータを読み出し（ステップＳ２１）、読み出したデータを解析する（ステップＳ２２）。具体的には、データ解析部１３３は、読み出したデータが異常な値を示すか否かを、データをしきい値と比較するなどして判定する。
【００５８】
データが異常値の場合（ステップＳ２３：Ｙｅｓ）、データ解析部１３３は、読み出したデータにアラートフラグを設定して出力キュー１４１に出力する（ステップＳ２４）。一方、データが正常値の場合（ステップＳ２３：Ｎｏ）、データ解析部１３３は、データをデータ保持部１３２に出力する（ステップＳ２５）。
【００５９】
データ解析部１３３は、ステップＳ２４またはステップＳ２５を実行後、入力キュー１２１−１にデータがあるかどうかを確認する（ステップＳ２６）。入力キュー１２１−１にデータがある場合（ステップＳ２６：Ｙｅｓ）、データ解析部１３３は、ステップＳ２１に戻る。入力キュー１２１−１にデータがない場合（ステップＳ２６：Ｎｏ）、データ解析部１３３は、データ保持部１３２に対してデータの出力を指示し、この指示を受けたデータ保持部１３２は、保持しているデータを出力キュー１４１に出力する（ステップＳ２７）。
【００６０】
本実施の形態では、実施の形態１にかかるデータ処理装置１のデータソート部１３（図４参照）のフラグ確認部１３１をデータ解析部１３３に置き換え、アラートフラグを設定するデータ処理装置について説明した。また、実施の形態２にかかるデータ処理装置１ａのデータソート部１３ａが図９に示した構成の場合、フラグ確認部１３１−１〜１３１−Ｎのそれぞれを上述したデータ解析部１３３に置き換えることが可能である。
【００６１】
以上のように、本実施の形態にかかるデータ処理装置において、データソート部は、各入力キューに格納されているデータを解析して異常値か否かを判別し、データが異常値を示す場合には先に処理されるように並べ替えて出力する。本実施の形態にかかるデータ処理装置は、アラートフラグを設定する機能を有さないデータ出力機器から出力されるデータを受信する場合であっても、優先度が高いデータか否かを判別することができ、実施の形態１，２にかかるデータ処理装置と同様に、優先度が高いデータを受け取った場合に処理順序を変更し、優先度が高いデータを受け取ってから処理するまでの所要時間を短縮することができる。
【００６２】
実施の形態４．
図１２は、実施の形態４にかかるデータ処理装置の構成例を示す図である。なお、実施の形態４にかかるデータ処理装置を備えるデータ処理システムの構成は実施の形態１と同様である。本実施の形態では、実施の形態１，２と同様に、各工場のゲートウェイ５からデータ処理システムに送信されてくるデータにはアラートフラグが設定されているものとする。
【００６３】
本実施の形態にかかるデータ処理装置１ｃは、実施の形態２にかかるデータ処理装置１ａのデータ受信部１１およびデータソート部１３ａを、それぞれ、データ受信部１１ｃおよびデータソート部１３ｂに置き換えたものである。
【００６４】
データ受信部１１ｃは、各工場のゲートウェイ５から受信したデータを解析し、解析結果に基づいて、受信したデータを入力バッファ１２または出力バッファ１４ａに格納する。具体的には、データ受信部１１ｃは、受信したデータにアラートフラグが設定されていない場合、データ送信元のゲートウェイ５に対応する入力キュー１２１にデータを格納し、受信したデータにアラートフラグが設定されている場合、データ送信元のゲートウェイ５に対応する出力キュー１４１に格納する。
【００６５】
図１３は、実施の形態４にかかるデータ処理装置が備えるデータ受信部の動作の一例を示すフローチャートである。
【００６６】
データ受信部１１ｃは、動作を開始すると、データを受信したか否かを確認し（ステップＳ３１）、データを受信しない場合（ステップＳ３１：Ｎｏ）、ステップＳ３１の処理を繰り返す。データ受信部１１ｃは、データを受信した場合（ステップＳ３１：Ｙｅｓ）、受信したデータにアラートフラグがあるか否か、すなわち、フラグ有データか否かを確認する（ステップＳ３２）。データ受信部１１ｃは、受信したデータがフラグ有データの場合（ステップＳ３２：Ｙｅｓ）、データに含まれるゲートウェイＩＤに対応する出力キュー１４１にデータを格納する（ステップＳ３３）。データ受信部１１ｃは、受信したデータがフラグ無しデータの場合（ステップＳ３２：Ｎｏ）、データに含まれるゲートウェイＩＤに対応する入力キュー１２１にデータを格納する（ステップＳ３４）。
【００６７】
データソート部１３ｂは、実施の形態３で説明したデータソート部１３ｂと同一である（図１０および図１１参照）。すなわち、データソート部１３ｂは、各入力キュー１２１から読み出したデータを解析して異常値か否かを判別し、異常値を示すデータが正常値を示すデータよりも先に出力されるよう並べ替えて出力キュー１４１に格納する。
【００６８】
このように、本実施の形態にかかるデータ処理装置１ｃにおいて、データ受信部１１ｃは、受信したデータが優先度が高いデータであるフラグ有データの場合、入力キューに格納するのではなく出力キュー１４１に格納する。そのため、データ処理装置１ｃは、受信したデータを入力キューに格納してから優先度が高いデータか否かを判定する実施の形態１〜３にかかるデータ処理装置と比較して、優先度が高いデータを受け取ってから処理するまでの所要時間をさらに短縮することができる。
【００６９】
また、本実施の形態にかかるデータ処理装置において、データソート部はデータを解析して異常値か否かを判定し、異常値が正常値よりも先に処理されるように並べ替えて出力キューに格納する。これにより、データ処理装置は、アラートフラグを設定する機能を有さないデータ出力機器から出力されるデータを受信する場合であっても、優先度が高いデータか否かを判別することができ、優先度が高いデータを受け取ってから処理するまでの所要時間を短縮することができる。
【００７０】
実施の形態５．
つづいて、実施の形態５にかかるデータ処理装置について説明する。実施の形態５にかかるデータ処理装置を備えるデータ処理システムの構成は実施の形態１と同様である。実施の形態１，２などでは、工場から送信されてくるデータに予めアラートフラグが設定されていたが、本実施の形態では、工場から送信されてくるデータが、アラートフラグに加えてデータの種類を示す情報を含むものとする。
【００７１】
本実施の形態にかかるデータ処理装置は、図１２に示す実施の形態４にかかるデータ処理装置１１ｃのデータソート部１３ｂを、図１４に示すデータソート部１３ｃまたは図１５に示すデータソート部１３ｄに置き換えたものである。なお、図１４は、実施の形態５にかかるデータ処理装置が備えるデータソート部の構成例を示す図、図１５は、実施の形態５にかかるデータ処理装置が備えるデータソート部の他の構成例を示す図である。
【００７２】
図１４に示したように、データソート部１３ｃは、データ解析部１３４、データ保持部１３５およびデータ読出部１３６を備える。データソート部１３ｃは、実施の形態１で説明したデータソート部１３と同様に、複数の入力キュー１２１の各々に格納されているデータを入力キュー１２１ごとに順番に読み出して解析し、解析結果に従った順番で各データを出力キュー１４１に出力する。ただし、データソート部１３ｃは、データの送信元のゲートウェイ５に対応する出力キューにデータを出力する。
【００７３】
データソート部１３ｃのデータ解析部１３４は、データを解析し、解析結果に基づく優先度をデータに付与して出力する。データ保持部１３５は、データ解析部１３４から入力されたデータを保持する。データ読出部１３６は、データ保持部１３５で保持されているデータを優先度の高いものから順番に読み出して出力する。
【００７４】
また、図１５に示したように、データソート部１３ｄは、データ解析部１３４−１〜１３４−Ｎ、データ保持部１３５−１〜１３５−Ｎおよびデータ読出部１３６−１〜１３６−Ｎを備える。データ解析部１３４−１〜１３４−Ｎは、データソート部１３ｃのデータ解析部１３４と同様のものである。データ保持部１３５−１〜１３５−Ｎは、データソート部１３ｃのデータ保持部１３５と同様のものである。データ読出部１３６−１〜１３６−Ｎは、データソート部１３ｃのデータ読出部１３６と同様のものである。また、データ解析部１３４−ｎ、データ保持部１３５−ｎおよびデータ読出部１３６−ｎは、入力キュー１２１−ｎに格納されたデータを対象として並べ替え処理を行い、並べ替えた後のデータを出力キュー１４１−ｎに格納する（ｎ＝１，２，…，Ｎ）。
【００７５】
図１６は、実施の形態５にかかるデータ処理装置のデータソート部がデータを並び替える動作の一例を示すフローチャートである。
【００７６】
ここでは、図１４に示したデータソート部１３ｃが、入力キュー１２１−１からデータを読み出して並べ替えを行い、出力キュー１４１−１に格納する場合について、説明を行う。
【００７７】
データソート部１３ｃのデータ解析部１３４は、入力キュー１２１−１から先頭のデータを読み出し（ステップＳ４１）、解析する（ステップＳ４２）。ステップＳ４２において、データ解析部１３４は、データの種類を確認する。次に、データ解析部１３４は、データに優先度を付加してデータ保持部１３５に出力し、データ保持部１３５は優先度が付加されたデータを保持する（ステップＳ４３）。データ解析部１３４は、例えば、データの種類と優先度との対応関係を示すテーブルを保持しておき、テーブルを参照することにより優先度を決定してデータに付加する。この場合、データ解析部１３４は、図１７に示したようなテーブルを保持しておく。図１７は、実施の形態５にかかるデータ処理装置のデータソート部が使用するテーブルの構成例を示す図である。なお、図１７に示したテーブルでは、数値が小さいほど優先度が高い。データ解析部１３４は、図１７に示した構成のテーブルを参照してデータに優先度を付加する場合、故障を示すデータに対して優先度「１」を付加し、エラーを示すデータに対して優先度「２」を付加し、警告を示すデータに対して優先度「３」を付加し、測定値を示すデータに対して優先度「４」を付加する。
【００７８】
次に、データ解析部１３４は、入力キュー１２１−１にデータがあるかどうかを確認し（ステップＳ４４）、入力キュー１２１−１にデータがある場合（ステップＳ４４：Ｙｅｓ）、ステップＳ４１に戻る。入力キュー１２１−１にデータがない場合（ステップＳ４４：Ｎｏ）、データ解析部１３４は、データ読出部１３６に対して、データ保持部１３５からデータを読み出して出力するよう指示する。この指示を受けたデータ読出部１３６は、データ保持部１３５が保持しているデータを優先度に従った順番で出力キュー１４１−１に出力する（ステップＳ４５）。すなわち、データ読出部１３６は、データ保持部１３５で保持されている各データを優先度が高いものから順番に読み出して出力キュー１４１−１に格納する。
【００７９】
ここでは、データソート部１３ｃが、入力キュー１２１−１からデータを読み出して並べ替えを行い、出力キュー１４１−１に格納する場合について、説明したが、データソート部１３ｃが他の入力キュー１２１からデータを読み出す場合の処理も同様である。また、データソート部１３ｄが入力キュー１２１の各々からデータを読み出して並べ替えを行い、出力キュー１４１の各々に格納する動作も同様である。なお、データソート部１３ｄでは、図１６に示したフローチャートに従った動作を並列に実行する。
【００８０】
このように、本実施の形態にかかるデータ処理装置において、データソート部は、各入力キューに格納されているデータを解析し、データの種類に応じた優先度が高いものほど先に処理されるように並べ替えて出力する。本実施の形態にかかるデータ処理装置は、フラグ有データの処理遅延時間を、実施の形態４にかかるデータ処理装置を適用する場合と同等にすることができ、さらに、フラグ無しデータについては、優先度が高い種類のデータほど、データを受け取ってから処理するまでの所要時間を短くすることができる。
【００８１】
実施の形態６．
実施の形態５では、実施の形態４にかかるデータ処理装置１１ｃのデータソート部１３ｂを、図１４に示すデータソート部１３ｃまたは図１５に示すデータソート部１３ｄに置き換える場合について説明したが、実施の形態２にかかるデータ処理装置１ａのデータソート部１３ａを、図１８に示すデータソート部１３ｅまたは図１９に示すデータソート部１３ｆに置き換えてもよい。図１８は、実施の形態６にかかるデータ処理装置が備えるデータソート部の構成例を示す図、図１９は、実施の形態６にかかるデータ処理装置が備えるデータソート部の他の構成例を示す図である。
【００８２】
図１８に示したように、データソート部１３ｅは、データ解析部１３４ｅ、データ保持部１３５ｅおよびデータ読出部１３６ｅを備える。データソート部１３ｅは、実施の形態１で説明したデータソート部１３と同様に、複数の入力キュー１２１の各々に格納されているデータを入力キュー１２１ごとに順番に読み出して解析し、解析結果に従った順番で各データを出力キュー１４１に出力する。ただし、データソート部１３ｅは、データの送信元のゲートウェイ５に対応する出力キューにデータを出力する。
【００８３】
データソート部１３ｅのデータ解析部１３４ｅは、データがフラグ有データか否かを確認し、フラグ有データの場合は出力キュー１４１に出力し、フラグ無しデータの場合は、さらに、データの種類を確認し、データの種類に基づく優先度をデータに付与してデータ保持部１３５ｅに出力する。データ保持部１３５ｅは、データ解析部１３４ｅから入力されたデータを保持する。データ読出部１３６ｅは、データ保持部１３５ｅで保持されているデータを優先度の高いものから順番に読み出して出力する。
【００８４】
また、図１９に示したように、データソート部１３ｆは、データ解析部１３４ｅ−１〜１３４ｅ−Ｎ、データ保持部１３５ｅ−１〜１３５ｅ−Ｎおよびデータ読出部１３６ｅ−１〜１３６ｅ−Ｎを備える。データ解析部１３４ｅ−１〜１３４ｅ−Ｎは、データソート部１３ｅのデータ解析部１３４ｅと同様のものである。データ保持部１３５ｅ−１〜１３５ｅ−Ｎは、データソート部１３ｅのデータ保持部１３５ｅと同様のものである。データ読出部１３６ｅ−１〜１３６ｅ−Ｎは、データソート部１３ｅのデータ読出部１３６ｅと同様のものである。また、データ解析部１３４ｅ−ｎ、データ保持部１３５ｅ−ｎおよびデータ読出部１３６ｅ−ｎは、入力キュー１２１−ｎに格納されたデータを対象として並べ替え処理を行い、並べ替えた後のデータを出力キュー１４１−ｎに格納する（ｎ＝１，２，…，Ｎ）。
【００８５】
図２０は、実施の形態６にかかるデータ処理装置のデータソート部がデータを並び替える動作の一例を示すフローチャートである。
【００８６】
ここでは、図１８に示したデータソート部１３ｅが、入力キュー１２１−１からデータを読み出して並べ替えを行い、出力キュー１４１−１に格納する場合について、説明を行う。
【００８７】
データソート部１３ｅのデータ解析部１３４ｅは、入力キュー１２１−１から先頭のデータを読み出し（ステップＳ５１）、アラートフラグがあるか否か、すなわち、フラグ有データか否かを確認する（ステップＳ５２）。データ解析部１３４ｅは、フラグ有データの場合（ステップＳ５２：Ｙｅｓ）、データを出力キュー１４１−１に出力する（ステップＳ５５）。データ解析部１３４ｅは、フラグ有データではない、すなわちフラグ無しデータの場合（ステップＳ５２：Ｎｏ）、データを解析する（ステップＳ５３）。ステップＳ５３において、データ解析部１３４ｅは、データの種類を確認する。次に、データ解析部１３４ｅは、データに優先度を付加してデータ保持部１３５ｅに出力し、データ保持部１３５ｅは優先度が付加されたデータを保持する（ステップＳ５４）。データ解析部１３４ｅは、実施の形態５で説明したデータ解析部１３４と同様の方法で優先度を決定してデータに付加する。
【００８８】
次に、データ解析部１３４ｅは、入力キュー１２１−１にデータがあるかどうかを確認し（ステップＳ５６）、入力キュー１２１−１にデータがある場合（ステップＳ５６：Ｙｅｓ）、ステップＳ５１に戻る。入力キュー１２１−１にデータがない場合（ステップＳ５６：Ｎｏ）、データ解析部１３４ｅは、データ読出部１３６ｅに対して、データ保持部１３５ｅからデータを読み出して出力するよう指示する。この指示を受けたデータ読出部１３６ｅは、データ保持部１３５ｅが保持しているデータを優先度に従った順番で出力キュー１４１−１に出力する（ステップＳ５７）。すなわち、データ読出部１３６ｅは、データ保持部１３５ｅで保持されている各データを優先度が高いものから順番に読み出して出力キュー１４１−１に格納する。
【００８９】
ここでは、データソート部１３ｅが、入力キュー１２１−１からデータを読み出して並べ替えを行い、出力キュー１４１−１に格納する場合について、説明したが、データソート部１３ｅが他の入力キュー１２１からデータを読み出す場合の処理も同様である。また、データソート部１３ｆが入力キュー１２１の各々からデータを読み出して並べ替えを行い、出力キュー１４１の各々に格納する動作も同様である。なお、データソート部１３ｆでは、図２０に示したフローチャートに従った動作を並列に実行する。
【００９０】
このように、本実施の形態にかかるデータ処理装置において、データソート部は、各入力キューに格納されているデータを解析し、フラグ有データがフラグ無しデータよりも先に処理され、かつ、フラグ無しデータについてはデータの種類に応じた優先度が高いものほど先に処理されるように並べ替えて出力する。本実施の形態にかかるデータ処理装置は、フラグ有データを受け取ってから処理するまでの所要時間を短くすることができ、さらに、フラグ無しデータについては、優先度が高い種類のデータほど、データを受け取ってから処理するまでの所要時間を短くすることができる。
【００９１】
なお、本実施の形態では、実施の形態２にかかるデータ処理装置１ａのデータソート部１３ａを、図１８に示すデータソート部１３ｅまたは図１９に示すデータソート部１３ｆに置き換える場合について説明したが、実施の形態１にかかるデータ処理装置１のデータソート部１３を、図１８に示すデータソート部１３ｅに置き換えてもよい。
【００９２】
次に、各実施の形態で説明したデータ処理装置を実現するハードウェアの構成について説明する。図２１は、各実施の形態にかかるデータ処理装置を実現するハードウェアの構成例を示す図である。
【００９３】
データ処理装置１は、図２１に示したプロセッサ２０１、メモリ２０２およびインタフェース回路２０３を備えたハードウェアにより実現できる。プロセッサ２０１は、ＣＰＵ（Central  Processing  Unit、中央処理装置、処理装置、演算装置、マイクロプロセッサ、マイクロコンピュータ、ＤＳＰ（Digital  Signal  Processor）ともいう）、システムＬＳＩ（Large  Scale  Integration）などである。また、メモリ２０２は、ＲＡＭ（Random  Access  Memory）、ＲＯＭ（Read  Only  Memory）、フラッシュメモリー、ＥＰＲＯＭ（Erasable  Programmable  ＲＯＭ）、ＥＥＰＲＯＭ（登録商標）（Electrically  Erasable  Programmable  ＲＯＭ）などである。データ処理装置１を実現するハードウェアは、表示装置、入力装置、通信装置などをさらに備えた構成であってもよい。
【００９４】
たとえば、実施の形態１にかかるデータ処理装置１の場合、データ受信部１１およびデータ出力部１５はインタフェース回路２０３により実現される。また、入力バッファ１２および出力バッファ１４は、メモリ２０２により実現される。データソート部１３は、データソート部１３として動作するためのプログラムをプロセッサ２０１がメモリ２０２から読み出して実行することにより実現される。実施の形態１にかかるデータ処理装置１を実現する場合について説明したが、その他の実施の形態にかかるデータ処理装置についても同様である。
【００９５】
なお、各実施の形態では、クラウド側に設置されたデータ処理装置がデータを並べ替えて優先度が高いデータが他のデータよりも先に処理されるようにしていたが、データの並べ替えは工場内の装置が行うようにすることも可能である。すなわち、各実施の形態で説明したデータ処理装置のデータソート部が行う、１つの入力キューからデータを読み出して解析を行い並べ替える処理を、各工場のゲートウェイ５の前段で行うようにしてもよい。
【００９６】
また、各実施の形態では、生産現場で得られるデータ、すなわち、工場に設置されたデータ出力機器が出力したデータを対象としてデータの解析および並べ替えを行うデータ処理装置について説明したが、データ処理装置が取り扱うデータは生産現場で得られるデータに限定されない。複数の拠点の各々に設置されたゲートウェイを介して各拠点内の機器から出力されるデータを取得する構成のシステムに対して、各実施の形態で説明したデータ処理装置を適用可能である。複数の拠点の例は、商品の販売店、企業の支社または営業所、などである。
【００９７】
以上の実施の形態に示した構成は、本発明の内容の一例を示すものであり、別の公知の技術と組み合わせることも可能であるし、本発明の要旨を逸脱しない範囲で、構成の一部を省略、変更することも可能である。
【符号の説明】
【００９８】
１，１ａ，１ｃ  データ処理装置、２  データベース、３  端末装置、４  アプリケーション、５  ゲートウェイ、６  データ出力機器、７  ネットワーク、１１，１１ｃ  データ受信部、１２  入力バッファ、１３，１３ａ，１３ｂ，１３ｃ，１３ｄ，１３ｅ，１３ｆ  データソート部、１４，１４ａ  出力バッファ、１５，１５−１〜１５−Ｎ  データ出力部、１００  データ処理システム、１２１−１〜１２１−Ｎ  入力キュー、１３１，１３１−１〜１３１−Ｎ  フラグ確認部、１３２，１３２−１〜１３２−Ｎ，１３５，１３５−１〜１３５−Ｎ，１３５ｅ，１３５ｅ−１〜１３５ｅ−Ｎ  データ保持部、１３３，１３４，１３４−１〜１３４−Ｎ，１３４ｅ，１３４ｅ−１〜１３４ｅ−Ｎ  データ解析部、１３６，１３６−１〜１３６−Ｎ，１３６ｅ，１３６ｅ−１〜１３６ｅ−Ｎ  データ読出部、１４１−１〜１４１−Ｎ  出力キュー。
【図１】
2019186920.tif 000003
【図２】
2019186920.tif 000004
【図３】
2019186920.tif 000005
【図４】
2019186920.tif 000006
【図５】
2019186920.tif 000007
【図６】
2019186920.tif 000008
【図７】
2019186920.tif 000009
【図８】
2019186920.tif 000010
【図９】
2019186920.tif 000011
【図１０】
2019186920.tif 000012
【図１１】
2019186920.tif 000013
【図１２】
2019186920.tif 000014
【図１３】
2019186920.tif 000015
【図１４】
2019186920.tif 000016
【図１５】
2019186920.tif 000017
【図１６】
2019186920.tif 000018
【図１７】
2019186920.tif 000019
【図１８】
2019186920.tif 000020
【図１９】
2019186920.tif 000021
【図２０】
2019186920.tif 000022
【図２１】
2019186920.tif 000023
【手続補正書】
【提出日】平成30年11月2日(2018.11.2)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから読み出されたデータを格納する複数の出力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように、データを読み出した入力キューと対応付けられている出力キューに格納するデータソート部と、
前記複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部と、
を備えることを特徴とするデータ処理装置。
【請求項２】
前記データ受信部は、データを受信すると、受信したデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、前記アラートフラグが立っているデータを前記出力キューに格納し、前記アラートフラグが立っていないデータを前記入力キューに格納する、
ことを特徴とする請求項１に記載のデータ処理装置。
【請求項３】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認するフラグ確認部と、
前記アラートフラグが立っていないデータを一時的に保持するデータ保持部と、
を備え、
前記フラグ確認部は、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項４】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項３に記載のデータ処理装置。
【請求項５】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項３に記載のデータ処理装置。
【請求項６】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認する複数のフラグ確認部と、
各々が前記複数のフラグ確認部の１つと１対１で対応付けられ、対応付けられているフラグ確認部から前記アラートフラグが立っていないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のフラグ確認部の各々は、対応付けられている入力キューからデータを読み出し、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを対応付けられている前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項７】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
データを解析して前記優先度が高いデータに該当するか否かを判定するデータ解析部と、
前記優先度が高いデータに該当しないデータを一時的に保持するデータ保持部と、
を備え、
前記データ解析部は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項８】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項７に記載のデータ処理装置。
【請求項９】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項７に記載のデータ処理装置。
【請求項１０】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して前記優先度が高いデータに該当するか否かを判定する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が高いデータに該当しないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のデータ解析部の各々は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項１１】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１２】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１１に記載のデータ処理装置。
【請求項１３】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１１に記載のデータ処理装置。
【請求項１４】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１５】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っている場合は前記データを外部へ出力し、アラートフラグが立っていない場合には前記データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１６】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１５に記載のデータ処理装置。
【請求項１７】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１５に記載のデータ処理装置。
【請求項１８】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っているデータを外部へ出力し、アラートフラグが立っていないデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１９】
前記出力キューは、前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから前記データソート部によって読み出されたデータを格納する複数の出力キューであり、
前記複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部、
を備えることを特徴とする請求項３から１８のいずれか一つに記載のデータ処理装置。
【請求項２０】
前記データ受信部は、データを受信すると、受信したデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、前記アラートフラグが立っているデータを前記出力キューに格納し、前記アラートフラグが立っていないデータを前記入力キューに格納する、
ことを特徴とする請求項１９に記載のデータ処理装置。
【手続補正２】
【補正対象書類名】明細書
【補正対象項目名】０００８
【補正方法】変更
【補正の内容】
【０００８】
上述した課題を解決し、目的を達成するために、本発明にかかるデータ処理装置は、データを受信するデータ受信部と、データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元のデータを格納する複数の入力キューと、複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから読み出されたデータを格納する複数の出力キューと、を備える。また、データ処理装置は、複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように、データを読み出した入力キューと対応付けられている出力キューに格納するデータソート部と、複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部と、を備える。
【手続補正書】
【提出日】平成31年1月16日(2019.1.16)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
複数の通信機器と１対多で接続され、前記複数の通信機器からデータを受信するデータ受信部と、
前記複数の通信機器の中の１つと１対１で対応付けられ、対応付けられている通信機器が送信元の前記データを前記データ受信部から受け取って格納する、前記複数の通信機器と同じ数の複数の入力キューと、
前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから読み出されたデータを格納する複数の出力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように、データを読み出した入力キューと対応付けられている出力キューに格納するデータソート部と、
前記複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部と、
を備えることを特徴とするデータ処理装置。
【請求項２】
前記データ受信部は、データを受信すると、受信したデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、前記アラートフラグが立っているデータを前記出力キューに格納し、前記アラートフラグが立っていないデータを前記入力キューに格納する、
ことを特徴とする請求項１に記載のデータ処理装置。
【請求項３】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認するフラグ確認部と、
前記アラートフラグが立っていないデータを一時的に保持するデータ保持部と、
を備え、
前記フラグ確認部は、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項４】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項３に記載のデータ処理装置。
【請求項５】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項３に記載のデータ処理装置。
【請求項６】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認する複数のフラグ確認部と、
各々が前記複数のフラグ確認部の１つと１対１で対応付けられ、対応付けられているフラグ確認部から前記アラートフラグが立っていないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のフラグ確認部の各々は、対応付けられている入力キューからデータを読み出し、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを対応付けられている前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項７】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
データを解析して前記優先度が高いデータに該当するか否かを判定するデータ解析部と、
前記優先度が高いデータに該当しないデータを一時的に保持するデータ保持部と、
を備え、
前記データ解析部は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項８】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項７に記載のデータ処理装置。
【請求項９】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項７に記載のデータ処理装置。
【請求項１０】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して前記優先度が高いデータに該当するか否かを判定する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が高いデータに該当しないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のデータ解析部の各々は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項１１】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１２】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１１に記載のデータ処理装置。
【請求項１３】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１１に記載のデータ処理装置。
【請求項１４】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１５】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っている場合は前記データを外部へ出力し、アラートフラグが立っていない場合には前記データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１６】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１５に記載のデータ処理装置。
【請求項１７】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１５に記載のデータ処理装置。
【請求項１８】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っているデータを外部へ出力し、アラートフラグが立っていないデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１９】
前記出力キューは、前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから前記データソート部によって読み出されたデータを格納する複数の出力キューであり、
前記複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部、
を備えることを特徴とする請求項３から１８のいずれか一つに記載のデータ処理装置。
【請求項２０】
前記データ受信部は、データを受信すると、受信したデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、前記アラートフラグが立っているデータを前記出力キューに格納し、前記アラートフラグが立っていないデータを前記入力キューに格納する、
ことを特徴とする請求項１９に記載のデータ処理装置。
【手続補正２】
【補正対象書類名】明細書
【補正対象項目名】０００８
【補正方法】変更
【補正の内容】
【０００８】
上述した課題を解決し、目的を達成するために、本発明にかかるデータ処理装置は、複数の通信機器と１対多で接続され、複数の通信機器からデータを受信するデータ受信部と、複数の通信機器の中の１つと１対１で対応付けられ、対応付けられている通信機器が送信元のデータをデータ受信部から受け取って格納する、複数の通信機器と同じ数の複数の入力キューと、複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから読み出されたデータを格納する複数の出力キューと、を備える。また、データ処理装置は、複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように、データを読み出した入力キューと対応付けられている出力キューに格納するデータソート部と、複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部と、を備える。
【手続補正書】
【提出日】令和1年5月31日(2019.5.31)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認するフラグ確認部と、
前記アラートフラグが立っていないデータを一時的に保持するデータ保持部と、
を備え、
前記フラグ確認部は、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項２】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１に記載のデータ処理装置。
【請求項３】
前記データソート部は、前記フラグ確認部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項２に記載のデータ処理装置。
【請求項４】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認する複数のフラグ確認部と、
各々が前記複数のフラグ確認部の１つと１対１で対応付けられ、対応付けられているフラグ確認部から前記アラートフラグが立っていないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のフラグ確認部の各々は、対応付けられている入力キューからデータを読み出し、前記アラートフラグが立っているデータを外部に出力し、前記アラートフラグが立っていないデータを対応付けられている前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項５】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
データを解析して前記優先度が高いデータに該当するか否かを判定するデータ解析部と、
前記優先度が高いデータに該当しないデータを一時的に保持するデータ保持部と、
を備え、
前記データ解析部は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項６】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項５に記載のデータ処理装置。
【請求項７】
前記データソート部は、前記データ解析部および前記データ保持部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項５に記載のデータ処理装置。
【請求項８】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して前記優先度が高いデータに該当するか否かを判定する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が高いデータに該当しないデータを受け取って一時的に保持する複数のデータ保持部と、
を備え、
前記複数のデータ解析部の各々は、前記優先度が高いデータであることを示すアラートフラグを前記優先度が高いデータに立てて外部に出力し、前記優先度が高いデータに該当しないデータを前記データ保持部に出力し、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ保持部に対して、保持しているデータを外部に出力するよう指示する、
ことを特徴とするデータ処理装置。
【請求項９】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１０】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項９に記載のデータ処理装置。
【請求項１１】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項９に記載のデータ処理装置。
【請求項１２】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１３】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
前記データに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っている場合は前記データを外部へ出力し、アラートフラグが立っていない場合には前記データを解析して優先度を決定し、決定した優先度を前記解析したデータに付加するデータ解析部と、
前記データ解析部から前記優先度が付加されたデータを受け取って一時的に保持するデータ保持部と、
前記データ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力するデータ読出部と、
を備え、
前記データ解析部は、１つの入力キューに格納されているデータを全て読み出した後、前記データ読出部に対して、前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１４】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が少ない入力キューから順番に行う、
ことを特徴とする請求項１３に記載のデータ処理装置。
【請求項１５】
前記データソート部は、前記データ解析部、前記データ保持部およびデータ読出部により１つの入力キューからデータを読み出して並べ替えてから外部に出力する処理を、格納されているデータの数が多い入力キューから順番に行う、
ことを特徴とする請求項１３に記載のデータ処理装置。
【請求項１６】
データを受信するデータ受信部と、
前記データ受信部が受信するデータの送信元の１つと１対１で対応付けられ、対応付けられている送信元の前記データを格納する複数の入力キューと、
前記複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、
を備え、
前記データソート部は、
各々が前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューに格納されているデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、アラートフラグが立っているデータを外部へ出力し、アラートフラグが立っていないデータを解析して優先度を決定し、決定した優先度を前記解析したデータに付加する複数のデータ解析部と、
各々が前記複数のデータ解析部の１つと１対１で対応付けられ、対応付けられているデータ解析部から前記優先度が付加されたデータを受け取って一時的に保持する複数のデータ保持部と、
各々が前記複数のデータ保持部の１つと１対１で対応付けられ、対応付けられているデータ保持部が保持しているデータを、付加されている優先度に従った順番で読み出して外部へ出力する複数のデータ読出部と、
を備え、
前記複数のデータ解析部の各々は、対応付けられている入力キューに格納されているデータを全て読み出した後、対応付けられている前記データ読出部に対して、対応付けられている前記データ保持部からデータを読み出すよう指示する、
ことを特徴とするデータ処理装置。
【請求項１７】
前記出力キューは、前記複数の入力キューの１つと１対１で対応付けられ、対応付けられている入力キューから前記データソート部によって読み出されたデータを格納する複数の出力キューであり、
前記複数の出力キューの１つと１対１で対応付けられ、対応付けられている出力キューからデータを読み出して出力する複数のデータ出力部、
を備えることを特徴とする請求項１から１６のいずれか一つに記載のデータ処理装置。
【請求項１８】
前記データ受信部は、データを受信すると、受信したデータに前記優先度が高いデータであることを示すアラートフラグが立っているか否かを確認し、前記アラートフラグが立っているデータを前記出力キューに格納し、前記アラートフラグが立っていないデータを前記入力キューに格納する、
ことを特徴とする請求項１７に記載のデータ処理装置。
【手続補正２】
【補正対象書類名】明細書
【補正対象項目名】０００８
【補正方法】変更
【補正の内容】
【０００８】
上述した課題を解決し、目的を達成するために、本発明にかかるデータ処理装置は、データを受信するデータ受信部と、データ受信部が受信するデータの送信元と１対１で対応付けられ、対応付けられている送信元のデータを格納する複数の入力キューと、複数の入力キューの各々に格納された各データを入力キューごとに読み出し、優先度が高いデータが先に処理されるように出力キューに格納するデータソート部と、を備える。データソート部は、データに優先度が高いデータであることを示すアラートフラグが立っているか否かを確認するフラグ確認部と、アラートフラグが立っていないデータを一時的に保持するデータ保持部と、を備える。フラグ確認部は、アラートフラグが立っているデータを外部に出力し、アラートフラグが立っていないデータをデータ保持部に出力し、１つの入力キューに格納されているデータを全て読み出した後、データ保持部に対して、保持しているデータを外部に出力するよう指示する。
【国際調査報告】
2019186920.tif 000024
2019186920.tif 000025