JP7464503B2 - Data request processing device, data request processing method and storage medium - Google Patents
Data request processing device, data request processing method and storage medium Download PDFInfo
- Publication number
- JP7464503B2 JP7464503B2 JP2020189329A JP2020189329A JP7464503B2 JP 7464503 B2 JP7464503 B2 JP 7464503B2 JP 2020189329 A JP2020189329 A JP 2020189329A JP 2020189329 A JP2020189329 A JP 2020189329A JP 7464503 B2 JP7464503 B2 JP 7464503B2
- Authority
- JP
- Japan
- Prior art keywords
- priority
- data
- request
- unit
- data request
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Images
Landscapes
- Information Transfer Between Computers (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Description
本発明は、データ連携及び流通の優先度制御に関する技術に関する。 The present invention relates to technology related to priority control of data linkage and distribution.
近年、日本政府は、ネットワーク化やサイバー空間利用の飛躍的な発展により、新しいサービスが次々と創出され、社会の主体となる人々に豊かさをもたらす「超スマート社会」を未来社会の姿として定義し、その実現に向けた一連の取組を「Ｓｏｃｉｅｔｙ ５．０」として推進している。 In recent years, the Japanese government has defined the future society as a "super smart society" in which new services are constantly being created through rapid developments in networking and the use of cyberspace, bringing prosperity to the people who are the main players in society, and is promoting a series of initiatives to realize this society, known as "Society 5.0."
Ｓｏｃｉｅｔｙ ５．０では、ＩｏＴ（Ｉｎｔｅｒｎｅｔ ｏｆ Ｔｈｉｎｇｓ）で人と物がつながり、様々なデータ（知識・情報）が流通・連携されることで新たな価値が生み出すことが期待されており、データ流通・連携の取組が活発に行われている。 In Society 5.0, it is expected that new value will be created by connecting people and things through the Internet of Things (IoT) and distributing and linking various types of data (knowledge and information), and active efforts are being made to distribute and link data.
一例として、スマートシティに関する取組（例えば、非特許文献１）では、行政が保有するデータや、建物や道路等のインフラのＩｏＴデータなどを横断的に連携することができるデータ連携・流通のプラットフォーム（以下、都市ＯＳ）が提唱されている。以下、都市ＯＳにおける、データ流通・連携の事例を説明する。 As an example, smart city initiatives (e.g., Non-Patent Document 1) propose a data linkage and distribution platform (hereafter, City OS) that can cross-link data held by the government and IoT data on infrastructure such as buildings and roads. Below, we explain examples of data linkage and distribution in City OS.
都市ＯＳは、データを提供元から利用者（又は、アプリケーション・サービス）へ仲介するが、社会状況の変化に伴う変更に対して、ダイナミックでかつ柔軟に対応できるイベント処理機能（非特許文献１：７．２．４．２）が要求されている。 The City OS mediates data from data providers to users (or application services), but it is required to have an event processing function (Non-Patent Document 1: 7.2.4.2) that can dynamically and flexibly respond to changes that accompany changes in social conditions.
また、データ利用者が提供するサービス・アプリケーションは、データのリアルタイム性を要するもの（例えば、監視カメラによる犯罪の抑止やインフラの災害監視）、リアルタイム性が要求されないものまで様々であり、都市ＯＳが仲介するデータにもリアルタイム性、即ち即座に利用者に仲介するものと、そうでないものが混在する。 In addition, the services and applications provided by data users vary from those that require real-time data (for example, crime prevention using surveillance cameras or disaster monitoring of infrastructure) to those that do not, and the data mediated by the City OS also includes a mixture of real-time data, meaning that data is mediated to users immediately, and data that is not.
リアルタイム性が要求されるデータ仲介においては、従来のデータ連携では、特許文献１、２のような優先制御の手法が用いられてきた。
In data intermediation, which requires real-time performance, conventional data linkage has used priority control methods such as those described in
特許文献１の技術は、予め提供させるデータに優先度を設定し、優先順位の高いデータを提供元から受信した場合に、仲介する処理をジョブとして優先度管理する。現在実行中のジョブによって仲介するジョブを実行するためのリソースを確保できない場合に、実行中のジョブの優先度情報に基づいて、実行中のジョブのうち、受信したジョブよりも優先度が低いジョブの少なくとも１つを停止する、ことが開示されている。
The technology in
これにより、仲介するデータ量が増加しても、リアルタイム性が必要なデータに優先度を予め設定することにより、優先順位の高いデータをリアルタイムに仲介することができる。 As a result, even if the amount of data being mediated increases, by presetting priorities for data that requires real-time performance, data with high priority can be mediated in real time.
特許文献２の技術は、アプリケーションからのデータ取得のリクエストの頻度を用いて、レスポンスの遅延を解消する技術である。特許文献２によれば、優先度ルール記憶部に、受け取られた各リクエストを、種別毎に、時刻と共に格納している優先度テーブル、及び各リクエストの時刻を時系列にそって格納している時刻記録テーブルを格納する。 The technology in Patent Document 2 uses the frequency of requests for data acquisition from an application to eliminate response delays. According to Patent Document 2, the priority rule storage unit stores a priority table that stores each received request by type along with the time, and a time record table that stores the time of each request in chronological order.
優先度設定部は、最新のリクエストを対象として、優先度テーブルから、最新のリクエストの種別と同一の種別のリクエストの数を特定し、さらに、特定したリクエストの数と時刻記録テーブルに格納されている時刻の数とに基づいて、最新リクエストの発生頻度を算出し、処理順序を決定する際の指標となる優先度を設定する、ことが開示されている。これにより、仲介するデータが増加した場合に、予めプログラムされた優先度ルールにより、頻度の高いデータをリアルタイムに仲介することができる。 The priority setting unit identifies the number of requests of the same type as the latest request from the priority table for the latest request, and further calculates the occurrence frequency of the latest request based on the number of identified requests and the number of times stored in the time recording table, and sets a priority that serves as an index for determining the processing order. In this way, when the amount of data to be mediated increases, it is possible to mediate frequent data in real time according to pre-programmed priority rules.
一方で、都市ＯＳは、前述の通り、社会状況の変化に伴う変更に対して、ダイナミックでかつ柔軟に対応できる必要があり、予め設定されたリアルタイム性に関する優先度を変更する場合がある。 On the other hand, as mentioned above, the Urban OS needs to be able to dynamically and flexibly respond to changes that accompany changes in social conditions, and there may be cases where the pre-set priorities regarding real-time performance need to be changed.
例えば、道路等のインフラ保守に関するアプリケーションにおいて、通常時において都市ＯＳではリアルタイム性を必要としない優先度で設定されているが、アクシデントが発生した緊急時には、アクシデント発生箇所に関して仲介するデータの優先度を一時的に高くするなどである。 For example, in an application related to infrastructure maintenance such as roads, the City OS normally sets priorities that do not require real-time performance, but in the event of an emergency such as an accident, the priority of the data mediated by the location of the accident can be temporarily increased.
また、事故や災害などが発生した場合でも、都市ＯＳは、状況に応じてダイナミックでかつ柔軟に対応し、安定的にデータの利用者がデータを取得し続けられるようにすることが要求される。 In addition, even in the event of an accident or disaster, the City OS will be required to respond dynamically and flexibly to the situation, and ensure that data users can continue to obtain data stably.
ここで、特許文献１、２を適用した場合でも、上記のダイナミックでかつ柔軟なデータの仲介は実現できない。特許文献１では、予め提供元から送付されるデータに優先度を設定しておくことが必要であり、緊急時にダイナミックに優先度を変える方法については開示されていない。
Here, even if
特許文献２は、頻度を用いて優先度を設定する方法に関して開示しており、頻度の増加するケース以外のケースに関しては開示されていない。このように特許文献１、２のどちらを適用しても、状況が変わった場合に優先度の変更ができず、緊急時に必要なデータの仲介処理ができなくなる可能性があった。
Patent Document 2 discloses a method for setting priorities using frequency, but does not disclose cases other than those in which frequency increases. In this way, whether
そこで本発明は、上記問題点に鑑みてなされたもので、データの仲介を行う際に、状況に応じてダイナミックでかつ柔軟にデータを要求するリクエストの優先度を制御することを目的とする。 The present invention was made in consideration of the above problems, and aims to dynamically and flexibly control the priority of data requests depending on the situation when mediating data.
本発明は、プロセッサとメモリを有するデータ要求処理装置であって、データベースに格納されているデータをリクエストするメッセージを受信し、前記メッセージに含まれるデータ要求に優先度を設定して、前記優先度に応じて前記データ要求の処理順序を決定する優先度制御部を有し、前記優先度制御部は、前記メッセージを受信する受信部と、前記メッセージに含まれるデータ要求を取得し、前記データ要求を分析して前記優先度の設定に必要なパラメータを生成する分析部と、前記パラメータを用いて前記データ要求に優先度を設定する優先度設定部と、を有し、前記優先度設定部は、前記パラメータを受け付けて、所定のルールで前記パラメータを分類し、前記分類の結果に応じて前記データ要求の優先度を設定する。 The present invention is a data request processing device having a processor and memory, and includes a priority control unit that receives a message requesting data stored in a database, sets a priority for the data request included in the message, and determines the processing order of the data requests according to the priority. The priority control unit includes a receiving unit that receives the message, an analysis unit that obtains the data request included in the message, analyzes the data request, and generates parameters necessary for setting the priority, and a priority setting unit that sets a priority for the data request using the parameters. The priority setting unit accepts the parameters, classifies the parameters according to a predetermined rule, and sets the priority of the data request according to the result of the classification.
本発明によれば、状況に応じてダイナミックでかつ柔軟にリクエストの優先度を制御して、リアルタイム性が必要なアプリケーションは安定的にデータを取得することができる。 According to the present invention, the priority of requests can be dynamically and flexibly controlled according to the situation, allowing applications that require real-time performance to stably obtain data.
本明細書において開示される主題の、少なくとも１つの実施の詳細は、添付されている図面と以下の記述の中で述べられる。開示される主題のその他の特徴、態様、効果は、以下の開示、図面、請求項により明らかにされる。 Details of at least one implementation of the subject matter disclosed herein are set forth in the accompanying drawings and the description below. Other features, aspects, and advantages of the disclosed subject matter will become apparent from the following disclosure, drawings, and claims.
以下、本発明の実施の形態について、図面を参照して詳細に説明する。なお、各図において共通する部分には、同一の符号が付与されている。 The following describes in detail an embodiment of the present invention with reference to the drawings. Note that the same reference numerals are used to designate common parts in each drawing.
実施例１で説明する都市ＯＳ（データ連携・流通のプラットフォーム）のデータ仲介では、都市ＯＳの内部に仲介するデータを格納しておくためのデータベース（内部データベース）を用意し、データ提供者が都市ＯＳの内部データベースにデータを格納しておく。 In the data brokerage of City OS (a platform for data linkage and distribution) described in Example 1, a database (internal database) is prepared inside City OS to store the data to be brokered, and data providers store their data in the internal database of City OS.
データ利用者は、都市ＯＳの内部データベースに格納されたデータを都市ＯＳに対してリクエストする方法と、データ利用者が提供元のデータベース（外部データベース）に格納されているデータについて都市ＯＳを介してリクエストして取得する方法がある。 Data users can either request data stored in the City OS's internal database from the City OS, or request and obtain data stored in the provider's database (external database) via the City OS.
実施例１で説明する都市ＯＳのデータ仲介において、リクエストからレスポンス（リクエストされたデータをアプリケーションに返すこと）までの時間を保証するために、プランを作成しておき、プランに加入したデータ利用者は、プランで決められた最低レスポンス時間内にデータを取得できるようにする仕組みを実装することができる。 In the data brokerage of City OS described in Example 1, in order to guarantee the time from request to response (returning the requested data to the application), a plan can be created and a mechanism can be implemented that allows data users who subscribe to the plan to obtain data within the minimum response time determined by the plan.
実施例１は、上記の外部データベースに都市ＯＳがデータをリクエストする場合に、状況に応じてレスポンス時間テーブルを参照してリクエストからレスポンスまでかかった時間（以下、実測レスポンス時間）を用いて、リクエストの優先順位を変更し、処理遅延を解消するデータ要求処理システムに関して説明する。なお、上記状況は、例えば、レスポンスに時間がかかる状況や、上記の都市ＯＳのプランで決められた最低限のレスポンス時間より遅れそうな状況、又は、カテゴリ（種類）や属性（自治体、民間、企業、等）別にデータの取得に時間がかかる状況である。 In the first embodiment, a data request processing system is described that, when the City OS requests data from the external database, refers to a response time table depending on the situation and uses the time taken from the request to the response (hereinafter, the actual response time) to change the priority of the request and eliminate processing delays. Note that the above situation is, for example, a situation where the response takes a long time, a situation where the response time is likely to be slower than the minimum response time determined in the plan of the City OS, or a situation where it takes a long time to obtain data by category (type) or attribute (municipal government, private sector, company, etc.).
図１は、実施例１によるデータ要求処理システムの構成の一例を示すブロック図である。 Figure 1 is a block diagram showing an example of the configuration of a data request processing system according to the first embodiment.
データ要求処理システムは、データ要求処理装置１と、アプリケーション２－１～２－３をそれぞれ実行する端末１００－１～１００－３と、ネットワーク３、ネットワーク４、データベース５、外部データベース６、データ送信部７から構成される。なお、データベース５と、データ送信部７はデータ要求処理装置１が提供する例を示すが、他の計算機が提供してもよい。また、端末を個々に特定しない場合には、「－」以降を省略した符号「１００」を用いる。他の構成要素の符号についても同様である。
The data request processing system is composed of a data
データ要求処理装置１は、プロセッサ２１と、メモリ２２と、ストレージ装置２３と、通信インターフェース２４と、入出力装置２５を含む計算機である。
The data
メモリ２２には、都市ＯＳ３０がロードされて、プロセッサ２１によって実行される。都市ＯＳ３０は、優先度制御部１１と、スケジューリング部１２と、データ送信部７の機能部を含む。優先度制御部１１は、リクエスト受信部１１１と、リクエスト分析部１１２と、優先度設定部１１３の機能部を含む。
City OS 30 is loaded into
都市ＯＳ３０の各機能を提供する優先度制御部１１と、スケジューリング部１２と、データ送信部７は、プログラムとしてメモリ２２にロードされる。
The
プロセッサ２１は、各機能部のプログラムに従って処理を実行することによって、所定の機能を提供する機能部として稼働する。例えば、プロセッサ２１は、優先度制御プログラムに従って処理を実行することで優先度制御部１１として機能する。他のプログラムについても同様である。さらに、プロセッサ２１は、各プログラムが実行する複数の処理のそれぞれの機能を提供する機能部としても稼働する。計算機及び計算機システムは、これらの機能部を含む装置及びシステムである。
The
ストレージ装置２３は、データベース５を格納する。データベース５は都市ＯＳ３０の内部のデータベースとして管理される。通信インターフェース２４は、ネットワーク３、４に接続されて、端末１００や外部データベース６と通信を行う。入出力装置２５は、キーボードやマウス或いはタッチパネル等の入力装置と、ディスプレイ等の出力装置を含む。
The
優先度制御部１１は、後述するように、アプリケーション２から受け付けたデータのリクエストメッセージに優先度を設定して、スケジューリング部１２に出力する。スケジューリング部１２は優先度（優先順位）の高い順にリクエストメッセージを処理してデータベース５又は外部データベース６にアクセスする。なお、外部データベース６は、外部の都市ＯＳ（図示省略）によって管理される。
As described below, the
なお、スケジューリング部１２は、リクエストメッセージから抽出したクエリ（データ要求）をデータベース５又は外部データベース６に出力してもよいし、データベース５又は外部データベース６がリクエストメッセージを受け付け可能な場合には、リクエストメッセージを送信すればよい。
The
データ送信部７は、データベース５又は外部データベース６の応答を受け付けると、レスポンスメッセージを生成して、アプリケーション２に送信する。
When the
図２は、データ要求処理システムのシーケンスを示す。なお、以下の説明では、端末１００－１～１００－３のアプリケーション２－１～２－３の構成は同様であるので、アプリケーション２－１について説明する。 Figure 2 shows the sequence of the data request processing system. In the following explanation, the configurations of applications 2-1 to 2-3 of terminals 100-1 to 100-3 are the same, so application 2-1 will be explained.
端末１００が実行するアプリケーション２は、ネットワーク３を介して、データ要求処理装置１に接続し、データ取得のためのリクエストメッセージを送信する（Ｓ１）。
The application 2 executed by the terminal 100 connects to the data
データ要求処理装置１は、優先度制御部１１で設定された優先度（可変優先度）に従って、リクエストメッセージの処理順位を決定し、スケジューリング部１２で処理順位の高いリクエストメッセージのクエリを送信してデータベース５にアクセスする。
The data
スケジューリング部１２は、データの所在によっては、データベース５かネットワーク４を介して接続された外部データベース６にアクセスする。データベース５又は外部データベース６から取得したデータはデータ送信部７に出力され、データ送信部７はレスポンスメッセージを生成して、アプリケーション２にデータを送信する。
Depending on the location of the data, the
優先度制御部１１のリクエスト受信部１１１は、アプリケーション２から送信されたリクエストメッセージを記録する。リクエスト分析部１１２は、リクエスト受信部１１１に記録されているリクエストメッセージを取得し（Ｓ２、Ｓ３）、リクエストメッセージを分析し（Ｓ４）、分析結果のパラメータ（リアルタイム性）を生成し（Ｓ５）、優先度設定部１１３に出力する（Ｓ６、Ｓ７）。
The
優先度設定部１１３は、リクエスト分析部１１２からの全パラメータが入力されると、パラメータからリクエストメッセージ毎に優先度の変更を判断し、判断に応じて可変優先度を算出する（Ｓ８）。優先度設定部１１３は、リクエストメッセージと可変優先度をスケジューリング部１２へ送信する（Ｓ９）。
When all parameters are input from the
スケジューリング部１２は、受信したリクエストメッセージの可変優先度に従って、リクエストメッセージに含まれるクエリを送信して、データベース５にデータを要求する（Ｓ１０）。データベース５はリクエストメッセージのクエリで要求されたデータを検索した結果をデータ送信部７に送信する（Ｓ１１）。
The
スケジューリング部１２は、リクエストメッセージで要求されたデータが外部データベース６の場合には、外部データベース６にデータを要求する（Ｓ１２）し、外部データベース６はリクエストメッセージで要求されたデータを検索した結果（データ）をデータ送信部７に送信する（Ｓ１３）。
When the data requested in the request message is an
データ送信部７は、データベース５又は外部データベース６から受信したデータからレスポンスメッセージを生成して（Ｓ１４）アプリケーション２へ送信する（Ｓ１５）。
The
図３は、実施例１によるリクエストメッセージ３００の構造の一例を示す図である。ｒｅｑｕｅｓｔＩＤ３０１は、アプリケーション２から送信されたリクエストメッセージを識別するための項目で、リクエスト受信部１１１で付与される。
Figure 3 is a diagram showing an example of the structure of a request message 300 according to the first embodiment. The
ｒｅｑｕｅｓｔＴｉｍｅ３０２は、リクエストメッセージ３００がリクエスト受信部１１１に記録（又は受信）された時刻であり、リクエスト受信部１１１で付与される。ａｐｐｒｉｃａｔｉｏｎＩＤ３０３は、アプリケーション２を識別するための項目であり、アプリケーション２から送信されるリクエストメッセージ３００に含まれる。
The
ｐｒｉｏｒｔｙ３０４は、予め決められたアプリケーション２毎の優先度（アプリ優先度）であり、アプリケーション２から送信されるリクエストメッセージ３００に含まれる。アプリ優先度（３０４）は、例えば、自然数を用いて優先順位の値を設定する（例えば、１～７）。なお、優先度設定部１１３で設定される可変優先度の値の範囲も前記のアプリ優先度（３０４）と同じレンジとする。なお、優先順位は値が小さいほど優先度が高いものとする。
ｑｕｅｒｙ３０５は、リクエストメッセージ３００に含まれるデータ要求であり、要求されるデータ名３０５１や、データのカテゴリ（種別・図中ｄａｔａＣａｔａｌｏｇ）３０５２や、サイズ３０５３、属性（図中ｐｒｏｐｅｒｔｙ）３０５４など、データを取得するために必要な情報の全てが含まれる。ｑｕｅｒｙ３０５は、アプリケーション２から送信されるリクエストメッセージ３００に含まれている。
図４は、実施例１によるリクエスト分析部１１２の構成の一例を示すブロック図である。リクエスト分析部１１２は、リクエストメッセージ３００を取得するリクエスト取得部１１２１と、リクエストメッセージ３００に含まれるアプリ優先度（３０４）を取得するアプリ優先度読み取り部１１２２と、リクエストメッセージ３００からｑｕｅｒｙ３０５を取得するクエリ読み取り部１１２３と、データ送信部７からレスポンスに関する情報を受け付けて実測レスポンス時間を算出してレスポンス時間テーブル１１２５に格納するレスポンス時間計算部１１２６と、ｑｕｅｒｙ３０５とレスポンス時間テーブル１１２５の情報からパラメータを生成するパラメータ検出部１１２４を含む。
Fig. 4 is a block diagram showing an example of the configuration of the
図５は、リクエスト分析部１１２の処理を示すフローチャートである。この処理は、リクエスト受信部１１１からリクエストメッセージ３００を受診した場合に実行される。
Figure 5 is a flowchart showing the processing of the
リクエスト取得部１１２１は、リクエスト受信部１１１に記録されているリクエストメッセージ３００を要求し、レスポンスとしてリクエストメッセージを取得する（Ｓ５１）。
The
リクエスト取得部１１２１は、取得したリクエストメッセージ３００をアプリ優先度読み取り部１１２２と、クエリ読み取り部に送る（Ｓ５２）。アプリ優先度読み取り部１１２２は、リクエストメッセージ３００からｒｅｑｕｅｓｔＩＤ３０１と、ｐｒｉｏｒｉｔｙ３０４を取得（Ｓ５３）し、優先度設定部１１３に出力する（Ｓ５７）。
The
クエリ読み取り部１１２３は、ｒｅｑｕｅｓｔＩＤ３０１と、ｒｅｑｕｅｓｔＴｉｍｅ３０２と、ａｐｐｒｉｃａｔｉｏｎＩＤ３０３と、クエリ３０５をリクエストメッセージ３００から取得し（Ｓ５４）、パラメータ検出部１１２４に出力する。
The
パラメータ検出部１１２４は、クエリ読み取り部１１２３で取得した項目を用いて、可変優先度を設定するのに必要なパラメータを生成する。実施例１では、パラメータ検出部１１２４は、レスポンス時間テーブル１１２５にアクセスし、ｑｕｅｒｙ３０５を用いてリクエストメッセージ３００に該当する過去の実測レスポンス時間を参照する（Ｓ５５）。
The
パラメータ検出部１１２４は、例えば、ｑｕｅｒｙ３０５のデータ名３０５１を取得し、データ名３０５１でレスポンス時間テーブル１１２５を検索し、データ名１２０２が一致するレコードの実測レスポンス時間１２０４を取得し、リクエストメッセージ３００でアクセスする際の推定レスポンス時間として設定する。
The
図８は、レスポンス時間テーブル１１２５の一例を示す図である。レスポンス時間テーブル１１２５は、アプリＩＤ１２０１と、データ名１２０２と、種類１２０３と、実測レスポンス時間１２０４と、所在１２０５と、タイムスタンプ１２０６を１つのレコードに含む。
Figure 8 is a diagram showing an example of a response time table 1125. The response time table 1125 includes an
アプリＩＤ１２０１は、アプリケーション２の識別子を格納する。データ名１２０２は、リクエストメッセージ３００で要求されたデータの名称が格納される。種類１２０３にはデータの種類が格納される。所在１２０５には、データが格納されている位置（又はパス）が格納される。タイムスタンプ１２０６には、データが登録された日時が格納される。
The
実測レスポンス時間１２０４は、データ送信部７から送信されたデータ要求に対してデータベース５からの応答がデータ送信部７に到着した時刻と、リクエストメッセージ３００のｒｅｑｕｅｓｔＴｉｍｅ３０２の差分からレスポンス時間計算部１１２６が計算した時間である。
The
なお、実測レスポンス時間１２０４は、上記に限定されるものではなく、スケジューリング部１２がリクエストメッセージ３００又はクエリを送信してから、データベース５（又は外部データベース６）の応答をデータ送信部７で受け付けるまでの時間をレスポンス時間計算部１１２６が測定して、レスポンス時間テーブル１１２５へ蓄積してもよい。
The
なお、レスポンス時間テーブル１１２５は、図示はしないが、少なくともデータ名（３０５１）と、データのカテゴリ（３０５２）と、実測レスポンス時間を１つのレコードに含めばよい。 Although not shown in the figure, the response time table 1125 only needs to include at least the data name (3051), the data category (3052), and the actual response time in one record.
また、レスポンス時間計算部１１２６は、計算した実測レスポンス時間１２０４と、データ名１２０１やデータの所在などの情報を登録し、登録した時刻をタイムスタンプ１２０６に設定する。レスポンス時間計算部１１２６は、毎回のレスポンス毎に計算するか、一定時間内に発生したレスポンスの平均値を計算することも可能である。
The response
次に、パラメータ検出部１１２４は、取得した実測レスポンス時間１２０４を用いて、パラメータを生成する（Ｓ５６）。なお、パラメータ検出部１１２４は、レスポンス時間テーブル１１２５から複数の実測レスポンス時間１２０４を検索した場合には、タイムスタンプ１２０６が最新のレコードの値を選択して推定レスポンス時間とする。
Next, the
例えば、外部データベース６にデータを要求する状況においては、パラメータ検出部１１２４は、ｑｕｅｒｙ３０５のデータ名を用いてレスポンス時間テーブル１１２５を検索し、パラメータとして実測レスポンス時間１２０４と、外部アクセス判定結果が「Ｔｒｕｅ」の値と、データの所在１２０５を生成する。なお、外部アクセス判定結果は、「Ｔｒｕｅ」又は「Ｆａｌｓｅ」が設定される。
For example, in a situation where data is requested from the
また、パラメータ検出部１１２４は、要求されているデータの所在１２０５が、外部データベース６ではない場合にはパラメータとして外部アクセス判定結果が「Ｆａｌｓｅ」の値を生成する。パラメータ検出部１１２４が生成したパラメータは優先度設定部１１３に出力される（Ｓ５７）。
If the
リクエストメッセージ３００の到着からデータ送信部７が検索結果を取得するまでにレスポンスに時間を要するカテゴリ３０５２（種類１２０３）のデータの処理速度を上げるために、パラメータ検出部１１２４が、リクエストメッセージ３００のカテゴリ３０５２でレスポンス時間テーブル１１２５を検索し、データの種類１２０３に一致する実測レスポンス時間１２０４をパラメータとして使用することも可能である。
In order to increase the processing speed of data of category 3052 (type 1203) that requires time for response from the arrival of the request message 300 until the
又は、レスポンスに時間を要する属性（自治体、民間、企業、等）のデータの処理速度を上げるために、レスポンス時間テーブル１１２５にデータの属性情報と実測レスポンス時間１２０４を登録し、パラメータとして生成することも可能である。
Alternatively, to increase the processing speed of data for attributes that require a long response time (such as local government, private sector, or business), it is possible to register data attribute information and
又は、都市ＯＳ３０のプランで決められた最低限のレスポンス時間より遅れそうな場合に、遅延を回避するため、レスポンス時間テーブル１１２５にプラン情報（最低限レスポンス時間）を加えておくことができる。
Alternatively, if the response time is likely to be slower than the minimum response time determined in the
パラメータ検出部１１２４は、リクエストメッセージ３００のａｐｐｒｉｃａｔｉｏｎＩＤ３０３に一致するアプリＩＤ１２０１のレコードを検索し、レスポンス時間テーブル１１２５からプラン情報（最低限レスポンス時間）、実測レスポンス時間１２０４を取得する。そして、パラメータ検出部１１２４は、アプリケーション２が加入しているプランの最低限レスポンス時間と、実測レスポンス時間１２０４の差を計算し、パラメータを生成することも可能である。
The
パラメータ検出部１１２４は、実測レスポンス時間１２０４と外部アクセス判定結果（「Ｔｒｕｅ」又は「Ｆａｌｓｅ」）と、上記ステップＳ５３で取得したアプリ優先度（３０４）を含むパラメータを優先度設定部１１３に出力する（Ｓ５７）。
The
次に、リクエスト分析部１１２のリクエスト取得部１１２１は、優先度設定部１１３からパラメータの受信完了の通知（レスポンス）を待って処理を終了する（Ｓ５８）。
Next, the
図６は、優先度設定部１１３の構成の一例を示すブロック図である。優先度設定部１１３は、リクエスト分析部１１２からパラメータを受け付けて、可変優先度を算出してスケジューリング部１２へ出力する。優先度設定部１１３は、パラメータ受信部１１３１と、優先度計算部１１３２と、処理順序制御部１１３３から構成される。
Figure 6 is a block diagram showing an example of the configuration of the
図７は、優先度設定部１１３で行われる処理の一例を示すフローチャートである。
Figure 7 is a flowchart showing an example of the processing performed by the
パラメータ受信部１１３１は、リクエスト分析部１１２から出力されたパラメータを受信し、ｒｅｑｕｅｓｔＩＤ３０１で、リクエストメッセージ毎のパラメータを識別する（Ｓ７１）。
The
パラメータ受信部１１３１は、リクエストメッセージのパラメータの受信が完了すると、リクエスト分析部１１２のリクエスト取得部１１２１にパラメータの受信終了のレスポンスを返し、リクエスト取得部１１２１に新しいリクエストメッセージを取得するよう通知する（Ｓ７２、Ｓ７３）。
When the
パラメータ受信部１１３１は、パラメータが複数の場合は、全てのパラメータの受信が完了してからリクエスト取得部１１２１にレスポンスを返す。パラメータ受信部１１３１が受け取ったパラメータは優先度計算部１１３２に出力され、優先度計算部１１３２はパラメータを用いて可変優先度を計算する（Ｓ７４）。
When there are multiple parameters, the
実施例１の優先度計算部１１３２は、パラメータ内の実測レスポンス時間を、リクエストメッセージ３００で要求されたデータを取得する際の推定レスポンス時間として扱う。優先度計算部１１３２は、推定レスポンス時間が予め設定した閾値を超えているかを判断し、閾値を超える場合は、アプリ優先度（ｐｒｉｏｒｉｔｙ３０４）よりも優先順位を上げて、可変優先度（値は減少）を設定する。
The
優先順位を上げる程度は、アプリ優先度（３０４）の設定レンジ内（例えば、自然数で１～７）で、アプリ優先度（３０４）を１段階又は２段階だけ上げた可変優先度を設定することができる。そして、推定レスポンス時間が、閾値を超えると、優先度計算部１１３２が可変優先度を最優先（可変優先度＝１）に設定することができる。
The degree to which the priority is increased can be set to a variable priority that increases the application priority (304) by one or two steps within the setting range of the application priority (304) (for example,
すでに、アプリ優先度（３０４）が最優先順位（＝１）に相当する値であれば、優先度計算部１１３２は優先順位の変更はしない。優先度計算部１１３２は、推定レスポンス時間が閾値を超えない場合は、優先順位を変えずに、優先度計算部１１３２はアプリ優先度（３０４）で処理する。
If the application priority (304) is already a value corresponding to the highest priority (=1), the
又は、優先度計算部１１３２は、予め閾値を複数設定し、推定レスポンス時間が低い閾値（第１の閾値）を超えない場合は、優先度計算部１１３２が優先順位（可変優先度）を下げ、推定レスポンス時間が高い閾値（第２の閾値）を超える場合は、優先順位（可変優先度）を上げ、その間の場合は、優先順位を変えない方法もある。
Alternatively, the
又は、優先度計算部１１３２は、予め複数の閾値を設定し、推定レスポンス時間が低い閾値（第１の閾値）を超える場合は、優先順位を１段階上げた可変優先度を算出し、推定レスポンス時間が高い閾値（第２の閾値）を超える場合は、優先順位を２段階だけ上げた可変優先度を算出する方法もある。
Alternatively, the
優先度計算部１１３２は、外部データベース６からデータを取得する場合、受け取ったパラメータの外部アクセス判定結果が「Ｔｒｕｅ」である場合、推定レスポンス時間と閾値を比較し、可変優先度を設定するようにしてもよい。
When retrieving data from the
また、優先度計算部１１３２は、受け取ったパラメータの外部アクセス判定結果が「Ｆａｌｓｅ」の場合は、アプリ優先度（３０４）のまま処理する。或いは、優先度計算部１１３２は、パラメータのうち外部アクセス判定結果の「Ｔｒｕｅ」又は「Ｆａｌｓｅ」のみ用いて、「Ｔｒｕｅ」の場合に優先順位を上げ、「Ｆａｌｓｅ」場合にはアプリ優先度（３０４）で処理することも可能である。
If the external access judgment result of the received parameter is "False", the
また、優先度計算部１１３２は、パラメータのうち外部アクセス判定結果の「Ｔｒｕｅ」又は「Ｆａｌｓｅ」のみ用いて、「Ｔｒｕｅ」の場合に優先順位を上げ、「Ｆａｌｓｅ」場合にはアプリ優先度（３０４）で処理することも可能である。
In addition, the
また、優先度計算部１１３２は、パラメータに外部アクセス判定結果の「Ｔｒｕｅ」が含まれる場合には、推定レスポンス時間と閾値に応じて可変優先度を算出し、パラメータが「Ｆａｌｓｅ」の場合にはアプリ優先度（３０４）の値を可変優先度に設定してもよい。
In addition, if the parameter includes the external access judgment result of "True", the
また、優先度設定部１１３は、リクエスト分析部１１２から受け付けたパラメータが、カテゴリ３０５２や属性（ｐｒｏｐｅｒｔｙ３０５４）の場合、推定レスポンス時間と閾値を用いて、優先度計算部１１３２で可変優先度を設定してもよい。
In addition, when the parameters received from the
また、パラメータ検出部１１２４が、複数のリクエストメッセージ３００について推定レスポンス時間を取得して、複数のリクエストメッセージ３００と複数の推定レスポンス時間を優先度設定部１１３に出力することができる。この場合、パラメータ受信部１１３１で、複数のリクエストメッセージと複数の推定レスポンス時間を優先度計算部１１３２に出力し、優先度計算部１１３２は、複数のリクエストメッセージの推定レスポンス時間を比較して、推定レスポンス時間が最長時間か、推定レスポンス時間が長い上位いくつかの優先順位を上げて、可変優先度を設定する方法もある。
Also, the
パラメータ受信部１１３１から、一定期間の間に貯められたリクエストメッセージのパラメータを優先度計算部１１３２に出力する場合、優先度計算部１１３２は、推定レスポンス時間が最長時間か、推定レスポンス時間が上位いくつかのリクエストメッセージか、推定レスポンス時間が上位何割かのリクエストメッセージの優先順位を上げることも可能である。
When the
処理順序制御部１１３３は、算出された可変優先度（又はアプリ優先度（３０４））を含めて、スケジューリング部１２にリクエストメッセージ３００を送信する（Ｓ７５）。なお、処理順序制御部１１３３は、リクエストメッセージ３００のクエリ（ｑｕｅｒｙ３０５）と可変優先度（アプリ優先度）を送信すればよい。
The processing
スケジューリング部１２は、優先順位の異なる複数のキューで構成され、優先順位（可変優先度）の高いキューから優先的にデキューされるアルゴリズムでスケジューリングを実施する。
The
スケジューリング部１２からアクセス先のデータベース５又は外部データベース６にリクエストメッセージのクエリ（ｑｕｅｒｙ３０５）が送信されて、リクエストメッセージ３００で要求されたデータの取得が実施される。
The
以上のように実施例１のデータ要求処理装置１は、リクエストメッセージ３００の受信からレスポンスまでにかかった時間情報（推定レスポンス時間）と所定の閾値に基づいて、優先順位（可変優先度）を変更し、リクエストメッセージの処理を迅速化することで、端末１００から要求されたデータの取得までの時間を短縮することができる。
As described above, the data
また、データ要求処理装置１は、外部データベース６へアクセスする場合（パラメータの外部アクセス判定結果が「Ｔｒｕｅ」）に、推定レスポンス時間と閾値を用いて可変優先度を算出し、推定レスポンス時間の長さに応じた優先順位を設定することで、データの仲介を行う際にネットワーク４やアクセスの状況に応じてダイナミックでかつ柔軟にデータを要求するリクエストの優先度を制御することが可能となる。
In addition, when the data
実施例２では、端末１００のアプリケーション２が、事故や災害のように発生時期が予想できない状況で優先度の変更を要求し、データ要求処理装置１が優先度の変更要求に応じて、優先順位を上げるための制御をリクエスト分析部１１２と、優先度設定部１１３で実施する例を説明する。
In the second embodiment, an example is described in which an application 2 of a terminal 100 requests a change in priority in a situation where the occurrence time is unpredictable, such as an accident or disaster, and the data
図９は、実施例２によるリクエスト分析部の構成を示す。 Figure 9 shows the configuration of the request analysis unit according to the second embodiment.
実施例２において、リクエスト分析部１１２は、リクエスト取得部１１２１と、アプリ優先度読み取り部１１２２と、クエリ読み取り部１１２３と、パラメータ検出部１１２４及び優先度変更要求取得部１１２７から構成される。パラメータ検出部１１２４は、優先度変更を管理するために入出力装置２５からの指令を受け付ける。
In the second embodiment, the
リクエスト取得部１１２１、アプリ優先度読み取り部１１２２、クエリ読み取り部１１２３は実施例１と同様である。実施例２のリクエスト分析部１１２は、前記実施例１のレスポンス時間計算部１１２６とレスポンス時間テーブル１１２５を削除し、優先度変更要求取得部１１２７を加えた点が実施例１と相違する。
The
図１０は、本発明の実施例２によるリクエスト分析部１１２の処理の一例を示すフローチャートである。この処理は、リクエスト受信部１１１から優先度変更要求を含むリクエストメッセージ３００を受け付けた場合に開始される。なお、優先度変更要求は、リクエストメッセージ３００と異なるメッセージであってもよい。
Figure 10 is a flowchart showing an example of the processing of the
優先度変更要求取得部１１２７は、リクエスト受信部１１１から優先度変更を含むリクエストメッセージ３００を取得する（Ｓ９１）。優先度変更のリクエストメッセージ３００は、ａｐｐｒｉｃａｔｉｏｎＩＤ３０３と、アプリ優先度（ｐｒｉｏｒｉｔｙ３０４）と同様の形式（レンジなど）を含む要求優先度で構成される。優先度変更要求取得部１１２７は、リクエストメッセージ３００内の優先度変更要求を抽出してパラメータ検出部１１２４へ送信する。
The priority change
パラメータ検出部１１２４は、優先度変更のリクエストを受け付ける（Ｓ９２）と、入出力装置２５へ優先度変更要求の可否を問い合せる（Ｓ９３）。入出力装置２５を利用する管理者は、通知を受けた入出力装置２５で、要求優先度への変更を許可（Ｔｒｕｅ）又は不可（Ｆａｌｓｅ）を決定し（Ｓ９４）、決定内容を応答に含めてパラメータ検出部１１２４に送信する（Ｓ９５）。
When the
図１１は、本発明の実施例２によるリクエスト分析部１１２の処理の一例を示すフローチャートである。この処理は、入出力装置２５から優先度の変更の可否を受け付けた場合に開始される。
Figure 11 is a flowchart showing an example of the processing of the
ステップＳ１０１～Ｓ１０４は前記実施例１の図５に示したステップＳ５１～Ｓ５４と同様の処理である。 Steps S101 to S104 are the same as steps S51 to S54 shown in Figure 5 of the first embodiment.
入出力装置２５から許可又は拒否の応答を受け付けたパラメータ検出部１１２４は、優先度変更の可否が設定されたａｐｐｒｉｃａｔｉｏｎＩＤ３０３と同一のＩＤを含むアプリケーション２のリクエストメッセージ３００を取得し、優先度変更の可否が「Ｔｒｕｅ」（許可）であるかを判定し（Ｓ１０５）、「Ｔｒｕｅ」であればステップＳ１０６へ進み、「Ｆａｌｓｅ」（拒否）であればステップＳ１０７へ進む。
The
ステップＳ１０６では、パラメータ検出部１１２４が、優先度変更要求に含まれる要求優先度をパラメータとして生成し、優先度設定部１１３に出力する（Ｓ１０８）。一方、優先度変更が不可であれば、パラメータ検出部１１２４は０の値をパラメータとし（Ｓ１０７）、優先度設定部１１３に出力する（Ｓ１０８）。
In step S106, the
優先度設定部１１３の優先度計算部１１３２は、受け付けたパラメータが０値であれば、アプリ優先度（３０４）をそのまま可変優先度に設定し、０でなければ、要求優先度を可変優先度に設定して出力する。
If the received parameter is 0, the
次に、リクエスト分析部１１２のリクエスト取得部１１２１は、優先度設定部１１３からパラメータの受信完了の通知（レスポンス）を待って処理を終了する（Ｓ１０９）。
Next, the
なお、上記の他に、要求優先度は、通常時は「０」に設定され、予め設定された緊急時は「１」に設定しておき、緊急時には、可変優先度を最優先順位に設定することも可能である。 In addition to the above, the request priority can be set to "0" under normal circumstances and to "1" in a pre-defined emergency, and in an emergency the variable priority can be set as the highest priority.
実施例２より、停電が起きた場合の電力インフラの保守アプリケーションや、洪水が起きた場合の下水道インフラの保守アプリケーションなど、平常より、優先されるべき事故や災害が発生した場合、それらのアプリケーション２が優先度変更を要求する場合に、データ要求処理装置１は当該アプリケーション２の優先順位を上げることが可能となる。なお、混雑度を計算するアプリケーション２が、都市内のイベントにより人の混雑発生した場合に、データ要求処理装置１が当該アプリケーション２の優先順位を上げるようにしてもよい。
According to the second embodiment, when an accident or disaster occurs that should be prioritized over normal times, such as an application for maintaining power infrastructure in the event of a power outage or an application for maintaining sewerage infrastructure in the event of a flood, and when such an application 2 requests a change in priority, the data
実施例３は、アプリケーション２が様々なアプリケーションで利用された汎用性が高いデータにアクセスする場合に、過去のリクエストメッセージを用いて、優先順位を変更するためのパラメータを生成するリクエスト分析部１１２の例に関して説明する。
Example 3 describes an example of a
図１２は、実施例３によるリクエスト分析部１１２の構成の一例を示す。実施例３のリクエスト分析部１１２は、リクエスト取得部１１２１と、アプリ優先度読み取り部１１２２と、クエリ読み取り部１１２３と、パラメータ検出部１１２４及びリクエスト記録部１１２８から構成される。
FIG. 12 shows an example of the configuration of the
リクエスト取得部１１２１、アプリ優先度読み取り部１１２２、クエリ読み取り部１１２３は実施例１と同様である。実施例３のリクエスト分析部１１２は、前記実施例１のレスポンス時間計算部１１２６とレスポンス時間テーブル１１２５を削除し、リクエスト記録部１１２８を加えた点が実施例１と相違する。
The
図１３は、実施例３によるリクエスト分析部の処理を示すフローチャートである。この処理は、リクエスト受信部１１１からリクエストメッセージ３００を受診した場合に実行される。
Figure 13 is a flowchart showing the processing of the request analysis unit according to the third embodiment. This processing is executed when a request message 300 is received from the
リクエスト取得部１１２１は、リクエスト受信部１１１に記録されているリクエストメッセージ３００を要求し、リクエストメッセージ３００を取得する（Ｓ１２１）。
The
リクエスト取得部１１２１は、取得したリクエストメッセージ３００をアプリ優先度読み取り部１１２２と、クエリ読み取り部に送信する（Ｓ１２２）。アプリ優先度読み取り部１１２２は、リクエストメッセージ３００からｒｅｑｕｅｓｔＩＤ３０１と、ｐｒｉｏｒｉｔｙ３０４を取得（Ｓ１２３）し、優先度設定部１１３に出力する（Ｓ１２７）。
The
クエリ読み取り部１１２３は、ｒｅｑｕｅｓｔＩＤ３０１と、ｒｅｑｕｅｓｔＴｉｍｅ３０２と、ａｐｐｒｉｃａｔｉｏｎＩＤ３０３と、クエリ３０５をリクエストメッセージ３００から取得優先度変更要求（Ｓ１２４）し、取得した情報をリクエスト記録部１１２８に記録を行う。また、クエリ読み取り部１１２３は、取得した情報をパラメータ検出部１１２４に出力する。
The
リクエスト記録部１１２８は過去のリクエストメッセージ３００のｒｅｑｕｅｓｔＴｉｍｅ３０２と、ａｐｐｒｉｃａｔｉｏｎＩＤ３０３と、ｑｕｅｒｙ３０５を記録する。リクエスト記録部１１２８は、ＳＳＤのような記憶装置か、ＤＲＡＭのように揮発性の記憶装置で構成することも可能である。
The
パラメータ検出部１１２４は、リクエスト記録部１１２８にアクセスして、ステップＳ１２４で取得したｒｅｑｕｅｓｔＴｉｍｅ３０２よりも過去のリクエストメッセージ３００を検索する（Ｓ１２５）。パラメータ検出部１１２４は、検索結果を用いてパラメータを生成する（Ｓ１２６）。パラメータ検出部１１２４は、生成されたパラメータを優先度設定部１１３に出力する（Ｓ１２７）。
The
例えば、汎用性の高いデータを要求する場合、パラメータ検出部１１２４は、ｒｅｑｕｅｓｔＴｉｍｅ３０２より一定期間の過去で、ａｐｐｒｉｃａｔｉｏｎＩＤ３０３が異なり、かつｑｕｅｒｙ３０５の同じデータを要求したリクエストメッセージ３００を検索しする。
For example, when requesting highly versatile data, the
パラメータ検出部１１２４は、同じデータを利用しているアプリケーションの数を特定し、アプリケーションの数が多い（又は最大）リクエストメッセージ３００のｑｕｅｒｙ３０５からパラメータを生成し（Ｓ１２６）、優先度設定部１１３に送信する（Ｓ１２７）。
The
次に、リクエスト分析部１１２のリクエスト取得部１１２１は、優先度設定部１１３からパラメータの受信完了の通知（レスポンス）を待って処理を終了する（Ｓ１２８）。
Next, the
なお、特定したアプリケーション数は毎回のリクエストメッセージ３００に対して算出するか、算出したアプリケーション数をリクエスト記録部１１２８に一定時間記録しておいて、以降のリクエストメッセージ３００はその値をパラメータとして設定する方法もある。優先度設定部１１３の優先度計算部１１３２は、実施例１と同様の方法で、可変優先度の設定を実施する。
The number of identified applications can be calculated for each request message 300, or the calculated number of applications can be recorded in the
実施例３により、過去のリクエストメッセージ３００の情報を用いて、優先順位を上げ、リクエストメッセージ３００の処理を迅速化することで、データ取得までの時間を短縮することができる。 In Example 3, by using information on past request messages 300, the priority can be increased and the processing of the request messages 300 can be expedited, thereby shortening the time it takes to obtain data.
＜結び＞
以上のように、上記実施例のデータ要求処理装置１は、以下のような構成とすることができる。
<Conclusion>
As described above, the data
（１）プロセッサ（２１）とメモリを有するデータ要求処理装置（１）であって、データベース（５又は外部データベース６）に格納されているデータをリクエストするメッセージ（リクエストメッセージ３００）を受信し、前記メッセージ（３００）に含まれるデータ要求（ｑｕｅｒｙ３０５）に優先度（可変優先度）を設定して、前記優先度に応じて前記データ要求（３０５）の処理順序を決定する優先度制御部（１１）を有し、前記優先度制御部（１１）は、前記メッセージ（３００）を受信する受信部（リクエスト受信部１１１）と、前記メッセージ（３００）に含まれるデータ要求（３０５）を取得し、前記データ要求（３０５）を分析して、前記優先度の設定に必要なパラメータ（推定レスポンス時間（実測レスポンス時間１２０４）又は外部アクセス判定結果）を生成する分析部（リクエスト分析部１１２）と、前記パラメータ（１２０４又は外部アクセス判定結果）を用いて前記データ要求（３０５）に優先度を設定する優先度設定部（１１３）と、を有し、前記優先度設定部（１１３）は、前記パラメータ（１２０４又は外部アクセス判定結果）を受け付けて、所定のルールで前記パラメータ（１２０４又は外部アクセス判定結果）を分類し、前記分類の結果に応じて前記データ要求（３０５）の優先度（可変優先度）を設定することを特徴とするデータ要求処理装置。 (1) A data request processing device (1) having a processor (21) and a memory, the device having a priority control unit (11) that receives a message (request message 300) requesting data stored in a database (5 or an external database 6), sets a priority (variable priority) for a data request (query 305) included in the message (300), and determines the processing order of the data request (305) according to the priority, the priority control unit (11) having a receiving unit (request receiving unit 111) that receives the message (300), obtains the data request (305) included in the message (300), and divides the data request (305) into A data request processing device comprising: an analysis unit (request analysis unit 112) that analyzes the request and generates parameters (estimated response time (actual response time 1204) or external access judgment result) necessary for setting the priority; and a priority setting unit (113) that sets a priority for the data request (305) using the parameters (1204 or external access judgment result), wherein the priority setting unit (113) accepts the parameters (1204 or external access judgment result), classifies the parameters (1204 or external access judgment result) according to a predetermined rule, and sets a priority (variable priority) for the data request (305) according to the result of the classification.
上記構成により、データ要求処理装置１は、パラメータ（１２０４又は外部アクセス判定結果）の状況に応じてダイナミックでかつ柔軟にリクエストの優先度を制御して、リアルタイム性が必要なアプリケーションは安定的にデータを取得することができる。
With the above configuration, the data
（２）上記（１）に記載のデータ要求処理装置であって、前記分析部（１１２）は、過去に算出されたレスポンス時間（実測レスポンス時間１２０４）を蓄積したテーブル（レスポンス時間テーブル１１２５）を参照し、前記データ要求（３０５）に対応するレスポンス時間（１２０４）を取得して前記パラメータとして出力し、前記優先度設定部（１１３）は、前記レスポンス時間（推定レスポンス時間）に応じて前記データ要求（３０５）に前記優先度を設定することを特徴とするデータ要求処理装置。 (2) A data request processing device according to (1) above, characterized in that the analysis unit (112) refers to a table (response time table 1125) that accumulates previously calculated response times (actual response times 1204), obtains the response time (1204) corresponding to the data request (305), and outputs it as the parameter, and the priority setting unit (113) sets the priority to the data request (305) according to the response time (estimated response time).
上記構成により、データ要求処理装置１は、レスポンスまでにかかった時間情報（推定レスポンス時間）に基づいて、優先順位（可変優先度）を変更し、リクエストメッセージの処理を迅速化することで、端末１００から要求されたデータの取得までの時間を短縮することができる。
With the above configuration, the data
（３）上記（２）に記載のデータ要求処理装置であって、前記優先度設定部（１１３）が設定した前記優先度に応じた前記データ要求（３０５）を前記データベース（５、６）に送信するスケジューリング部（１２）を、さらに有し、前記分析部（１１２）は、前記データ要求（３０５）が前記スケジューリング部（１２）で送信されてから前記データベース（５、６）からの応答を受け付けるまでの時間をレスポンス時間（１２０４）として計算して前記テーブル（１１２５）に蓄積するレスポンス時間計算部（１１２６）を、さらに有することを特徴とするデータ要求処理装置。 (3) The data request processing device according to (2) above, further comprising a scheduling unit (12) that transmits the data request (305) to the database (5, 6) according to the priority set by the priority setting unit (113), and the analysis unit (112) further comprises a response time calculation unit (1126) that calculates the time from when the data request (305) is transmitted by the scheduling unit (12) to when a response is received from the database (5, 6) as a response time (1204) and stores the calculated time in the table (1125).
上記構成により、データ要求処理装置１は、レスポンスまでにかかった時間情報（推定レスポンス時間）に基づいて、優先順位（可変優先度）を変更し、リクエストメッセージの処理を迅速化することで、端末１００から要求されたデータの取得までの時間を短縮することができる。
With the above configuration, the data
（４）上記（１）に記載のデータ要求処理装置であって、 前記優先度設定部（１１３）は、前記分析部（１１２）から出力されたパラメータ（１２０４又は外部アクセス判定結果）と、予め設定された閾値とを比較して、前記比較の結果に応じて前記データ要求（３０５）の前記優先度を設定することを特徴とするデータ要求処理装置。 (4) The data request processing device according to (1) above, characterized in that the priority setting unit (113) compares the parameter (1204 or the external access judgment result) output from the analysis unit (112) with a preset threshold value, and sets the priority of the data request (305) according to the result of the comparison.
上記構成により、データ要求処理装置１は、レスポンスまでにかかった時間情報（推定レスポンス時間）と所定の閾値に基づいて、優先順位（可変優先度）を変更し、リクエストメッセージの処理を迅速化することで、端末１００から要求されたデータの取得までの時間を短縮することができる。
With the above configuration, the data
（５）上記（２）に記載のデータ要求処理装置であって、前記分析部（１１２）は、複数の前記データ要求（３０５）について前記レスポンス時間を取得して、前記複数のメッセージと複数の前記レスポンス時間を前記優先度設定部（１１３）に出力し、前記優先度設定部（１１３）は、前記複数のレスポンス時間に応じて、前記複数のデータ要求（３０５）の優先度を設定することを特徴とするデータ要求処理装置。 (5) The data request processing device according to (2) above, characterized in that the analysis unit (112) acquires the response times for the plurality of data requests (305) and outputs the plurality of messages and the plurality of response times to the priority setting unit (113), and the priority setting unit (113) sets priorities for the plurality of data requests (305) according to the plurality of response times.
上記構成により、パラメータ検出部１１２４が、複数のリクエストメッセージ３００について推定レスポンス時間を取得して、複数のリクエストメッセージ３００と複数の推定レスポンス時間を優先度設定部１１３に出力することができる。この場合、パラメータ受信部１１３１で、複数のリクエストメッセージと複数の推定レスポンス時間を優先度計算部１１３２に出力し、優先度計算部１１３２は、複数のリクエストメッセージの推定レスポンス時間を比較して、推定レスポンス時間が最長時間か、推定レスポンス時間が長い上位いくつかの優先順位を上げることができる。
With the above configuration, the
また、パラメータ受信部１１３１から、一定期間の間に貯められたリクエストメッセージのパラメータ（１２０４又は外部アクセス判定結果）を優先度計算部１１３２に出力する場合、優先度計算部１１３２は、推定レスポンス時間が最長時間か、推定レスポンス時間が上位いくつかのリクエストメッセージか、推定レスポンス時間が上位何割かのリクエストメッセージの優先順位を上げることも可能である。
In addition, when the
（６）上記（２）に記載のデータ要求処理装置であって、前記受信部は、前記優先度の変更要求を受信し、前記分析部（１１２）は、前記優先度の変更要求の可否の問い合せを出力し、前記問い合せに対する応答を受け付け、当該応答の内容（Ｔｒｕｅ又はＦａｌｓｅ）を前記優先度設定部（１１３）に出力し、前記優先度設定部（１１３）は、前記応答の内容に応じて前記優先度を設定することを特徴とするデータ要求処理装置。 (6) The data request processing device according to (2) above, characterized in that the receiving unit receives the request to change the priority, the analysis unit (112) outputs an inquiry as to whether the priority change request is acceptable, receives a response to the inquiry, outputs the content of the response (True or False) to the priority setting unit (113), and the priority setting unit (113) sets the priority according to the content of the response.
上記構成により、データ要求処理装置１は、停電が起きた場合の電力インフラの保守アプリケーションや、洪水が起きた場合の下水道インフラの保守アプリケーションなど、平常より、優先されるべき事故や災害が発生した場合、それらのアプリケーション２が優先度変更を要求する場合に、データ要求処理装置１は当該アプリケーション２の優先順位を上げることが可能となる。
With the above configuration, when an accident or disaster occurs that should be prioritized over normal times, such as a power infrastructure maintenance application in the event of a power outage or a sewer infrastructure maintenance application in the event of a flood, and such application 2 requests a priority change, the data
（７）上記（６）に記載のデータ要求処理装置であって、前記分析部（１１２）は、前記問い合せに対する応答がＴｒｕｅを含む場合には、前記優先度設定部（１１３）に前記優先度の変更要求を通知し、前記優先度設定部（１１３）は、前記通知に応じて前記優先度を設定することを特徴とするデータ要求処理装置。 (7) The data request processing device according to (6) above, characterized in that, when the response to the inquiry includes True, the analysis unit (112) notifies the priority setting unit (113) of a request to change the priority, and the priority setting unit (113) sets the priority in response to the notification.
上記構成により、優先度設定部１１３の優先度計算部１１３２は、受け付けたパラメータ（１２０４）が０値であれば、アプリ優先度（３０４）をそのまま可変優先度に設定し、０でなければ、要求優先度を可変優先度に設定して出力することができる。
With the above configuration, if the received parameter (1204) is 0, the
（８）上記（１）に記載のデータ要求処理装置であって、前記分析部（１１２）は、過去のメッセージ（３００）に含まれるデータ要求（３０５）を記録する記録部（１１２８）と、前記記録部（１１２８）から過去のデータ要求（３０５）を検索して、前記パラメータ（１２０４又は外部アクセス判定結果）を生成する検出部（パラメータ検出部１１２４）と、を有することを特徴とするデータ要求処理装置。 (8) The data request processing device according to (1) above, characterized in that the analysis unit (112) has a recording unit (1128) that records the data request (305) included in the past message (300), and a detection unit (parameter detection unit 1124) that searches the recording unit (1128) for the past data request (305) and generates the parameter (1204 or external access judgment result).
上記構成により、データ要求処理装置１は、過去のリクエストメッセージ３００の情報を用いて、優先順位を上げ、リクエストメッセージ３００の処理を迅速化することで、データ取得までの時間を短縮することができる。
With the above configuration, the data
（９）上記（１）に記載のデータ要求処理装置であって、上記（８）に記載のデータ要求処理装置であって、前記検出部（１１２４）は、前記記録部（１１２８）から、異なるアプリケーションで、かつ、前記データ要求（３０５）と同一のデータを要求した過去のデータ要求（３０５）を検索し、前記アプリケーションの数を取得し、前記アプリケーションの数が所定の条件を満たすデータ要求（３０５）からパラメータを生成することを特徴とするデータ要求処理装置。 (9) The data request processing device according to (1) above, which is also according to (8) above, characterized in that the detection unit (1124) searches the recording unit (1128) for past data requests (305) that are different applications and that request the same data as the data request (305), obtains the number of applications, and generates parameters from the data request (305) for which the number of applications satisfies a predetermined condition.
上記構成により、データ要求処理装置１は、アプリケーションの数が所定の条件（例えば、最大）を満たすデータ要求からパラメータ（１２０４又は外部アクセス判定結果）を生成することができ、過去のリクエストメッセージ３００の情報を用いて、優先順位を上げ、リクエストメッセージ３００の処理を迅速化することで、データ取得までの時間を短縮することができる。
With the above configuration, the data
なお、本発明は上記した実施例に限定されるものではなく、様々な変形例が含まれる。例えば、上記した実施例は本発明を分かりやすく説明するために詳細に記載したものであり、必ずしも説明した全ての構成を備えるものに限定されるものではない。また、ある実施例の構成の一部を他の実施例の構成に置き換えることが可能であり、また、ある実施例の構成に他の実施例の構成を加えることも可能である。また、各実施例の構成の一部について、他の構成の追加、削除、又は置換のいずれもが、単独で、又は組み合わせても適用可能である。 The present invention is not limited to the above-described embodiments, but includes various modified examples. For example, the above-described embodiments are described in detail to clearly explain the present invention, and are not necessarily limited to those having all of the configurations described. It is also possible to replace part of the configuration of one embodiment with the configuration of another embodiment, and it is also possible to add the configuration of another embodiment to the configuration of one embodiment. In addition, the addition, deletion, or replacement of part of the configuration of each embodiment with other configurations can be applied alone or in combination.
また、上記の各構成、機能、処理部、及び処理手段等は、それらの一部又は全部を、例えば集積回路で設計する等によりハードウェアで実現してもよい。また、上記の各構成、及び機能等は、プロセッサがそれぞれの機能を実現するプログラムを解釈し、実行することによりソフトウェアで実現してもよい。各機能を実現するプログラム、テーブル、ファイル等の情報は、メモリや、ハードディスク、ＳＳＤ（Ｓｏｌｉｄ Ｓｔａｔｅ Ｄｒｉｖｅ）等の記録装置、又は、ＩＣカード、ＳＤカード、ＤＶＤ等の記録媒体に置くことができる。 The above configurations, functions, processing units, and processing means may be realized in part or in whole in hardware, for example by designing them as integrated circuits. The above configurations and functions may be realized in software by a processor interpreting and executing a program that realizes each function. Information on the programs, tables, files, etc. that realize each function may be stored in a memory, a recording device such as a hard disk or SSD (Solid State Drive), or a recording medium such as an IC card, SD card, or DVD.
また、制御線や情報線は説明上必要と考えられるものを示しており、製品上必ずしも全ての制御線や情報線を示しているとは限らない。実際には殆ど全ての構成が相互に接続されていると考えてもよい。 In addition, the control lines and information lines shown are those considered necessary for the explanation, and not all control lines and information lines on the product are necessarily shown. In reality, it can be assumed that almost all components are interconnected.
１ データ要求処理装置
２ アプリケーション
３、４ ネットワーク
５ データベース
６ 外部データベース
７ データ送信部
１１ 優先度制御部
１２ スケジューリング部
１１１ リクエスト受信部
１１２ リクエスト分析部
１１３ 優先度設定部
１１４ 管理部
３００ リクエストメッセージ
１１２１ リクエスト取得部
１１２２ アプリ優先度読み取り部
１１２３ クエリ読み取り部
１１２４ パラメータ検出部
１１２５ パラメータテーブル
１１２６ レスポンス時間計算部
１１２７ 優先度変更要求取得部
１１２８ リクエスト記録部
１１３１ パラメータ受信部
１１３２ 優先度計算部
１１３３ 処理順序制御部
REFERENCE SIGNS
Claims (4)
データベースに格納されているデータをリクエストするメッセージを受信し、前記メッセージに含まれるデータ要求に優先度を設定して、前記優先度に応じて前記データ要求の処理順序を決定する優先度制御部を有し、
前記優先度制御部は、
前記メッセージを受信する受信部と、
前記メッセージに含まれるデータ要求を取得し、前記データ要求を分析して前記優先度の設定に必要なパラメータを生成する分析部と、
前記パラメータを用いて前記データ要求に優先度を設定する優先度設定部と、を有し、
前記優先度設定部は、
前記パラメータを受け付けて、所定のルールで前記パラメータを分類し、前記分類の結果に応じて前記データ要求の優先度を設定し、
前記分析部は、
過去のメッセージに含まれるデータ要求を記録する記録部と、
前記記録部から過去のデータ要求を検索して、前記パラメータを生成する検出部と、を有し、
前記検出部は、
前記記録部から、異なるアプリケーションで、かつ、前記データ要求と同一のデータを要求した過去のデータ要求を検索し、前記アプリケーションの数を取得し、前記アプリケーションの数が所定の条件を満たすデータ要求からパラメータを生成することを特徴とするデータ要求処理装置。 A data request processing device having a processor and a memory,
a priority control unit that receives a message requesting data stored in a database, sets priorities for the data requests included in the message, and determines an order of processing the data requests in accordance with the priorities;
The priority control unit
A receiving unit for receiving the message;
an analysis unit that acquires a data request included in the message, analyzes the data request, and generates parameters necessary for setting the priority;
a priority setting unit that sets a priority to the data request using the parameter,
The priority setting unit
receiving the parameters, classifying the parameters according to a predetermined rule, and setting a priority of the data request according to a result of the classification ;
The analysis unit includes:
a recorder for recording data requests included in past messages;
a detection unit that searches the recording unit for past data requests and generates the parameters;
The detection unit is
A data request processing device characterized by searching the recording unit for past data requests that were made using a different application and that requested the same data as the data request, obtaining the number of the applications, and generating parameters from a data request for which the number of applications satisfies a predetermined condition .
前記優先度設定部は、The priority setting unit
前記分析部から出力されたパラメータと、予め設定された閾値とを比較して、前記比較の結果に応じて前記データ要求の前記優先度を設定することを特徴とするデータ要求処理装置。2. A data request processing device comprising: a processor for processing data requests, the processor for processing data requests being processed by a processor for processing data; a processor for processing data being processed by a processor for processing data;
前記計算機が、データベースに格納されているデータをリクエストするメッセージを受信する受信ステップと、a receiving step by said computer receiving a message requesting data stored in a database;
前記計算機が、前記メッセージに含まれるデータ要求を取得し、前記データ要求を分析して優先度の設定に必要なパラメータを生成する分析ステップと、an analysis step in which the computer acquires a data request included in the message and analyzes the data request to generate parameters necessary for setting a priority;
前記計算機が、前記パラメータを受け付けて、所定のルールで前記パラメータを分類し、前記分類の結果に応じて前記データ要求の前記優先度を設定して、前記優先度に応じて前記データ要求の処理順序を決定する優先度設定ステップと、a priority setting step in which the computer receives the parameters, classifies the parameters according to a predetermined rule, sets the priority of the data requests in accordance with a result of the classification, and determines a processing order of the data requests in accordance with the priority;
を含み、Including,
前記分析ステップは、The analyzing step includes:
過去のメッセージに含まれるデータ要求を記録する記録ステップと、a recording step of recording data requests contained in past messages;
前記記録ステップで記録された過去のデータ要求を検索して、前記パラメータを生成する検出ステップと、を含み、a detection step of searching for past data requests recorded in the recording step to generate the parameters;
前記検出ステップは、前記記録ステップで記録された過去のデータ要求において、異なるアプリケーションで、かつ、前記データ要求と同一のデータを要求した過去のデータ要求を検索し、前記アプリケーションの数を取得し、前記アプリケーションの数が所定の条件を満たすデータ要求からパラメータを生成することを特徴とするデータ要求処理方法。The detection step is characterized in that, among past data requests recorded in the recording step, a past data request that requested the same data as the data request from a different application is searched for, the number of the applications is obtained, and a parameter is generated from a data request for which the number of applications satisfies a predetermined condition.
データベースに格納されているデータをリクエストするメッセージを受信する受信ステップと、a receiving step of receiving a message requesting data stored in a database;
前記メッセージに含まれる前記データ要求を取得し、前記データ要求を分析して優先度の設定に必要なパラメータを生成する分析ステップと、an analysis step of acquiring the data request included in the message and analyzing the data request to generate parameters necessary for setting a priority;
前記パラメータを受け付けて、所定のルールで前記パラメータを分類し、前記分類の結果に応じて前記データ要求の前記優先度を設定して、前記優先度に応じて前記データ要求の処理順序を決定する優先度設定ステップと、を含み、a priority setting step of receiving the parameters, classifying the parameters according to a predetermined rule, setting the priority of the data requests according to a result of the classification, and determining a processing order of the data requests according to the priority,
前記分析ステップは、The analyzing step includes:
過去のメッセージに含まれるデータ要求を記録する記録ステップと、a recording step of recording data requests contained in past messages;
前記記録ステップで記録された過去のデータ要求を検索して、前記パラメータを生成する検出ステップと、を含み、a detection step of searching for past data requests recorded in the recording step to generate the parameters;
前記検出ステップは、前記記録ステップで記録された過去のデータ要求において、異なるアプリケーションで、かつ、前記データ要求と同一のデータを要求した過去のデータ要求を検索し、前記アプリケーションの数を取得し、前記アプリケーションの数が所定の条件を満たすデータ要求からパラメータを生成する、処理を前記計算機に実行させるためのプログラムを格納した非一時的な計算機読み取り可能な記憶媒体。The detection step is a non-transitory computer-readable storage medium storing a program for causing the computer to execute a process of searching for past data requests recorded in the recording step that were made using different applications and that requested the same data as the data request, obtaining the number of the applications, and generating parameters from data requests for which the number of the applications satisfies a predetermined condition.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2020189329A JP7464503B2 (en) | 2020-11-13 | 2020-11-13 | Data request processing device, data request processing method and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2020189329A JP7464503B2 (en) | 2020-11-13 | 2020-11-13 | Data request processing device, data request processing method and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2022078575A JP2022078575A (en) | 2022-05-25 |
| JP7464503B2 true JP7464503B2 (en) | 2024-04-09 |
Family
ID=81706906
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2020189329A Active JP7464503B2 (en) | 2020-11-13 | 2020-11-13 | Data request processing device, data request processing method and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP7464503B2 (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2005339243A (en) | 2004-05-27 | 2005-12-08 | Fuji Xerox Co Ltd | Printing control device, method, and program |
| JP2006190005A (en) | 2005-01-04 | 2006-07-20 | Internatl Business Mach Corp <Ibm> | Priority determination device, service process allocation device, control method, and program |
| JP2006313576A (en) | 2006-08-24 | 2006-11-16 | Fujitsu Ltd | Service providing order changing method, service providing apparatus, and service providing program |
| JP2008191819A (en) | 2007-02-02 | 2008-08-21 | Toshiba Corp | Online trading system |
| CN110928944A (en) | 2018-08-30 | 2020-03-27 | 阿里巴巴集团控股有限公司 | Data processing method and device |
-
2020
- 2020-11-13 JP JP2020189329A patent/JP7464503B2/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2005339243A (en) | 2004-05-27 | 2005-12-08 | Fuji Xerox Co Ltd | Printing control device, method, and program |
| JP2006190005A (en) | 2005-01-04 | 2006-07-20 | Internatl Business Mach Corp <Ibm> | Priority determination device, service process allocation device, control method, and program |
| JP2006313576A (en) | 2006-08-24 | 2006-11-16 | Fujitsu Ltd | Service providing order changing method, service providing apparatus, and service providing program |
| JP2008191819A (en) | 2007-02-02 | 2008-08-21 | Toshiba Corp | Online trading system |
| CN110928944A (en) | 2018-08-30 | 2020-03-27 | 阿里巴巴集团控股有限公司 | Data processing method and device |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2022078575A (en) | 2022-05-25 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11777949B2 (en) | Dynamic user access control management | |
| US9952753B2 (en) | Predictive caching and fetch priority | |
| US9304815B1 (en) | Dynamic replica failure detection and healing | |
| US11275667B2 (en) | Handling of workload surges in a software application | |
| CN100517317C (en) | Method, system, and program product for maintaining a fileset namespace accessible by clients over a network | |
| CN107451853B (en) | A method, device, system and storage medium for real-time distribution of red envelopes | |
| CN107491470B (en) | Data management system, control method, and storage medium | |
| EP4080377B1 (en) | Method to implement multi-tenant/shared redis cluster using envoy | |
| US8135762B2 (en) | System and method for determining true computer file type identity | |
| CN106874423B (en) | Search control method and system | |
| CN114661419A (en) | Service quality control system and method | |
| WO2024119793A1 (en) | Scheduling method, system and device based on cache affinity, and medium | |
| US12020081B2 (en) | Method to implement multi-tenant/shared redis cluster using envoy | |
| US20100161585A1 (en) | Asymmetric cluster filesystem | |
| JP2018092389A (en) | File management device and program | |
| CN119441171A (en) | Distributed object storage method, device, equipment and medium | |
| US20130132552A1 (en) | Application-Aware Quality Of Service In Network Applications | |
| JP7464503B2 (en) | Data request processing device, data request processing method and storage medium | |
| JP6607044B2 (en) | Server device, distributed file system, distributed file system control method, and program | |
| JP6076882B2 (en) | Information processing system, management device, and key assignment program | |
| JP6127754B2 (en) | Program, exclusive control request distribution method and system | |
| US20210326386A1 (en) | Information processing system, information processing device, and non-transitory computer-readable storage medium for storing program | |
| CN120492188A (en) | Interface aggregation request method, device, apparatus, storage medium and program product | |
| JP2017117015A (en) | Information processing system, proxy device, proxy control method, and proxy program | |
| JP2020021344A (en) | Information management apparatus, information management method and program |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20230206 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20230920 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20231010 |
|
| A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20231206 |
|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20240305 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20240328 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 7464503 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |