JP7729149B2 - Management device and processing method - Google Patents
Management device and processing methodInfo
- Publication number
- JP7729149B2 JP7729149B2 JP2021158380A JP2021158380A JP7729149B2 JP 7729149 B2 JP7729149 B2 JP 7729149B2 JP 2021158380 A JP2021158380 A JP 2021158380A JP 2021158380 A JP2021158380 A JP 2021158380A JP 7729149 B2 JP7729149 B2 JP 7729149B2
- Authority
- JP
- Japan
- Prior art keywords
- vehicle
- information
- representative node
- communication
- node
- 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
Landscapes
- Mobile Radio Communication Systems (AREA)
Description
ここに開示する技術は、グリッドコンピューティングに関する。 The technology disclosed here relates to grid computing.
特許文献1には、分散処理システムが開示されている。この分散処理システムは、第1の態様と、第2の態様とをとりうる。第1の態様は、無線通信によって互いに接続可能な基地局と複数の車載端末から構成され、基地局が管理ノードとして機能し、複数の車載端末が計算ノードとして機能する。第2の態様は、無線通信によって互いに接続可能な複数の車載端末から構成され、複数の車載端末のうち少なくとも1つが管理ノードとして機能し、その他の車載端末が計算ノードとして機能する。 Patent Document 1 discloses a distributed processing system. This distributed processing system can take a first or second form. The first form is composed of a base station and multiple on-board terminals that can connect to each other via wireless communication, with the base station functioning as a management node and the multiple on-board terminals functioning as calculation nodes. The second form is composed of multiple on-board terminals that can connect to each other via wireless communication, with at least one of the multiple on-board terminals functioning as a management node and the other on-board terminals functioning as calculation nodes.
しかしながら、特許文献1では、分散処理システム(グリッドコンピューティング)における通信安定性をどのようにして確保するのか論じられていない。 However, Patent Document 1 does not discuss how to ensure communication stability in a distributed processing system (grid computing).
ここに開示する技術は、かかる点に鑑みてなされたものであり、その目的とするところは、グリッドコンピューティングにおける通信安定性を確保することにある。 The technology disclosed here was developed in light of these issues, and its purpose is to ensure communication stability in grid computing.
ここに開示する技術は、それぞれが演算装置を有する複数の移動体のうち複数の利用可能な移動体にジョブデータを処理させるグリッドコンピューティング処理を管理する管理装置に関する。この管理装置は、前記グリッドコンピューティング処理において、前記ジョブデータを前記複数の利用可能な移動体のうち前記管理装置との間の通信安定度が予め定められた閾値を上回る移動体である代表ノードに送信し、前記代表ノードに送信されたジョブデータを前記複数の利用可能な移動体のうち前記代表ノードを除く他の移動体である非代表ノードに送信するように前記代表ノードを制御し、前記非代表ノードに送信されたジョブデータを前記非代表ノードに処理させる制御部を備える。前記制御部と前記代表ノードは、通信網を経由して通信し、前記代表ノードと前記非代表ノードは、前記通信網を経由せずに直接的に通信する。 The technology disclosed herein relates to a management device that manages grid computing processing in which job data is processed by a plurality of available mobile bodies out of a plurality of mobile bodies, each having a computing device. In the grid computing processing, the management device transmits the job data to a representative node, which is one of the available mobile bodies whose communication stability with the management device exceeds a predetermined threshold; controls the representative node to transmit the job data transmitted to the representative node to non-representative nodes, which are other mobile bodies out of the available mobile bodies excluding the representative node; and has the non-representative nodes process the job data transmitted to the non-representative nodes. The control device and the representative node communicate via a communications network, and the representative node and the non-representative nodes communicate directly without going through the communications network.
前記の構成では、管理装置と代表ノードとの間の通信安定性を確保することができる。 The above configuration ensures stable communication between the management device and the representative node.
前記の管理装置において、前記制御部は、前記複数の利用可能な移動体のうち前記管理装置との間の通信安定度が前記閾値を上回る移動体を、前記代表ノードとして機能させる移動体に決定し、前記複数の利用可能な移動体のうち前記代表ノードと通信可能な移動体を、前記非代表ノードとして機能させる移動体に決定してもよい。 In the management device, the control unit may determine, among the plurality of available mobile objects, a mobile object whose communication stability with the management device exceeds the threshold value as a mobile object to function as the representative node, and may determine, among the plurality of available mobile objects, a mobile object that can communicate with the representative node as a mobile object to function as the non-representative node.
前記の構成では、制御部(管理側)が代表ノードと非代表ノードとを予め決定することで、「通信網を経由する通信経路」と「通信網を経由しない通信経路」とを決定することができる。そして、管理装置との通信安定性が高い移動体を代表ノードにすることで、通信経路全体としての通信安定性を高めることができる。 In the above configuration, the control unit (management side) determines the representative node and non-representative nodes in advance, making it possible to determine a "communication route via the communication network" and a "communication route that does not go through the communication network." Then, by selecting a mobile device with high communication stability with the management device as the representative node, it is possible to improve communication stability across the entire communication route.
前記の管理装置において、前記制御部は、前記ジョブデータを分割することにより得られる複数の部分ジョブデータの各々に対し、当該部分ジョブデータを処理させる前記非代表ノードを決定してもよい。 In the management device, the control unit may determine, for each of multiple partial job data obtained by dividing the job data, the non-representative node that will process the partial job data.
前記の構成では、制御部(管理側)が非代表ノードに割り当てる部分ジョブデータを予め決定することで、制御部(管理側)が各通信経路における通信量を制御することができる。 In the above configuration, the control unit (management side) can control the amount of communication on each communication path by predetermining the partial job data to be assigned to non-representative nodes.
前記の管理装置において、前記制御部は、前記グリッドコンピューティング処理において、前記代表ノードに対して、前記複数の部分ジョブデータのうち当該代表ノードに対応する前記非代表ノードに処理させる部分ジョブデータと、当該部分ジョブデータを処理させる前記非代表ノードを示す送信先情報とを送信してもよい。 In the management device, the control unit may, in the grid computing processing, transmit to the representative node partial job data of the plurality of partial job data to be processed by the non-representative node corresponding to the representative node, and destination information indicating the non-representative node that is to process the partial job data.
前記の構成では、どの部分ジョブデータをどの非代表ノードに送信するのかを、代表ノードに適切に指示することができる。 With the above configuration, it is possible to appropriately instruct the representative node which partial job data to send to which non-representative node.
前記の管理装置において、前記代表ノードは、前記グリッドコンピューティング処理において、前記制御部から送信された部分ジョブデータを、前記送信先情報に示された当該部分ジョブデータを処理させる前記非代表ノードに送信してもよい。 In the management device, the representative node may transmit partial job data transmitted from the control unit to the non-representative node that processes the partial job data indicated in the destination information during the grid computing process.
前記の構成では、代表ノードから非代表ノードに部分ジョブデータを適切に送信することができる。 With the above configuration, partial job data can be properly sent from the representative node to non-representative nodes.
前記の管理装置において、前記制御部は、前記グリッドコンピューティング処理において、前記ジョブデータの計算結果を示す計算結果データを前記代表ノードに送信するように前記非代表ノードを制御し、前記代表ノードに送信された計算結果データを前記管理装置に送信するように前記代表ノードを制御するように構成されてもよい。 In the management device, the control unit may be configured to control the non-representative node to transmit calculation result data indicating the calculation results of the job data to the representative node in the grid computing process, and to control the representative node to transmit the calculation result data transmitted to the representative node to the management device.
前記の構成では、管理装置と代表ノードとの間の通信(通信安定性が確保された通信)を利用して計算結果データを送信することができる。 In the above configuration, calculation result data can be sent using communication between the management device and the representative node (communication with guaranteed communication stability).
前記の管理装置において、前記非代表ノードは、前記代表ノードを基準とする通信可能範囲内に位置してもよい。 In the management device, the non-representative node may be located within a communication range based on the representative node.
前記の構成では、代表ノードと非代表ノードとの間の通信安定性を確保することができる。 The above configuration ensures communication stability between the representative node and non-representative nodes.
ここに開示する技術は、それぞれが演算装置を有する複数の移動体のうち複数の利用可能な移動体に管理装置により送信されたジョブデータを処理させる処理方法に関する。この方法では、前記管理装置により、前記ジョブデータを、前記複数の利用可能な移動体のうち前記管理装置との間の通信安定度が予め定められた閾値を上回る移動体である代表ノードに送信し、前記代表ノードにより、前記代表ノードに送信されたジョブデータを、前記複数の利用可能な移動体のうち前記代表ノードを除く他の移動体である非代表ノードに送信し、前記非代表ノードにより、前記非代表ノードに送信されたジョブデータを処理する。前記管理装置と前記代表ノードは、通信網を経由して通信し、前記代表ノードと前記非代表ノードは、前記通信網を経由せずに直接的に通信する。 The technology disclosed herein relates to a processing method for having a plurality of available mobile bodies out of a plurality of mobile bodies each having a computing device process job data transmitted by a management device. In this method, the management device transmits the job data to a representative node, which is one of the available mobile bodies and whose communication stability with the management device exceeds a predetermined threshold, and the representative node transmits the job data transmitted to the representative node to non-representative nodes, which are other mobile bodies out of the available mobile bodies excluding the representative node, and the non-representative nodes process the job data transmitted to the non-representative nodes. The management device and the representative node communicate via a communication network, and the representative node and the non-representative nodes communicate directly without going through the communication network.
前記の方法では、管理装置と代表ノードとの間の通信安定性を確保することができる。 The above method ensures communication stability between the management device and the representative node.
ここに開示する技術によれば、グリッドコンピューティングにおける通信安定性を確保することができる。 The technology disclosed here makes it possible to ensure communication stability in grid computing.
以下、図面を参照して実施の形態を詳しく説明する。なお、図中同一または相当部分には同一の符号を付しその説明は繰り返さない。 Embodiments will be described in detail below with reference to the drawings. Note that identical or corresponding parts in the drawings will be designated by the same reference numerals, and their description will not be repeated.
(実施形態)
図1は、実施形態のシステム1の構成を例示する。このシステム1は、複数の車両10と、複数のユーザ端末20と、クライアントサーバ30と、管理サーバ50とを備える。これらの構成要素は、通信網5(通信回線)を経由して互いに通信可能である。また、これらの構成要素は、必要に応じて、互いに通信して各種の情報およびデータを送受信する。複数の車両10の各々には、演算装置105が搭載される。なお、システム1には、複数のクライアントサーバ30が設けられてもよい。
(Embodiment)
FIG. 1 illustrates an example of the configuration of a system 1 according to an embodiment. The system 1 includes a plurality of vehicles 10, a plurality of user terminals 20, a client server 30, and a management server 50. These components can communicate with each other via a communication network 5 (communication line). These components also communicate with each other to transmit and receive various information and data as necessary. Each of the plurality of vehicles 10 is equipped with a computing device 105. Note that the system 1 may also include a plurality of client servers 30.
〔グリッドコンピューティング〕
図2に示すように、実施形態のシステム1では、複数の車両10の中から選出された車両10によりグリッドコンピューティング(分散処理システム)が構成され、複数の車両10のうち利用可能な車両10(詳しくは車両10に搭載された演算装置105)にジョブデータを処理させるグリッドコンピューティング処理が行われる。
[Grid Computing]
As shown in Figure 2, in the system 1 of the embodiment, grid computing (distributed processing system) is configured by vehicles 10 selected from a plurality of vehicles 10, and grid computing processing is performed in which job data is processed by an available vehicle 10 (more specifically, a computing device 105 installed in the vehicle 10) among the plurality of vehicles 10.
なお、車両10において演算装置105の計算能力が必要となると、演算装置105が稼働状態となり、演算装置105の計算能力が利用される。例えば、車両10が走行している場合、車両10の走行制御のために演算装置105の計算能力が必要となり、演算装置105が稼働状態となる。 When the vehicle 10 requires the computing power of the arithmetic unit 105, the arithmetic unit 105 enters an operating state and the computing power of the arithmetic unit 105 is utilized. For example, when the vehicle 10 is traveling, the computing power of the arithmetic unit 105 is required to control the traveling of the vehicle 10, and the arithmetic unit 105 enters an operating state.
一方、車両10において演算装置105の計算能力が不要となると、演算装置105が停止状態となり、演算装置105の計算能力が利用されなくなる。例えば、車両10が停車して車両10の電源がオフ状態になると、演算装置105の計算能力が不要となり、演算装置105が停止状態となる。 On the other hand, when the computing power of the arithmetic device 105 is no longer needed in the vehicle 10, the arithmetic device 105 enters a stopped state, and the computing power of the arithmetic device 105 is no longer used. For example, when the vehicle 10 is stopped and the power supply to the vehicle 105 is turned off, the computing power of the arithmetic device 105 is no longer needed, and the arithmetic device 105 enters a stopped state.
ここで、車両10において演算装置105の計算能力が不要である場合に、演算装置105の計算能力をグリッドコンピューティング処理に提供することで、演算装置105の計算能力を有効に利用することが可能となる。例えば、車両10の停車中に、演算装置105の計算能力をグリッドコンピューティング処理に提供することが望ましい。 Here, when the computing power of the computing device 105 is not needed in the vehicle 10, the computing power of the computing device 105 can be provided for grid computing processing, thereby making effective use of the computing power of the computing device 105. For example, it is desirable to provide the computing power of the computing device 105 for grid computing processing while the vehicle 10 is stopped.
〔車両〕
車両10は、ユーザに所有される。ユーザは、車両10を運転する。この例では、車両10は、自動四輪車である。また、車両10には、電池(図示省略)が搭載される。電池の電力は、演算装置105などの車載機器に供給される。このような車両10の例としては、電気自動車、プラグインハイブリッド自動車などが挙げられる。また、車両10は、車両ネットワーク間通信(V2N)を利用した通信および車車間通信(V2V)を利用した通信を行うことが可能である。
〔vehicle〕
The vehicle 10 is owned by a user. The user drives the vehicle 10. In this example, the vehicle 10 is a four-wheeled automobile. The vehicle 10 is equipped with a battery (not shown). Power from the battery is supplied to on-board devices such as the computing device 105. Examples of such vehicles 10 include electric vehicles and plug-in hybrid vehicles. The vehicle 10 is capable of communication using vehicle-to-network (V2N) communication and vehicle-to-vehicle (V2V) communication.
図3に示すように、車両10は、アクチュエータ11と、センサ12と、入力部101と、出力部102と、通信部103と、記憶部104と、演算装置105とを備える。 As shown in FIG. 3, the vehicle 10 includes an actuator 11, a sensor 12, an input unit 101, an output unit 102, a communication unit 103, a memory unit 104, and a computing device 105.
アクチュエータ11は、駆動系のアクチュエータ、操舵系のアクチュエータ、制動系のアクチュエータなどを含む。駆動系のアクチュエータの例としては、エンジン、トランスミッション、モータが挙げられる。制動系のアクチュエータの例としては、ブレーキが挙げられる。操舵系のアクチュエータの例としては、ステアリングが挙げられる。 Actuators 11 include drive system actuators, steering system actuators, braking system actuators, etc. Examples of drive system actuators include the engine, transmission, and motor. Examples of braking system actuators include brakes. Examples of steering system actuators include steering.
センサ12は、車両10の制御に用いられる各種の情報を取得する。センサ12の例としては、車外を撮像する車外カメラ、車内を撮像する車内カメラ、車外の物体を検出するレーダ、車速センサ、加速度センサ、ヨーレートセンサ、アクセル開度センサ、ステアリングセンサ、ブレーキ油圧センサなどが挙げられる。 Sensor 12 acquires various types of information used to control vehicle 10. Examples of sensors 12 include an exterior camera that captures images outside the vehicle, an interior camera that captures images inside the vehicle, radar that detects objects outside the vehicle, a vehicle speed sensor, an acceleration sensor, a yaw rate sensor, an accelerator position sensor, a steering sensor, and a brake oil pressure sensor.
入力部101は、情報やデータを入力する。入力部101の例としては、操作されることで操作に応じた情報を入力する操作部、情報を示す画像を入力するカメラ、情報を示す音声を入力するマイクロフォンなどが挙げられる。操作部の例としては、カーナビゲーション装置の操作ボタンやタッチセンサなどが挙げられる。入力部101に入力された情報やデータは、演算装置105に送られる。 The input unit 101 inputs information and data. Examples of the input unit 101 include an operation unit that is operated to input information corresponding to the operation, a camera that inputs an image representing information, and a microphone that inputs audio representing information. Examples of an operation unit include the operation buttons and touch sensors of a car navigation device. The information and data input to the input unit 101 are sent to the calculation device 105.
出力部102は、情報やデータを出力する。出力部102の例としては、情報を示す画像を出力する表示部、情報を示す音声を出力するスピーカなどが挙げられる。表示部の例としては、カーナビゲーション装置のディスプレイが挙げられる。スピーカの例としては、カーナビゲーション装置のスピーカが挙げられる。 The output unit 102 outputs information and data. Examples of the output unit 102 include a display unit that outputs an image representing information, and a speaker that outputs audio representing information. An example of a display unit is the display of a car navigation device. An example of a speaker is the speaker of a car navigation device.
通信部103は、情報やデータを送受信する。通信部103により受信された情報やデータは、演算装置105に送られる。 The communication unit 103 sends and receives information and data. The information and data received by the communication unit 103 is sent to the calculation device 105.
記憶部104は、情報やデータを記憶する。 The memory unit 104 stores information and data.
演算装置105は、車両10の各部を制御する。この例では、演算装置105は、センサ12により得られた各種の情報に応じてアクチュエータ11を制御する。演算装置105は、通信部103を経由して外部機器(システム1の構成要素など)と通信を行う。演算装置105は、入力部101に入力された情報およびデータ、通信部103を経由して受信した情報およびデータに基づいて、記憶部104に記憶された情報およびデータを適宜更新する。 The arithmetic unit 105 controls each part of the vehicle 10. In this example, the arithmetic unit 105 controls the actuator 11 in accordance with various information obtained by the sensor 12. The arithmetic unit 105 communicates with external devices (such as components of the system 1) via the communication unit 103. The arithmetic unit 105 updates the information and data stored in the memory unit 104 as appropriate, based on the information and data input to the input unit 101 and the information and data received via the communication unit 103.
演算装置105は、プロセッサ、メモリなどを有する。プロセッサの例としては、CPU(Central Processing Unit)、GPU(Graphics Processing Unit)などが挙げられる。メモリは、プロセッサを動作させるためのプログラム、プロセッサの処理結果を示す情報やデータなどを記憶する。メモリに記憶されたプログラムをプロセッサ(コンピュータ)が実行することで、演算装置105の各種の機能が実現される。 The arithmetic device 105 includes a processor, memory, etc. Examples of processors include a CPU (Central Processing Unit) and a GPU (Graphics Processing Unit). The memory stores programs for operating the processor, information and data indicating the processing results of the processor, etc. The various functions of the arithmetic device 105 are realized by the processor (computer) executing the programs stored in the memory.
なお、演算装置105に搭載されるプロセッサの数は、1つであってもよいし、複数のであってもよい。また、演算装置105に搭載されるプロセッサは、CPUおよびGPUのいずれか一方のみであってもよいし、CPUおよびGPUの両方であってもよい。この例では、演算装置105は、CPUおよびGPUの両方を有する。例えば、演算装置105は、1つまたは複数のECU(Electronic Control Unit)により構成される。 The number of processors installed in the arithmetic device 105 may be one or more. Furthermore, the processor installed in the arithmetic device 105 may be either a CPU or a GPU, or both a CPU and a GPU. In this example, the arithmetic device 105 has both a CPU and a GPU. For example, the arithmetic device 105 is configured by one or more ECUs (Electronic Control Units).
この例では、記憶部104は、車両基本情報D11と、演算装置情報D12と、車両状態情報D13と、機能利用情報D14と、車両利用情報D15と、位置管理情報D16と、稼働管理情報D17と、通信管理情報D18とを記憶する。 In this example, the memory unit 104 stores vehicle basic information D11, computing device information D12, vehicle status information D13, function usage information D14, vehicle usage information D15, location management information D16, operation management information D17, and communication management information D18.
〈車両基本情報〉
車両基本情報D11は、車両10に関する基本情報である。例えば、車両基本情報D11は、車両10に設定された車両ID、車両を所有するユーザに設定されたユーザID、車両の性能を示す車両性能情報などを含む。車両IDは、車両10を識別する車両識別情報の一例である。ユーザIDは、ユーザを識別するユーザ識別情報の一例である。
<Vehicle basic information>
The vehicle basic information D11 is basic information related to the vehicle 10. For example, the vehicle basic information D11 includes a vehicle ID set for the vehicle 10, a user ID set for the user who owns the vehicle, vehicle performance information indicating the performance of the vehicle, etc. The vehicle ID is an example of vehicle identification information that identifies the vehicle 10. The user ID is an example of user identification information that identifies the user.
〈演算装置情報〉
演算装置情報D12は、演算装置105に関する情報である。例えば、演算装置情報D12は、演算装置105に設定された演算装置ID、演算装置105の性能を示す演算装置性能情報などを含む。演算装置IDは、演算装置105を識別する演算装置識別情報の一例である。演算装置性能情報に示される演算装置105の性能には、演算装置105の計算能力(具体的には最大計算能力)、演算装置105におけるCPUとGPUの比率、演算装置105の通信性能、演算装置105の分散処理性能などが含まれる。なお、演算装置105の計算能力は、演算装置105が単位時間当たりに計算することができるデータ量である。
<Calculation device information>
The arithmetic unit information D12 is information related to the arithmetic unit 105. For example, the arithmetic unit information D12 includes a arithmetic unit ID set in the arithmetic unit 105, arithmetic unit performance information indicating the performance of the arithmetic unit 105, and the like. The arithmetic unit ID is an example of arithmetic unit identification information for identifying the arithmetic unit 105. The performance of the arithmetic unit 105 indicated in the arithmetic unit performance information includes the computational capacity (specifically, maximum computational capacity) of the arithmetic unit 105, the ratio of CPU to GPU in the arithmetic unit 105, the communication performance of the arithmetic unit 105, the distributed processing performance of the arithmetic unit 105, and the like. The computational capacity of the arithmetic unit 105 is the amount of data that the arithmetic unit 105 can calculate per unit time.
〈車両状態情報〉
車両状態情報D13は、車両10の状態を示す。例えば、車両状態情報D13は、車両位置情報、車両通信情報、車両電源情報、車両電池残量情報、車両充電情報などを含む。
<Vehicle status information>
The vehicle state information D13 indicates the state of the vehicle 10. For example, the vehicle state information D13 includes vehicle position information, vehicle communication information, vehicle power source information, vehicle battery remaining amount information, vehicle charging information, and the like.
車両位置情報は、車両10の位置(緯度および経度)を示す。例えば、車両位置情報は、GPS(Global Positioning System)により取得可能である。車両通信情報は、車両10の通信状態を示す。車両電源情報は、車両10の電源の状態を示す。例えば、車両電源情報は、イグニッション電源のオンオフ、アクセサリ電源のオンオフなどを示す。 Vehicle position information indicates the position (latitude and longitude) of the vehicle 10. For example, vehicle position information can be obtained using the Global Positioning System (GPS). Vehicle communication information indicates the communication status of the vehicle 10. Vehicle power supply information indicates the power supply status of the vehicle 10. For example, vehicle power supply information indicates whether the ignition power supply is on or off, whether the accessory power supply is on or off, etc.
車両電池残量情報は、車両10に搭載された電池(図示省略)の残量を示す。車両充電情報は、車両10の電池を充電可能な充電設備(図示省略)において車両10が充電中であるか否かを示す。 Vehicle battery remaining capacity information indicates the remaining capacity of the battery (not shown) installed in vehicle 10. Vehicle charging information indicates whether vehicle 10 is being charged at charging equipment (not shown) that can charge the battery of vehicle 10.
演算装置105は、車両10の状態を監視し、その監視の結果に基づいて車両状態情報D13を適宜(例えば定期的に)更新する。 The computing device 105 monitors the state of the vehicle 10 and updates the vehicle state information D13 appropriately (e.g., periodically) based on the results of that monitoring.
〈機能利用情報〉
機能利用情報D14は、車両10の各種機能の利用履歴(過去の利用状況)および利用予定(未来の利用状況)を示す。言い換えると、機能利用情報D14は、車両10の機能毎に、その機能がどの時刻に利用されていたのか(または利用される予定であるのか)を示す。例えば、機能利用情報D14は、車両10の機能毎に、その機能の利用の有無と時刻とを関連付けて示す。なお、車両10の機能の例としては、OTA(Over The Air)などが挙げられる。
<Function usage information>
The function usage information D14 indicates the usage history (past usage) and planned usage (future usage) of various functions of the vehicle 10. In other words, the function usage information D14 indicates, for each function of the vehicle 10, the time at which the function was used (or is planned to be used). For example, the function usage information D14 indicates, for each function of the vehicle 10, whether or not the function was used and the time in association with each other. Note that an example of a function of the vehicle 10 is OTA (Over The Air).
演算装置105は、機能利用情報D14を適宜更新する。例えば、演算装置105は、車両10の各種機能の利用履歴または利用予定に関する情報を入力すると、その情報に基づいて機能利用情報D14を更新する。 The computing device 105 updates the function usage information D14 as appropriate. For example, when the computing device 105 receives information regarding the usage history or planned usage of various functions of the vehicle 10, it updates the function usage information D14 based on that information.
〈車両利用情報〉
車両利用情報D15は、車両10の利用履歴(過去の利用状況)および利用予定(未来の利用状況)を示す。言い換えると、車両利用情報D15は、車両10がどの時刻に利用されていたのか(または利用される予定であるのか)を示す。例えば、車両利用情報D15は、車両10の利用の有無と時刻とを関連付けて示す。
<Vehicle Usage Information>
The vehicle usage information D15 indicates the usage history (past usage) and planned usage (future usage) of the vehicle 10. In other words, the vehicle usage information D15 indicates the time when the vehicle 10 was used (or is planned to be used). For example, the vehicle usage information D15 indicates whether the vehicle 10 was used and the time in association with each other.
なお、車両利用情報D15に示される車両10の利用状況は、グリッドコンピューティング処理のための利用を除く他の利用目的における利用状況である。このような他の利用目的の例としては、車両10の走行が挙げられる。例えば、車両10の走行目的での利用の有無は、車両10の電源(具体的にはイグニッション電源)のオンオフの履歴および予定に基づいて特定することが可能である。 The usage status of the vehicle 10 indicated in the vehicle usage information D15 is usage status for purposes other than use for grid computing processing. An example of such other purposes of use is driving the vehicle 10. For example, whether the vehicle 10 is being used for driving purposes can be determined based on the on/off history and schedule of the vehicle 10's power supply (specifically, the ignition power supply).
演算装置105は、車両利用情報D15を適宜更新する。例えば、演算装置105は、車両の利用履歴または利用予定に関する情報を入力すると、その情報に基づいて車両利用情報D15を更新する。 The computing device 105 updates the vehicle usage information D15 as appropriate. For example, when the computing device 105 receives information about the vehicle's usage history or planned usage, it updates the vehicle usage information D15 based on that information.
〈位置管理情報〉
位置管理情報D16は、車両10の過去の位置および未来の位置を示す。言い換えると、位置管理情報D16は、車両10がどの時刻にどの位置にいたのか(またはどの位置にいる予定であるのか)を示す。例えば、位置管理情報D16は、車両10の位置と時刻とを関連付けて示す。
<Location management information>
The location management information D16 indicates the past and future locations of the vehicle 10. In other words, the location management information D16 indicates where the vehicle 10 was (or where the vehicle 10 is scheduled to be) at what time. For example, the location management information D16 indicates the location of the vehicle 10 in association with the time.
なお、位置管理情報D16には、車両10のシーンを示すシーン情報が含まれてもよい。車両10のシーンの例としては、車両10が市街地を走行しているシーン、車両10が高速道路を走行しているシーン、車両10が停車しているシーンなどが挙げられる。例えば、演算装置105は、センサ12の出力に基づいて車両10の外部環境を認識し、その認識の結果に基づいて車両10のシーンを推定し、その推定された車両10のシーンを位置管理情報D16に登録する。位置管理情報D16は、「車両10の位置」と「車両10のシーン」と「時刻」とを関連付けて示してもよい。 The location management information D16 may also include scene information indicating the scene of the vehicle 10. Examples of scenes of the vehicle 10 include a scene in which the vehicle 10 is traveling in an urban area, a scene in which the vehicle 10 is traveling on a highway, and a scene in which the vehicle 10 is stopped. For example, the computing device 105 recognizes the external environment of the vehicle 10 based on the output of the sensor 12, estimates the scene of the vehicle 10 based on the results of this recognition, and registers the estimated scene of the vehicle 10 in the location management information D16. The location management information D16 may indicate the "location of the vehicle 10," the "scene of the vehicle 10," and the "time" in association with each other.
演算装置105は、位置管理情報D16を適宜(例えば定期的に)更新する。位置管理情報D16の更新については、後で詳しく説明する。 The computing device 105 updates the location management information D16 as appropriate (e.g., periodically). Updating the location management information D16 will be explained in detail later.
〈稼働管理情報〉
稼働管理情報D17は、車両10に搭載された演算装置105の稼働履歴(過去の計算能力の利用率)および稼働予定(未来の計算能力の利用率)を示す。言い換えると、稼働管理情報D17は、車両10の計算能力の利用率がどの時刻にどのくらいであったのか(またはどのくらいになる予定であるのか)を示す。例えば、稼働管理情報D17は、演算装置105の計算能力の利用率と時刻とを関連付けて示す。
<Operation management information>
The operation management information D17 indicates the operation history (past utilization rate of computing capacity) and operation schedule (future utilization rate of computing capacity) of the arithmetic device 105 mounted on the vehicle 10. In other words, the operation management information D17 indicates what the utilization rate of the computing capacity of the vehicle 10 was at what time (or what the utilization rate is expected to be). For example, the operation management information D17 indicates the utilization rate of the computing capacity of the arithmetic device 105 in association with time.
なお、稼働管理情報D17に示される車両10の演算装置105の稼働状況(計算能力の利用率)は、グリッドコンピューティング処理のための利用を除く他の利用目的における稼働状況である。 Note that the operating status (computing capacity utilization rate) of the vehicle 10's computing device 105 shown in the operation management information D17 is the operating status for purposes other than use for grid computing processing.
演算装置105は、稼働管理情報D17を適宜(例えば定期的に)更新する。稼働管理情報D17の更新については、後で詳しく説明する。 The computing device 105 updates the operation management information D17 as appropriate (e.g., periodically). Updating the operation management information D17 will be explained in detail later.
〈通信管理情報〉
通信管理情報D18は、車両10の通信履歴(過去の通信状態)および通信予定(未来の通信状態)を示す。言い換えると、通信管理情報D18は、車両10の通信状態がどの時刻にどのような状態であったのか(またはどのような状態となる予定であるのか)を示す。具体的には、通信管理情報D18は、車両10の通信相手となる機器毎に、その機器と車両10との間の通信状態(過去の通信状態および未来の通信状態)を示す。例えば、通信管理情報D18は、車両10の通信相手となる機器毎に、「その機器と車両10との間の通信状態」と「車両10の位置」と「時刻」とを関連付けて示す。
<Communication Management Information>
The communication management information D18 indicates the communication history (past communication states) and communication schedule (future communication states) of the vehicle 10. In other words, the communication management information D18 indicates what the communication state of the vehicle 10 was at what time (or what state it is expected to be in). Specifically, the communication management information D18 indicates, for each device with which the vehicle 10 communicates, the communication state (past communication states and future communication states) between the device and the vehicle 10. For example, for each device with which the vehicle 10 communicates, the communication management information D18 indicates the "communication state between the device and the vehicle 10," the "location of the vehicle 10," and the "time," in association with each other.
この例では、通信管理情報D18には、「車両10」と「車両ネットワーク間通信(V2N)を利用して車両10と通信する管理サーバ50」との間の通信状態と、「車両10(自車両)」と「車車間通信(V2V)を利用して車両10(自車両)と通信する他の車両10(他車両)」との間の通信状態とが含まれる。車両10と管理サーバ50との間の通信状態には、「車両10」と「車両10と管理サーバ50との通信を中継する中継器(図示省略)」との間の通信状態と、中継器と管理サーバ50との間に通信状態とが含まれる。中継器の例としては、通信網5の基地局、家や施設などに設けられた通信機器などが挙げられる。 In this example, the communication management information D18 includes the communication status between the "vehicle 10" and the "management server 50 that communicates with the vehicle 10 using vehicle-to-network (V2N) communication," and the communication status between the "vehicle 10 (own vehicle)" and the "other vehicle 10 (other vehicle) that communicates with the vehicle 10 (own vehicle) using vehicle-to-vehicle (V2V) communication." The communication status between the vehicle 10 and the management server 50 includes the communication status between the "vehicle 10" and a "repeater (not shown) that relays communication between the vehicle 10 and the management server 50," and the communication status between the repeater and the management server 50. Examples of repeaters include base stations of the communication network 5, and communication equipment installed in homes, facilities, etc.
なお、通信状態には、通信品質、通信帯域、通信可能時間などの情報が含まれる。通信品質に関する情報には、レイテンシ、スループット、パケットロス、エラーレート、通信の遮断回数などが含まれる。例えば、演算装置105は、車両10の通信相手となる機器との間においてテスト信号を送受信することで、これらの情報を取得する。通信品質に関する情報には、レイテンシ、スループット、パケットロス、エラーレート、通信の遮断回数の一部が含まれてもよいし、これらの全部が含まれてもよいし、これらと相関のある他の情報が含まれてもよい。 The communication status includes information such as communication quality, communication bandwidth, and available communication time. Information related to communication quality includes latency, throughput, packet loss, error rate, and number of communication interruptions. For example, the computing device 105 obtains this information by sending and receiving test signals between the device with which the vehicle 10 communicates. Information related to communication quality may include some or all of the latency, throughput, packet loss, error rate, and number of communication interruptions, or it may also include other information correlated with these.
また、通信状態には、「車両10」と「車両10の通信相手となる機器」との間における通信安定性の程度を示す通信安定度が含まれる。具体的には、演算装置105は、通信品質、通信帯域、通信可能時間の少なくとも1つに基づいて、通信安定度を導出する。言い換えると、通信品質、通信帯域、通信可能時間の少なくとも1つが変化すると、通信安定度が変化する。 The communication state also includes communication stability, which indicates the degree of communication stability between "vehicle 10" and "device with which vehicle 10 communicates." Specifically, the calculation device 105 derives communication stability based on at least one of communication quality, communication bandwidth, and available communication time. In other words, when at least one of communication quality, communication bandwidth, and available communication time changes, the communication stability changes.
この例では、演算装置105は、通信品質、通信帯域、通信可能時間に基づいて、通信安定度を導出する。通信品質が高くなるほど、通信安定度が高くなる。通信帯域が広くなるほど、通信安定度が高くなる。通信可能時間が長くなるほど、通信安定性が高くなる。 In this example, the calculation device 105 derives communication stability based on communication quality, communication bandwidth, and available communication time. The higher the communication quality, the higher the communication stability. The wider the communication bandwidth, the higher the communication stability. The longer the available communication time, the higher the communication stability.
演算装置105は、通信管理情報D18を適宜(例えば定期的に)更新する。通信管理情報D18の更新については、後で詳しく説明する。 The computing device 105 updates the communication management information D18 as appropriate (e.g., periodically). Updating the communication management information D18 will be explained in detail later.
〔ユーザ端末〕
ユーザ端末20は、ユーザに所有される。ユーザは、ユーザ端末20を操作して各種の機能を利用する。また、ユーザは、ユーザ端末20を持ち運ぶことができる。このようなユーザ端末20の例としては、スマートフォン、タブレット、ノート型パーソナルコンピュータなどが挙げられる。
[User terminal]
The user terminal 20 is owned by a user. The user operates the user terminal 20 to use various functions. The user can also carry the user terminal 20. Examples of such user terminals 20 include smartphones, tablets, and notebook personal computers.
図4に示すように、ユーザ端末20は、入力部201と、出力部202と、通信部203と、記憶部204と、制御部205とを備える。 As shown in FIG. 4, the user terminal 20 includes an input unit 201, an output unit 202, a communication unit 203, a memory unit 204, and a control unit 205.
入力部201は、情報やデータを入力する。入力部201の例としては、操作されることで操作に応じた情報を入力する操作部、情報を示す画像を入力するカメラ、情報を示す音声を入力するマイクロフォンなどが挙げられる。操作部の例としては、操作ボタン、タッチセンサなどが挙げられる。入力部101に入力された情報は、演算装置105に送られる。 The input unit 201 inputs information and data. Examples of the input unit 201 include an operation unit that is operated to input information corresponding to the operation, a camera that inputs an image representing information, and a microphone that inputs audio representing information. Examples of the operation unit include an operation button and a touch sensor. The information input to the input unit 101 is sent to the calculation device 105.
出力部202は、情報やデータを出力する。出力部202の例としては、情報を示す画像を出力する表示部、情報を示す音声を出力するスピーカなどが挙げられる。 The output unit 202 outputs information and data. Examples of the output unit 202 include a display unit that outputs an image representing information, and a speaker that outputs audio representing information.
通信部203は、情報やデータを送受信する。通信部303により受信された情報やデータは、制御部205に送られる。 The communication unit 203 sends and receives information and data. Information and data received by the communication unit 303 is sent to the control unit 205.
記憶部204は、情報やデータを記憶する。 The memory unit 204 stores information and data.
制御部205は、ユーザ端末20の各部を制御する。制御部205は、通信部203を経由して外部機器(システム1の構成要素など)と通信を行う。制御部205は、入力部201に入力された情報およびデータ、通信部203を経由して受信した情報およびデータに基づいて、記憶部204に記憶された情報およびデータを適宜更新する。 The control unit 205 controls each unit of the user terminal 20. The control unit 205 communicates with external devices (such as components of system 1) via the communication unit 203. The control unit 205 updates the information and data stored in the memory unit 204 as appropriate based on the information and data input to the input unit 201 and the information and data received via the communication unit 203.
制御部205は、プロセッサ、メモリなどを有する。メモリは、プロセッサを動作させるためのプログラム、プロセッサの処理結果を示す情報やデータなどを記憶する。メモリに記憶されたプログラムをプロセッサ(コンピュータ)が実行することで、制御部205の各種の機能が実現される。 The control unit 205 includes a processor, memory, etc. The memory stores programs for operating the processor, information and data indicating the processing results of the processor, etc. The various functions of the control unit 205 are realized by the processor (computer) executing the programs stored in the memory.
この例では、記憶部204は、端末情報D21と、端末状態情報D22と、スケジュール情報D23とを記憶する。 In this example, the storage unit 204 stores terminal information D21, terminal status information D22, and schedule information D23.
〈端末情報〉
端末情報D21は、ユーザ端末20に関する情報である。例えば、端末情報D21は、ユーザ端末20に設定されたユーザ端末ID、ユーザ端末20の性能を示すユーザ端末性能情報などを含む。ユーザ端末IDは、ユーザ端末20を識別するユーザ端末識別情報の一例である。
<Device Information>
The terminal information D21 is information related to the user terminal 20. For example, the terminal information D21 includes a user terminal ID set in the user terminal 20, user terminal performance information indicating the performance of the user terminal 20, etc. The user terminal ID is an example of user terminal identification information that identifies the user terminal 20.
〈端末状態情報〉
端末状態情報D22は、ユーザ端末20の状態を示す情報である。端末状態情報D22は、ユーザ端末20の位置を示すユーザ端末位置情報、ユーザ端末20の通信状態を示すユーザ端末通信状態情報などを含む。
<Device status information>
The terminal status information D22 is information indicating the status of the user terminal 20. The terminal status information D22 includes user terminal position information indicating the position of the user terminal 20, user terminal communication status information indicating the communication status of the user terminal 20, and the like.
制御部205は、ユーザ端末20の状態を監視し、その監視の結果に基づいて端末状態情報D22を適宜(例えば定期的に)更新する。 The control unit 205 monitors the status of the user terminal 20 and updates the terminal status information D22 appropriately (e.g., periodically) based on the results of this monitoring.
〈スケジュール情報〉
スケジュール情報D23は、ユーザ端末20を所有するユーザの行動履歴(過去の行動)および行動予定(未来の行動)を示す。言い換えると、スケジュール情報D23は、ユーザがどの時刻にどの位置にいたのかを示す。例えば、スケジュール情報D23は、ユーザの位置と時刻とを関連付けて示す。なお、スケジュール情報D23は、ユーザ端末20に搭載されたスケジュール機能により取得可能である。具体的には、ユーザがスケジュール機能を利用して自身の行動履歴および行動予定をユーザ端末20に入力することで、そのユーザの行動履歴および行動予定を示すスケジュール情報D23が得られる。
<Schedule Information>
The schedule information D23 indicates the behavior history (past behavior) and behavior schedule (future behavior) of the user who owns the user terminal 20. In other words, the schedule information D23 indicates the location of the user at what time. For example, the schedule information D23 indicates the user's location in association with the time. The schedule information D23 can be acquired by a schedule function installed in the user terminal 20. Specifically, the user uses the schedule function to input their own behavior history and behavior schedule into the user terminal 20, thereby obtaining the schedule information D23 indicating the user's behavior history and behavior schedule.
また、スケジュール情報D23には、ユーザの行動が「車両10の利用を伴う行動」であることを示す情報が含まれてもよい。例えば、スケジュール情報D23は、「ユーザの位置」と「車両10の利用の有無」と「時刻」とを関連付けて示してもよい。 The schedule information D23 may also include information indicating that the user's activity is "activity involving the use of the vehicle 10." For example, the schedule information D23 may indicate the user's location, whether or not the vehicle 10 is being used, and the time of day in association with each other.
制御部205は、記憶部204に記憶されたスケジュール情報D23を適宜更新する。例えば、制御部205は、ユーザの行動に関する情報が入力部101に入力されると、その情報に基づいてスケジュール情報D23を更新する。 The control unit 205 updates the schedule information D23 stored in the memory unit 204 as appropriate. For example, when information about the user's behavior is input to the input unit 101, the control unit 205 updates the schedule information D23 based on that information.
〔クライアントサーバ〕
クライアントサーバ30は、クライアントに所有される。クライアントは、ジョブデータの計算を依頼する。このようなクライアントの例としては、企業、研究機関、教育機関などが挙げられる。
[Client Server]
The client server 30 is owned by a client, who requests the calculation of job data. Examples of such clients include companies, research institutes, and educational institutions.
図5に示すように、クライアントサーバ30は、入力部301と、出力部302と、通信部303と、記憶部304と、制御部305とを備える。 As shown in FIG. 5, the client server 30 includes an input unit 301, an output unit 302, a communication unit 303, a memory unit 304, and a control unit 305.
入力部301は、情報やデータを入力する。入力部301の例としては、操作されることで操作に応じた情報を入力する操作部、情報を示す画像を入力するカメラ、情報を示す音声を入力するマイクロフォンなどが挙げられる。操作部の例としては、操作ボタン、タッチセンサ、キーボード、マウスなどが挙げられる。入力部301に入力された情報やデータは、制御部305に送られる。 The input unit 301 inputs information and data. Examples of the input unit 301 include an operation unit that is operated to input information corresponding to the operation, a camera that inputs an image representing information, and a microphone that inputs audio representing information. Examples of the operation unit include an operation button, a touch sensor, a keyboard, and a mouse. The information and data input to the input unit 301 is sent to the control unit 305.
出力部302は、情報やデータを出力する。出力部302の例としては、情報を示す画像を出力する表示部、情報を示す音声を出力するスピーカなどが挙げられる。 The output unit 302 outputs information and data. Examples of the output unit 302 include a display unit that outputs an image representing information, and a speaker that outputs audio representing information.
通信部303は、情報やデータを送受信する。通信部303により受信された情報やデータは、制御部305に送られる。 The communication unit 303 sends and receives information and data. Information and data received by the communication unit 303 is sent to the control unit 305.
記憶部304は、情報やデータを記憶する。 The memory unit 304 stores information and data.
制御部305は、クライアントサーバ30の各部を制御する。制御部305は、通信部303を経由して外部機器(システム1の構成要素など)と通信を行う。制御部305は、入力部301に入力された情報およびデータ、通信部303を経由して受信した情報およびデータに基づいて、記憶部304に記憶された情報およびデータを適宜更新する。 The control unit 305 controls each unit of the client server 30. The control unit 305 communicates with external devices (such as components of system 1) via the communication unit 303. The control unit 305 updates the information and data stored in the memory unit 304 as appropriate, based on the information and data input to the input unit 301 and the information and data received via the communication unit 303.
制御部305は、プロセッサ、メモリなどを有する。メモリは、プロセッサを動作させるためのプログラム、プロセッサの処理結果を示す情報やデータなどを記憶する。メモリに記憶されたプログラムをプロセッサ(コンピュータ)が実行することで、制御部305の各種の機能が実現される。 The control unit 305 includes a processor, memory, etc. The memory stores programs for operating the processor, information and data indicating the processing results of the processor, etc. The various functions of the control unit 305 are realized by the processor (computer) executing the programs stored in the memory.
この例では、記憶部304は、クライアント情報D31と、ジョブデータD1とを記憶する。 In this example, the storage unit 304 stores client information D31 and job data D1.
〈クライアント情報〉
クライアント情報D31は、クライアントに関する情報である。クライアント情報D31は、クライアントに設定されたクライアントID、クライアントに所有されるクライアントサーバ30に設定されたクライアントサーバID、担当者名、住所、電話番号などを含む。クライアントIDは、クライアントを識別するクライアント識別情報の一例である。クライアントサーバIDは、クライアントサーバ30を識別するクライアントサーバ識別情報の一例である。
<Client Information>
The client information D31 is information about the client. The client information D31 includes a client ID set for the client, a client server ID set for the client server 30 owned by the client, a person in charge's name, address, telephone number, etc. The client ID is an example of client identification information that identifies the client. The client server ID is an example of client server identification information that identifies the client server 30.
〈ジョブデータ〉
ジョブデータD1は、ジョブに対応するデータであり、ジョブの実施のために処理されるデータである。
<Job Data>
The job data D1 is data corresponding to a job and is processed to execute the job.
なお、ジョブデータD1は、計算タイプにより分類可能である。計算タイプの例としては、CPU系の計算タイプ、GPU系の計算タイプなどが挙げられる。CPU系の計算タイプのジョブデータD1では、シミュレーション計算など、条件分岐の多い複雑な計算が要求される傾向にある。GPU系の計算タイプのジョブデータD1では、画像処理や機械学習など、膨大な量の単純計算が要求される傾向にある。 Job data D1 can be classified by calculation type. Examples of calculation types include CPU-based calculation types and GPU-based calculation types. Job data D1 of the CPU-based calculation type tends to require complex calculations with many conditional branches, such as simulation calculations. Job data D1 of the GPU-based calculation type tends to require a huge amount of simple calculations, such as image processing and machine learning.
また、ジョブデータD1は、処理条件により分類可能である。処理条件の例としては、常時通信が要求される処理条件、常時通信が要求されない処理条件などが挙げられる。常時通信が要求される処理条件のジョブデータD1では、グリッドコンピューティング処理において車両10が常に通信可能であることが要求される。常時通信が要求されない処理条件のジョブデータD1では、グリッドコンピューティング処理において車両10が常に通信可能であることが要求されない。 Job data D1 can also be classified by processing conditions. Examples of processing conditions include processing conditions that require constant communication and processing conditions that do not require constant communication. Job data D1 with processing conditions that require constant communication requires that the vehicle 10 be able to communicate at all times during grid computing processing. Job data D1 with processing conditions that do not require constant communication does not require that the vehicle 10 be able to communicate at all times during grid computing processing.
〈ジョブ情報〉
なお、記憶部304には、ジョブに関するジョブ情報が記憶されてもよい。ジョブ情報は、ジョブの名称を示すジョブ名称情報、ジョブの内容を説明するジョブ内容情報、ジョブに対応するジョブデータに関するジョブデータ情報、ジョブの納期を示すジョブ納期情報などを含む。ジョブデータ情報は、ジョブデータの計算タイプ、処理条件、必要計算能力などを示す。
<Job Information>
The storage unit 304 may store job information related to a job. The job information includes job name information indicating the name of the job, job content information explaining the content of the job, job data information related to the job data corresponding to the job, job delivery date information indicating the delivery date of the job, etc. The job data information indicates the calculation type, processing conditions, required calculation capacity, etc. of the job data.
〔管理サーバ〕
管理サーバ50は、グリッドコンピューティングが構成されるシステム1の運営を管理する。管理サーバ50は、システム1を運営する事業者に所有される。なお、管理サーバ50は、グリッドコンピューティング処理を管理する管理装置の一例である。
[Management Server]
The management server 50 manages the operation of the system 1 in which grid computing is configured. The management server 50 is owned by the business operator that operates the system 1. The management server 50 is an example of a management device that manages grid computing processing.
図6に示すように、管理サーバ50は、入力部501と、出力部502と、通信部503と、記憶部504と、制御部505とを備える。管理サーバ50の入力部501、出力部502、通信部503、記憶部504、制御部505の構成は、クライアントサーバ30の入力部301、出力部302、通信部303、記憶部304、制御部305の構成と同様である。 As shown in FIG. 6, the management server 50 includes an input unit 501, an output unit 502, a communication unit 503, a memory unit 504, and a control unit 505. The configurations of the input unit 501, output unit 502, communication unit 503, memory unit 504, and control unit 505 of the management server 50 are the same as the configurations of the input unit 301, output unit 302, communication unit 303, memory unit 304, and control unit 305 of the client server 30.
この例では、記憶部504は、ユーザテーブルD51と、車両テーブルD52と、クライアントテーブルD53と、ジョブテーブルD54と、位置予測テーブルD55と、能力予測テーブルD56と、通信予測テーブルD57と、マッチングテーブルD58と、ジョブデータD1と、計算結果データD2とを記憶する。 In this example, the storage unit 504 stores a user table D51, a vehicle table D52, a client table D53, a job table D54, a location prediction table D55, a capacity prediction table D56, a communication prediction table D57, a matching table D58, job data D1, and calculation result data D2.
〈ユーザテーブル〉
ユーザテーブルD51は、ユーザを管理するためのテーブルである。ユーザテーブルD51には、ユーザ毎に、そのユーザに設定されたユーザID、そのユーザに所有される車両10に設定された車両ID、そのユーザに所有される演算装置105に設定された演算装置ID、そのユーザに所有されるユーザ端末20に設定されたユーザ端末IDなどが登録される。
<User table>
The user table D51 is a table for managing users. For each user, the user table D51 registers a user ID set for the user, a vehicle ID set for the vehicle 10 owned by the user, a computing device ID set for the computing device 105 owned by the user, a user terminal ID set for the user terminal 20 owned by the user, and the like.
制御部505は、ユーザテーブルD51を適宜更新する。 The control unit 505 updates the user table D51 as appropriate.
例えば、新規のユーザがシステム1に加入すると、制御部505は、その新規のユーザに関連する情報をユーザテーブルD51に登録することで、ユーザテーブルD51を更新する。具体的には、制御部505は、新規のユーザに対してユーザIDを新たに設定し、新規のユーザに設定された「ユーザID」と、そのユーザに所有される車両10に設定された「車両ID」と、その車両10に搭載された演算装置105に設定された「演算装置ID」と、新規のユーザに所有されるユーザ端末20に設定された「ユーザ端末ID」とを関連付けて、ユーザテーブルD51に登録する。 For example, when a new user joins system 1, the control unit 505 updates the user table D51 by registering information related to the new user in the user table D51. Specifically, the control unit 505 assigns a new user ID to the new user, associates the "user ID" assigned to the new user with the "vehicle ID" assigned to the vehicle 10 owned by the user, the "computing device ID" assigned to the computing device 105 installed in the vehicle 10, and the "user terminal ID" assigned to the user terminal 20 owned by the new user, and registers them in the user table D51.
なお、新規のユーザに所有される車両10と管理サーバ50との通信により、新規のユーザに関連する「車両ID」と「演算装置ID」とを得ることが可能である。また、新規のユーザに所有されるユーザ端末20と管理サーバ50との通信により、新規のユーザに関連する「ユーザ端末ID」を得ることが可能である。 In addition, through communication between the vehicle 10 owned by the new user and the management server 50, it is possible to obtain a "vehicle ID" and a "computing device ID" associated with the new user. Also, through communication between the user terminal 20 owned by the new user and the management server 50, it is possible to obtain a "user terminal ID" associated with the new user.
〈車両テーブル〉
車両テーブルD52は、車両10を管理するためのテーブルである。この例では、車両テーブルD52には、車両10毎に、その車両10に関する車両基本情報D11、演算装置情報D12、車両状態情報D13、機能利用情報D14、車両利用情報D15、位置管理情報D16、稼働管理情報D17、通信管理情報D18などが登録される。
<Vehicle Table>
The vehicle table D52 is a table for managing the vehicles 10. In this example, the vehicle table D52 registers, for each vehicle 10, basic vehicle information D11, processing unit information D12, vehicle state information D13, function usage information D14, vehicle usage information D15, location management information D16, operation management information D17, communication management information D18, and the like related to the vehicle 10.
制御部505は、車両テーブルD52を適宜更新する。 The control unit 505 updates the vehicle table D52 as appropriate.
例えば、新規の車両10がシステム1に加入すると、制御部505は、その新規の車両10に関連する情報を車両テーブルD52に登録することで、車両テーブルD52を更新する。具体的には、制御部505は、新規の車両10に関する車両基本情報D11、演算装置情報D12、車両状態情報D13、機能利用情報D14、車両利用情報D15、位置管理情報D16、稼働管理情報D17、通信管理情報D18を関連付けて、車両テーブルD52に登録する。 For example, when a new vehicle 10 joins the system 1, the control unit 505 updates the vehicle table D52 by registering information related to the new vehicle 10 in the vehicle table D52. Specifically, the control unit 505 associates and registers the vehicle basic information D11, computing device information D12, vehicle status information D13, function usage information D14, vehicle usage information D15, location management information D16, operation management information D17, and communication management information D18 related to the new vehicle 10 in the vehicle table D52.
なお、新規の車両10と管理サーバ50との通信により、新規の車両10に関連する情報(この例では、車両基本情報D11、演算装置情報D12、車両状態情報D13、機能利用情報D14、車両利用情報D15、位置管理情報D16、稼働管理情報D17、通信管理情報D18)を得ることが可能である。また、ユーザテーブルD51を参照することにより、新規の車両10に関連する「ユーザID」を得ることが可能である。 In addition, through communication between the new vehicle 10 and the management server 50, it is possible to obtain information related to the new vehicle 10 (in this example, vehicle basic information D11, computing device information D12, vehicle status information D13, function usage information D14, vehicle usage information D15, location management information D16, operation management information D17, and communication management information D18). Furthermore, by referencing the user table D51, it is possible to obtain a "user ID" related to the new vehicle 10.
また、制御部505は、車両10毎に、その車両10と適宜(例えば定期的に)通信して車両10に関する情報(具体的には、車両状態情報D13、機能利用情報D14、車両利用情報D15、位置管理情報D16、稼働管理情報D17、通信管理情報D18)を取得し、その取得された情報に基づいて車両テーブルD52を更新する。 In addition, the control unit 505 communicates with each vehicle 10 as appropriate (e.g., periodically) to acquire information about the vehicle 10 (specifically, vehicle status information D13, function usage information D14, vehicle usage information D15, location management information D16, operation management information D17, and communication management information D18), and updates the vehicle table D52 based on the acquired information.
〈クライアントテーブル〉
クライアントテーブルD53は、クライアントを管理するためのテーブルである。クライアントテーブルD53には、クライアント毎に、そのクライアントに設定されたクライアントID、クライアントに所有されるクライアントサーバ30に設定されたクライアントサーバID、そのクライアントの担当者名、住所、電話番号などが登録される。
<Client Table>
The client table D53 is a table for managing clients. For each client, the client table D53 registers a client ID set for that client, a client server ID set for the client server 30 owned by the client, the name, address, and telephone number of the person in charge of that client.
制御部505は、クライアントテーブルD53を適宜更新する。 The control unit 505 updates the client table D53 as appropriate.
例えば、新規のクライアントがシステム1に加入すると、制御部505は、その新規のクライアントに関連する情報をクライアントテーブルD53に登録することで、クライアントテーブルD53を更新する。具体的には、制御部505は、新規のクライアントに対してクライアントIDを新たに設定し、新規のクライアントに設定された「クライアントID」と、新規のクライアントに所有されるクライアントサーバ30に設定された「クライアントサーバID」と、新規のクライアントの「担当者」と「住所」と「電話番号」とを関連付けて、クライアントテーブルD53に登録する。 For example, when a new client joins system 1, the control unit 505 updates the client table D53 by registering information related to the new client in the client table D53. Specifically, the control unit 505 sets a new client ID for the new client, associates the "client ID" set for the new client with the "client server ID" set for the client server 30 owned by the new client, and the new client's "contact person," "address," and "telephone number," and registers them in the client table D53.
なお、クライアントサーバ30と管理サーバ50との通信により、新規のクライアントに関する「クライアントサーバID」と「担当者」と「住所」と「電話番号」とを得ることが可能である。 In addition, through communication between the client server 30 and the management server 50, it is possible to obtain the "client server ID," "contact person," "address," and "telephone number" for a new client.
〈ジョブテーブル〉
ジョブテーブルD54は、クライアントから依頼されたジョブを管理するためのテーブルである。ジョブテーブルD54には、ジョブ毎に、そのジョブに設定された受付番号、そのジョブを依頼したクライアントに設定されたクライアントID、そのジョブの名称および内容などが登録される。また、ジョブテーブルD54には、ジョブ毎に、そのジョブに対応するジョブデータの計算タイプおよび処理条件、そのジョブデータの計算に必要となる計算能力である必要計算能力、そのジョブに設定された納期などが登録される。
<Job Table>
The job table D54 is a table for managing jobs requested by clients. For each job, the job table D54 registers the reception number set for that job, the client ID set for the client that requested the job, the name and content of the job, etc. The job table D54 also registers for each job the calculation type and processing conditions of the job data corresponding to that job, the required calculation capacity that is the calculation capacity required to calculate the job data, the delivery date set for that job, etc.
〈位置予測テーブル〉
位置予測テーブルD55は、車両10の位置の予測結果を管理するためのテーブルである。この例では、位置予測テーブルD55には、車両10毎に、その車両10に設定された車両ID、その車両10に関する位置予測情報D5などが登録される。位置予測情報D5は、車両10の位置の時間的変化の予測結果を示す。例えば、位置予測情報D5は、車両10の位置の予測値と時刻とを関連付けて示す。なお、車両10の位置の時間的変化を予測するための処理(位置予測処理)については、後で詳しく説明する。
<Position Prediction Table>
The position prediction table D55 is a table for managing the predicted results of the position of the vehicle 10. In this example, the position prediction table D55 registers, for each vehicle 10, the vehicle ID set for that vehicle 10, position prediction information D5 related to that vehicle 10, and the like. The position prediction information D5 indicates the predicted results of the change in the position of the vehicle 10 over time. For example, the position prediction information D5 indicates the predicted value of the position of the vehicle 10 in association with the time. The process for predicting the change in the position of the vehicle 10 over time (position prediction process) will be described in detail later.
〈能力予測テーブル〉
能力予測テーブルD56は、車両10の演算装置105の計算能力(グリッドコンピューティング処理に利用可能な計算能力)の予測結果を管理するためのテーブルである。この例では、能力予測テーブルD56には、車両10毎に、その車両10に設定された車両ID、その車両10に関する能力予測情報D6などが登録される。能力予測情報D6は、車両10の演算装置105のグリッドコンピューティング処理において利用可能な計算能力の時間的変化の予測結果を示す。例えば、能力予測情報D6は、車両10の演算装置105の利用可能な計算能力の予測値と時刻とを関連付けて示す。なお、車両10の演算装置105のグリッドコンピューティング処理において利用可能な計算能力の時間的変化を予測するための処理(能力予測処理)については、後で詳しく説明する。
Ability Prediction Table
The capacity prediction table D56 is a table for managing the predicted results of the computational capacity (computing capacity available for grid computing processing) of the computing device 105 of the vehicle 10. In this example, the capacity prediction table D56 registers, for each vehicle 10, the vehicle ID set for that vehicle 10, capacity prediction information D6 related to that vehicle 10, and the like. The capacity prediction information D6 indicates the predicted results of a change over time in the computational capacity available for grid computing processing of the computing device 105 of the vehicle 10. For example, the capacity prediction information D6 indicates the predicted value of the computational capacity available for the computing device 105 of the vehicle 10 in association with the time. The process for predicting a change over time in the computational capacity available for grid computing processing of the computing device 105 of the vehicle 10 (capacity prediction process) will be described in detail later.
〈通信予測テーブル〉
通信予測テーブルD57は、車両10の通信状態の予測結果を管理するためのテーブルである。この例では、通信予測テーブルD57には、車両10毎に、その車両10に設定された車両ID、その車両10に関する通信予測情報D7などが登録される。通信予測情報D7は、車両10の通信状態の時間的変化の予測結果を示す。例えば、通信予測テーブルD57は、車両10の通信状態の予測値と時刻とを関連付けて示す。なお、車両10の通信状態の時間的変化を予測するための処理(通信予測処理)については、後で詳しく説明する。
<Communication Prediction Table>
The communication prediction table D57 is a table for managing the predicted results of the communication state of the vehicle 10. In this example, the communication prediction table D57 registers, for each vehicle 10, the vehicle ID set for that vehicle 10, communication prediction information D7 related to that vehicle 10, and the like. The communication prediction information D7 indicates the predicted results of the temporal change in the communication state of the vehicle 10. For example, the communication prediction table D57 indicates the predicted value of the communication state of the vehicle 10 in association with the time. The process for predicting the temporal change in the communication state of the vehicle 10 (communication prediction process) will be described in detail later.
〈マッチングテーブル〉
マッチングテーブルD58は、後述するマッチング処理の結果を管理するためのテーブルである。マッチングテーブルD58には、ジョブ毎に、そのジョブに設定された受付番号、そのジョブに対応するジョブデータ、マッチング処理によりそのジョブデータに対して割り当てられた車両10に設定された車両IDなどが登録される。
Matching Table
The matching table D58 is a table for managing the results of the matching process described later. For each job, the matching table D58 registers the reception number set for the job, the job data corresponding to the job, the vehicle ID set for the vehicle 10 assigned to the job data by the matching process, and the like.
〈ジョブデータ〉
記憶部504に記憶されるジョブデータD1は、後述するジョブ受付処理により受け付けられたジョブデータD1である。
<Job Data>
The job data D1 stored in the storage unit 504 is job data D1 accepted by a job acceptance process, which will be described later.
〈計算結果データ〉
記憶部504に記憶される計算結果データD2は、後述するグリッドコンピューティング処理によるジョブデータD1の計算結果を示す。
<Calculation result data>
The calculation result data D2 stored in the storage unit 504 indicates the calculation result of the job data D1 by the grid computing process described later.
〔位置管理情報の更新〕
次に、位置管理情報D16の更新について説明する。演算装置105は、車両10の位置を監視し、その監視の結果に基づいて、位置管理情報D16に示された車両10の過去の位置を更新する。また、演算装置105は、車両10の位置の推定に利用可能な情報を取得すると、その情報に基づいて、位置管理情報D16に示された車両10の位置を更新する。
[Updating location management information]
Next, the updating of the position management information D16 will be described. The calculation device 105 monitors the position of the vehicle 10, and updates the past positions of the vehicle 10 indicated in the position management information D16 based on the results of the monitoring. Furthermore, when the calculation device 105 acquires information that can be used to estimate the position of the vehicle 10, it updates the position of the vehicle 10 indicated in the position management information D16 based on that information.
車両10の位置の推定に利用可能な情報の例としては、車両10の走行履歴および走行予定を示すカーナビゲーション情報、車両10の記憶部104に記憶された車両利用情報D15、ユーザ端末20の記憶部204に記憶されたスケジュール情報D23などが挙げられる。 Examples of information that can be used to estimate the location of vehicle 10 include car navigation information showing the driving history and driving schedule of vehicle 10, vehicle usage information D15 stored in the memory unit 104 of vehicle 10, and schedule information D23 stored in the memory unit 204 of user terminal 20.
〈カーナビゲーション情報に基づく位置管理情報の更新〉
この例では、演算装置105は、入力部101に入力されたカーナビゲーション情報に示された車両10の走行履歴および走行予定に基づいて、車両10の位置(過去の位置および未来の位置)を推定する。そして、演算装置105は、その推定された車両10の位置に基づいて、記憶部104に記憶された位置管理情報D16を更新する。
<Updating location management information based on car navigation information>
In this example, the arithmetic device 105 estimates the position (past and future positions) of the vehicle 10 based on the driving history and driving schedule of the vehicle 10 indicated in the car navigation information input to the input unit 101. Then, the arithmetic device 105 updates the position management information D16 stored in the storage unit 104 based on the estimated position of the vehicle 10.
〈車両利用情報に基づく位置管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された車両利用情報D15を取得する。演算装置105は、車両利用情報D15に示された車両10の利用状況(利用履歴および利用予定)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、車両10の位置(過去の位置および未来の位置)を推定する。そして、演算装置105は、その推定された車両10の位置に基づいて、記憶部104に記憶された位置管理情報D16を更新する。
Updating location management information based on vehicle usage information
Furthermore, in this example, the calculation device 105 accesses the storage unit 104 and acquires vehicle usage information D15 stored in the storage unit 104. The calculation device 105 estimates the driving status (driving history and driving schedule) of the vehicle 10 based on the usage status (usage history and usage schedule) of the vehicle 10 indicated in the vehicle usage information D15, and estimates the position (past position and future position) of the vehicle 10 based on the estimation result. Then, the calculation device 105 updates the position management information D16 stored in the storage unit 104 based on the estimated position of the vehicle 10.
〈スケジュール情報に基づく位置管理情報の更新〉
また、この例では、演算装置105は、その演算装置105が搭載された車両10を所有するユーザに所有されるユーザ端末20に対し、そのユーザ端末20の記憶部204に記憶されたスケジュール情報D23へのアクセスを要求する。ユーザ端末20の制御部205は、その要求に応答してスケジュール情報D23へのアクセスを許可する。
Updating location management information based on schedule information
In this example, the arithmetic device 105 requests the user terminal 20 owned by the user who owns the vehicle 10 equipped with the arithmetic device 105 to access the schedule information D23 stored in the storage unit 204 of the user terminal 20. In response to the request, the control unit 205 of the user terminal 20 permits access to the schedule information D23.
次に、演算装置105は、ユーザ端末20の記憶部204にアクセスし、記憶部204に記憶されたスケジュール情報D23に示されたユーザの行動(過去の行動および未来の行動)の中から、車両10の利用を伴う行動を検出する。例えば、演算装置105は、スケジュール情報D23に示されたユーザの行動のうち過去の行動である行動履歴の中から、そのユーザが車両10を利用していた行動履歴を検出する。また、演算装置105は、スケジュール情報D23に示されたユーザの行動のうち未来の行動である行動予定の中から、そのユーザが車両10を利用する予定がある行動予定を検出する。 Next, the calculation device 105 accesses the memory unit 204 of the user terminal 20 and detects actions involving the use of the vehicle 10 from among the user actions (past actions and future actions) shown in the schedule information D23 stored in the memory unit 204. For example, the calculation device 105 detects an action history in which the user used the vehicle 10 from among the action history, which is past actions, of the user actions shown in the schedule information D23. The calculation device 105 also detects an action plan in which the user plans to use the vehicle 10 from among the action plans, which are future actions, of the user actions shown in the schedule information D23.
次に、演算装置105は、その検出されたユーザの行動(行動履歴および行動予定)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、車両10の位置(過去の位置および未来の位置)を推定する。そして、演算装置105は、その推定された車両10の位置に基づいて、記憶部104に記憶された位置管理情報D16を更新する。 Then, the calculation device 105 estimates the driving conditions (driving history and driving schedule) of the vehicle 10 based on the detected user behavior (behavior history and behavior schedule), and estimates the position (past position and future position) of the vehicle 10 based on the result of this estimation. The calculation device 105 then updates the position management information D16 stored in the memory unit 104 based on the estimated position of the vehicle 10.
〔稼働管理情報の更新〕
次に、稼働管理情報D17の更新について説明する。演算装置105は、その演算装置105の稼働率(計算能力の利用率)を監視し、その監視の結果に基づいて、稼働管理情報D17に示された演算装置105の過去の稼働率を更新する。また、演算装置105は、演算装置105の稼働率の推定に利用可能な情報を取得すると、その情報に基づいて、稼働管理情報D17に示された演算装置105の稼働率を更新する。
[Updating operation management information]
Next, the updating of the operation management information D17 will be described. The computing device 105 monitors its operation rate (computing capacity utilization rate) and updates the past operation rate of the computing device 105 indicated in the operation management information D17 based on the monitoring results. Furthermore, when the computing device 105 acquires information that can be used to estimate the operation rate of the computing device 105, it updates the operation rate of the computing device 105 indicated in the operation management information D17 based on that information.
演算装置105の稼働率の推定に利用可能な情報の例としては、車両10の走行履歴および走行予定を示すカーナビゲーション情報、車両10の記憶部104に記憶された機能利用情報D14、車両利用情報D15、位置管理情報D16、ユーザ端末20の記憶部204に記憶されたスケジュール情報D23などが挙げられる。 Examples of information that can be used to estimate the operating rate of the computing device 105 include car navigation information indicating the driving history and driving schedule of the vehicle 10, function usage information D14 stored in the memory unit 104 of the vehicle 10, vehicle usage information D15, location management information D16, and schedule information D23 stored in the memory unit 204 of the user terminal 20.
〈カーナビゲーション情報に基づく稼働管理情報の更新〉
この例では、演算装置105は、入力部101に入力されたカーナビゲーション情報に示された車両10の走行履歴および走行予定に基づいて、車両10の稼働率(過去の稼働率および未来の稼働率)を推定する。例えば、「車両10が停車していた期間における演算装置105の稼働率」および「車両10が停車する予定である期間における演算装置105の稼働率」は、ゼロと推定される。そして、演算装置105は、その推定された演算装置105の稼働率に基づいて、記憶部104に記憶された稼働管理情報D17を更新する。
<Updating operation management information based on car navigation information>
In this example, the arithmetic device 105 estimates the availability of the vehicle 10 (past availability and future availability) based on the driving history and driving schedule of the vehicle 10 indicated in the car navigation information input to the input unit 101. For example, the "availability of the arithmetic device 105 during the period when the vehicle 10 was stopped" and the "availability of the arithmetic device 105 during the period when the vehicle 10 is scheduled to be stopped" are estimated to be zero. Then, the arithmetic device 105 updates the operation management information D17 stored in the storage unit 104 based on the estimated availability of the arithmetic device 105.
〈機能利用情報に基づく稼働管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された機能利用情報D14を取得する。演算装置105は、機能利用情報D14に示された各種機能の利用状況(利用履歴および利用予定)の中から、演算装置105の利用を伴う機能の利用状況を検出する。演算装置105は、その検出された機能の利用状況に基づいて、演算装置105の稼働率(過去の稼働率および未来の稼働率)を推定する。そして、演算装置105は、その推定された演算装置105の稼働率に基づいて、記憶部104に記憶された稼働管理情報D17を更新する。
<Updating operation management information based on function usage information>
Also, in this example, the computing device 105 accesses the storage unit 104 and acquires function usage information D14 stored in the storage unit 104. The computing device 105 detects the usage status of functions involving use of the computing device 105 from the usage status (usage history and usage schedule) of various functions indicated in the function usage information D14. The computing device 105 estimates the operation rates (past operation rates and future operation rates) of the computing device 105 based on the detected function usage status. Then, the computing device 105 updates the operation management information D17 stored in the storage unit 104 based on the estimated operation rate of the computing device 105.
〈車両利用情報に基づく稼働管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された車両利用情報D15を取得する。演算装置105は、車両利用情報D15に示された車両10の利用状況(利用履歴および利用予定)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、演算装置105の稼働率(過去の稼働率および未来の稼働率)を推定する。そして、演算装置105は、その推定された演算装置105の稼働率に基づいて、記憶部104に記憶された稼働管理情報D17を更新する。
<Updating operation management information based on vehicle usage information>
Also, in this example, the calculation device 105 accesses the storage unit 104 and acquires vehicle usage information D15 stored in the storage unit 104. The calculation device 105 estimates the driving status (driving history and driving schedule) of the vehicle 10 based on the usage status (usage history and usage schedule) of the vehicle 10 indicated in the vehicle usage information D15, and estimates the availability (past availability rate and future availability rate) of the calculation device 105 based on the estimation result. Then, the calculation device 105 updates the operation management information D17 stored in the storage unit 104 based on the estimated availability rate of the calculation device 105.
〈位置管理情報に基づく稼働管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された位置管理情報D16を取得する。次に、演算装置105は、位置管理情報D16に示された車両10の位置(過去の位置および未来の位置)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、演算装置105の稼働率(過去の稼働率および未来の稼働率)を推定する。そして、演算装置105は、その推定された演算装置105の稼働率に基づいて、記憶部104に記憶された稼働管理情報D17を更新する。
<Updating operation management information based on location management information>
Also, in this example, the calculation device 105 accesses the storage unit 104 and acquires the position management information D16 stored in the storage unit 104. Next, the calculation device 105 estimates the driving situation (driving history and driving schedule) of the vehicle 10 based on the position (past position and future position) of the vehicle 10 indicated in the position management information D16, and estimates the operation rate (past operation rate and future operation rate) of the calculation device 105 based on the result of the estimation. Then, the calculation device 105 updates the operation management information D17 stored in the storage unit 104 based on the estimated operation rate of the calculation device 105.
〈スケジュール情報に基づく稼働管理情報の更新〉
また、この例では、「スケジュール情報に基づく位置管理情報の更新」と同様に、演算装置105は、その演算装置105が搭載された車両10を所有するユーザに所有されるユーザ端末20の記憶部204にアクセスし、記憶部204に記憶されたスケジュール情報D23に示されたユーザの行動(行動履歴および行動予定)の中から、車両10の利用を伴う行動を検出する。
<Updating operation management information based on schedule information>
Also, in this example, similar to "updating location management information based on schedule information," the arithmetic device 105 accesses the memory unit 204 of the user terminal 20 owned by the user who owns the vehicle 10 in which the arithmetic device 105 is installed, and detects actions involving the use of the vehicle 10 from among the user's actions (action history and action plans) shown in the schedule information D23 stored in the memory unit 204.
次に、演算装置105は、その検出されたユーザの行動(行動履歴および行動予定)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、演算装置105の稼働率(過去の稼働率および未来の稼働率)を推定する。そして、演算装置105は、その推定された演算装置105の稼働率に基づいて、記憶部104に記憶された稼働管理情報D17を更新する。 Then, the computing device 105 estimates the driving conditions (driving history and driving schedule) of the vehicle 10 based on the detected user behavior (behavior history and behavior schedule), and estimates the operating rate (past operating rate and future operating rate) of the computing device 105 based on the result of this estimation. The computing device 105 then updates the operation management information D17 stored in the memory unit 104 based on the estimated operating rate of the computing device 105.
〔通信管理情報の更新〕
次に、通信管理情報D18の更新について説明する。演算装置105は、その演算装置105が搭載された車両10の通信状態を監視し、その監視の結果に基づいて、通信管理情報D18に示された車両10の過去の通信状態を更新する。また、演算装置105は、車両10の通信状態の推定に利用可能な情報を取得すると、その情報に基づいて、通信管理情報D18に示された車両10の通信状態を更新する。
[Updating communication management information]
Next, the updating of the communication management information D18 will be described. The arithmetic device 105 monitors the communication status of the vehicle 10 in which the arithmetic device 105 is installed, and updates the past communication status of the vehicle 10 indicated in the communication management information D18 based on the results of this monitoring. Furthermore, when the arithmetic device 105 acquires information that can be used to estimate the communication status of the vehicle 10, the arithmetic device 105 updates the communication status of the vehicle 10 indicated in the communication management information D18 based on that information.
車両10の通信状態の推定に利用可能な情報の例としては、車両10の走行履歴および走行予定を示すカーナビゲーション情報、車両10の記憶部104に記憶された機能利用情報D14、車両利用情報D15、位置管理情報D16、ユーザ端末20の記憶部204に記憶されたスケジュール情報D23などが挙げられる。 Examples of information that can be used to estimate the communication status of vehicle 10 include car navigation information indicating the driving history and driving schedule of vehicle 10, function usage information D14 stored in the memory unit 104 of vehicle 10, vehicle usage information D15, location management information D16, and schedule information D23 stored in the memory unit 204 of user terminal 20.
〈カーナビゲーション情報に基づく通信管理情報の更新〉
この例では、演算装置105は、入力部101に入力されたカーナビゲーション情報に示された車両10の走行履歴および走行予定に基づいて、車両10の通信状態(過去の通信状態および未来の通信状態)を推定する。例えば、「通信環境が比較的に良好な位置に車両10が停車していた期間における車両10の通信状態」および「通信環境が比較的に良好な位置に車両10が停車する予定である期間における車両10の通信状態」は、「比較的に良好な通信状態」と推定される。そして、演算装置105は、その推定された車両10の通信状態に基づいて、記憶部104に記憶された通信管理情報D18を更新する。
<Updating communication management information based on car navigation information>
In this example, the arithmetic device 105 estimates the communication state (past communication state and future communication state) of the vehicle 10 based on the driving history and driving schedule of the vehicle 10 indicated in the car navigation information input to the input unit 101. For example, the "communication state of the vehicle 10 during a period when the vehicle 10 was parked in a location with a relatively good communication environment" and the "communication state of the vehicle 10 during a period when the vehicle 10 is scheduled to be parked in a location with a relatively good communication environment" are estimated to be "relatively good communication states." Then, the arithmetic device 105 updates the communication management information D18 stored in the storage unit 104 based on the estimated communication state of the vehicle 10.
〈機能利用情報に基づく通信管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された機能利用情報D14を取得する。演算装置105は、機能利用情報D14に示された各種機能の利用状況(利用履歴および利用予定)の中から、通信の利用を伴う機能の利用状況を検出する。演算装置105は、その検出された機能の利用状況に基づいて、車両10の通信状態(過去の通信状態および未来の通信状態)を推定する。そして、演算装置105は、その推定された車両10の通信状態に基づいて、記憶部104に記憶された通信管理情報D18を更新する。
<Updating communication management information based on function usage information>
Also, in this example, the arithmetic device 105 accesses the storage unit 104 and acquires function usage information D14 stored in the storage unit 104. The arithmetic device 105 detects the usage status of functions involving communication use from the usage status (usage history and usage schedule) of various functions indicated in the function usage information D14. The arithmetic device 105 estimates the communication status of the vehicle 10 (past communication status and future communication status) based on the detected usage status of the functions. Then, the arithmetic device 105 updates the communication management information D18 stored in the storage unit 104 based on the estimated communication status of the vehicle 10.
〈車両利用情報に基づく通信管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された車両利用情報D15を取得する。演算装置105は、車両利用情報D15に示された車両10の利用状況(利用履歴および利用予定)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、車両10の通信状態(過去の通信状態および未来の通信状態)を推定する。そして、演算装置105は、その推定された車両10の通信状態に基づいて、記憶部104に記憶された通信管理情報D18を更新する。
<Updating communication management information based on vehicle usage information>
Also, in this example, the arithmetic device 105 accesses the storage unit 104 and acquires vehicle usage information D15 stored in the storage unit 104. The arithmetic device 105 estimates the driving status (driving history and driving schedule) of the vehicle 10 based on the usage status (usage history and usage schedule) of the vehicle 10 indicated in the vehicle usage information D15, and estimates the communication status (past communication status and future communication status) of the vehicle 10 based on the estimation result. Then, the arithmetic device 105 updates the communication management information D18 stored in the storage unit 104 based on the estimated communication status of the vehicle 10.
〈位置管理情報に基づく通信管理情報の更新〉
また、この例では、演算装置105は、記憶部104にアクセスし、記憶部104に記憶された位置管理情報D16を取得する。次に、演算装置105は、位置管理情報D16に示された車両10の位置(過去の位置および未来の位置)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、車両10の通信状態(過去の通信状態および未来の通信状態)を推定する。そして、演算装置105は、その推定された車両10の通信状態に基づいて、記憶部104に記憶された通信管理情報D18を更新する。
<Updating communication management information based on location management information>
Also, in this example, the arithmetic device 105 accesses the storage unit 104 and acquires the location management information D16 stored in the storage unit 104. Next, the arithmetic device 105 estimates the driving situation (driving history and driving schedule) of the vehicle 10 based on the location (past location and future location) of the vehicle 10 indicated in the location management information D16, and estimates the communication state (past communication state and future communication state) of the vehicle 10 based on the result of the estimation. Then, the arithmetic device 105 updates the communication management information D18 stored in the storage unit 104 based on the estimated communication state of the vehicle 10.
〈スケジュール情報に基づく通信管理情報の更新〉
また、この例では、「スケジュール情報に基づく位置管理情報の更新」と同様に、演算装置105は、その演算装置105が搭載された車両10を所有するユーザに所有されるユーザ端末20の記憶部204にアクセスし、記憶部204に記憶されたスケジュール情報D23に示されたユーザの行動(行動履歴および行動予定)の中から、車両10の利用を伴う行動を検出する。
<Updating communication management information based on schedule information>
Also, in this example, similar to "updating location management information based on schedule information," the arithmetic device 105 accesses the memory unit 204 of the user terminal 20 owned by the user who owns the vehicle 10 in which the arithmetic device 105 is installed, and detects actions involving the use of the vehicle 10 from among the user's actions (action history and action plans) shown in the schedule information D23 stored in the memory unit 204.
次に、演算装置105は、その検出されたユーザの行動(行動履歴および行動予定)に基づいて、車両10の走行状況(走行履歴および走行予定)を推定し、その推定の結果に基づいて、車両10の通信状態(過去の通信状態および未来の通信状態)を推定する。そして、演算装置105は、その推定された車両10の通信状態に基づいて、記憶部104に記憶された通信管理情報D18を更新する。 Then, the calculation device 105 estimates the driving conditions (driving history and driving schedule) of the vehicle 10 based on the detected user behavior (behavior history and behavior schedule), and estimates the communication state (past communication state and future communication state) of the vehicle 10 based on the results of this estimation. The calculation device 105 then updates the communication management information D18 stored in the memory unit 104 based on the estimated communication state of the vehicle 10.
〔制御部による処理(管理方法)〕
制御部505は、ジョブ受付処理と、位置予測処理と、能力予測処理と、通信予測処理と、マッチング処理と、グリッドコンピューティング処理とを行う。これらの処理は、グリッドコンピューティング処理を管理するための管理方法の一例である。
[Processing by the control unit (management method)]
The control unit 505 performs job reception processing, location prediction processing, capacity prediction processing, communication prediction processing, matching processing, and grid computing processing. These processes are examples of a management method for managing grid computing processing.
〔ジョブ受付処理〕
次に、図7を参照して、ジョブ受付処理について説明する。ジョブ受付処理では、クライアントにより計算を依頼されたジョブデータD1を受け付ける。例えば、制御部505は、クライアントからジョブデータD1の計算が依頼される毎に、以下の処理を行う。
[Job acceptance processing]
Next, the job reception process will be described with reference to Fig. 7. In the job reception process, job data D1 for which a calculation is requested by a client is received. For example, the control unit 505 performs the following process each time a calculation of job data D1 is requested by a client.
〈ステップS11〉
まず、管理サーバ50は、クライアントからジョブの依頼を受け付ける。具体的には、クライアントサーバ30は、クライアントの担当者による操作に応答して、ジョブ依頼申請を管理サーバ50に送信する。管理サーバ50の制御部505は、その申請に応答して以下の処理を行う。
<Step S11>
First, the management server 50 accepts a job request from a client. Specifically, in response to an operation by a client's staff member, the client server 30 transmits a job request application to the management server 50. In response to the application, the control unit 505 of the management server 50 performs the following processing.
制御部505は、ジョブの受付に必要となる情報(具体的にはジョブを依頼するクライアントに関するクライアント情報とジョブに関するジョブ情報)の送信をクライアントサーバ30に要求する。この例では、制御部505は、ジョブ受付画面の画像データをクライアントサーバ30に送信する。クライアントサーバ30の制御部305は、その画像データからジョブ受付画面の画像を再生し、その画像を出力部302(表示部)に出力(表示)させる。 The control unit 505 requests the client server 30 to send the information required to accept the job (specifically, client information about the client requesting the job and job information about the job). In this example, the control unit 505 sends image data of the job acceptance screen to the client server 30. The control unit 305 of the client server 30 reproduces the image of the job acceptance screen from the image data and outputs (displays) the image on the output unit 302 (display unit).
図8に示すように、ジョブ受付画面は、ジョブの受付に必要となる情報を入力させる画面である。ジョブ受付画面には、クライアント名を入力するクライアント名入力欄R101、クライアントの担当者名を入力する担当者名入力欄R102、クライアントの住所を入力する住所入力欄R104、ジョブの名称を入力するジョブ名称入力欄R111、ジョブの内容に関する説明を入力するジョブ内容入力欄R112、ジョブに対応するジョブデータの計算タイプを入力する計算タイプ入力欄R113、ジョブデータの処理条件を入力する処理条件入力欄R114、ジョブデータの必要計算能力を入力する必要計算能力入力欄R115、ジョブの納期を入力する納期入力欄R116と、登録ボタンB100とが設けられる。 As shown in FIG. 8, the job reception screen is a screen for entering information required to accept a job. The job reception screen is provided with a client name input field R101 for entering the client name, a person in charge name input field R102 for entering the client person in charge name, an address input field R104 for entering the client address, a job name input field R111 for entering the job name, a job content input field R112 for entering a description of the job content, a calculation type input field R113 for entering the calculation type of the job data corresponding to the job, a processing condition input field R114 for entering the processing conditions of the job data, a required calculation capacity input field R115 for entering the required calculation capacity for the job data, a delivery date input field R116 for entering the delivery date of the job, and a register button B100.
クライアントの担当者は、クライアントサーバ30の入力部301(操作部)を操作して、ジョブ受付画面に必要な情報を入力する。これにより、ジョブを依頼するクライアントに関するクライアント情報と、ジョブに関するジョブ情報とが入力される。そして、これらの情報の入力が完了すると、クライアントの担当者は、クライアントサーバ30の入力部301(操作部)を操作して、ジョブ受付画面の登録ボタンB100を押下する。登録ボタンB100が押下されると、クライアントサーバ30の制御部305は、ジョブ受付画面に入力された情報(クライアント情報およびジョブ情報)を管理サーバ50に送信する。管理サーバ50の制御部505は、クライアント情報とジョブ情報とを受信する。 The client staff operates the input unit 301 (operation unit) of the client server 30 to input the necessary information into the job reception screen. This inputs client information about the client requesting the job and job information about the job. Once this information has been input, the client staff operates the input unit 301 (operation unit) of the client server 30 to press the registration button B100 on the job reception screen. When the registration button B100 is pressed, the control unit 305 of the client server 30 sends the information entered into the job reception screen (client information and job information) to the management server 50. The control unit 505 of the management server 50 receives the client information and job information.
次に、制御部505は、ジョブに対応するジョブデータD1の送信をクライアントサーバ30に要求する。クライアントサーバ30の制御部305は、その要求に応答して、ジョブに対応するジョブデータD1を管理サーバ50に送信する。管理サーバ50の制御部505は、ジョブデータD1を受信する。 Next, the control unit 505 requests the client server 30 to send job data D1 corresponding to the job. In response to the request, the control unit 305 of the client server 30 sends job data D1 corresponding to the job to the management server 50. The control unit 505 of the management server 50 receives the job data D1.
〈ステップS12〉
次に、管理サーバ50の制御部505は、ステップS11において受信されたジョブデータD1を分析する。具体的には、制御部505は、ジョブデータD1の計算タイプ、処理条件、必要計算能力などを分析する。そして、制御部505は、ジョブデータD1の分析の結果に基づいて、ステップS11において受信されたジョブ情報を修正する。
<Step S12>
Next, the control unit 505 of the management server 50 analyzes the job data D1 received in step S11. Specifically, the control unit 505 analyzes the calculation type, processing conditions, required calculation capacity, etc. of the job data D1. Then, the control unit 505 modifies the job information received in step S11 based on the results of the analysis of the job data D1.
なお、ステップS11において受信されたジョブ情報が十分に信頼できる場合は、ステップS12の処理を省略してもよい。 Note that if the job information received in step S11 is sufficiently reliable, processing in step S12 may be omitted.
〈ステップS13〉
次に、管理サーバ50の制御部505は、ステップS11において受信されたクライアント情報と、ステップS12において必要に応じて修正されたジョブ情報(またはステップS11において受信されたジョブ情報)とを関連付けて、ジョブテーブルD54に登録する。また、制御部505は、ステップS11において受信されたジョブデータD1を記憶部504に記憶する。
<Step S13>
Next, the control unit 505 of the management server 50 associates the client information received in step S11 with the job information corrected as necessary in step S12 (or the job information received in step S11), and registers them in the job table D54. The control unit 505 also stores the job data D1 received in step S11 in the storage unit 504.
〔位置予測処理〕
次に、図9を参照して、位置予測処理について説明する。位置予測処理では、制御部505は、車両テーブルD52に登録された車両10の位置管理情報D16に基づいて、その車両10の位置の時間的変化を予測する。例えば、制御部505は、車両テーブルD52に登録された車両10の位置管理情報D16が更新されると、その車両10について以下の処理を行う。
[Position Prediction Processing]
Next, the position prediction process will be described with reference to Fig. 9. In the position prediction process, the control unit 505 predicts a change in the position of the vehicle 10 over time based on the position management information D16 of the vehicle 10 registered in the vehicle table D52. For example, when the position management information D16 of the vehicle 10 registered in the vehicle table D52 is updated, the control unit 505 performs the following process for the vehicle 10.
〈ステップS21〉
まず、制御部505は、車両テーブルD52に登録された車両10の位置管理情報D16を取得する。なお、「位置管理情報の更新」と同様に、制御部505は、車両10の位置の推定に利用可能な情報に基づいて、車両テーブルD52に登録された車両10の位置管理情報D16を更新し、その更新後の位置管理情報D16を取得してもよい。
<Step S21>
First, the control unit 505 acquires the location management information D16 of the vehicle 10 registered in the vehicle table D52. As in the "updating of location management information," the control unit 505 may update the location management information D16 of the vehicle 10 registered in the vehicle table D52 based on information that can be used to estimate the location of the vehicle 10, and acquire the updated location management information D16.
〈ステップS22〉
次に、制御部505は、ステップS21において取得された車両10の「位置管理情報D16」に基づいて、車両10の位置の時間的変化を予測する。
<Step S22>
Next, the control unit 505 predicts a change in the position of the vehicle 10 over time based on the "position management information D16" of the vehicle 10 acquired in step S21.
具体的には、制御部505は、位置管理情報D16に示された車両の位置から、車両10の位置の変化の傾向(パターン)を予測する。この車両10の位置の変化の傾向の予測は、機械学習により実現されてもよい。そして、制御部505は、車両10の位置の変化の傾向に基づいて、車両10の位置の時間的変化(車両10がどの時刻にどの位置にいるのか)を予測する。 Specifically, the control unit 505 predicts the trend (pattern) of changes in the position of the vehicle 10 from the vehicle position indicated in the position management information D16. This prediction of the trend of changes in the position of the vehicle 10 may be achieved by machine learning. Then, the control unit 505 predicts changes in the position of the vehicle 10 over time (where the vehicle 10 is at what time) based on the trend of changes in the position of the vehicle 10.
〈ステップS23〉
次に、制御部505は、ステップS22において予測された「車両10の位置の時間的変化」を示す位置予測情報D5を位置予測テーブルD55に登録(上書き)する。これにより、位置予測テーブルD55が更新される。なお、位置管理情報D16に示された車両10の未来の位置(推定値)が十分に信頼できる場合は、その車両10の未来の位置が位置予測情報D5に登録されてもよい。
<Step S23>
Next, the control unit 505 registers (overwrites) the position prediction information D5 indicating the "change in the position of the vehicle 10 over time" predicted in step S22 in the position prediction table D55. This updates the position prediction table D55. Note that if the future position (estimated value) of the vehicle 10 indicated in the position management information D16 is sufficiently reliable, the future position of the vehicle 10 may be registered in the position prediction information D5.
〔能力予測処理〕
次に、図10を参照して、能力予測処理について説明する。能力予測処理では、制御部505は、車両テーブルD52に登録された車両10の稼働管理情報D17に基づいて、その車両10の演算装置105のグリッドコンピューティング処理において利用可能な計算能力を予測する。例えば、制御部505は、車両テーブルD52に登録された車両10の稼働管理情報D17が更新されると、その車両10について以下の処理を行う。
[Ability Prediction Processing]
Next, the capacity prediction process will be described with reference to Fig. 10. In the capacity prediction process, the control unit 505 predicts the computational capacity available for grid computing processing of the computing device 105 of the vehicle 10 based on the operation management information D17 of the vehicle 10 registered in the vehicle table D52. For example, when the operation management information D17 of the vehicle 10 registered in the vehicle table D52 is updated, the control unit 505 performs the following process for the vehicle 10.
〈ステップS31〉
まず、制御部505は、車両テーブルD52に登録された車両10の演算装置情報D12と稼働管理情報D17を取得する。なお、「稼働管理情報の更新」と同様に、制御部505は、車両10の計算能力の利用率の推定に利用可能な情報に基づいて、車両テーブルD52に登録された車両10の稼働管理情報D17を更新し、その更新後の稼働管理情報D17を取得してもよい。
<Step S31>
First, the control unit 505 acquires the calculation unit information D12 and operation management information D17 of the vehicle 10 registered in the vehicle table D52. As in "updating operation management information," the control unit 505 may update the operation management information D17 of the vehicle 10 registered in the vehicle table D52 based on information that can be used to estimate the utilization rate of the computing capacity of the vehicle 10, and acquire the updated operation management information D17.
〈ステップS32〉
次に、制御部505は、ステップS31において取得された車両10の「演算装置情報D12」と「稼働管理情報D17」に基づいて、その車両10の演算装置105のグリッドコンピューティング処理において利用可能な計算能力の時間的変化を予測する。
<Step S32>
Next, the control unit 505 predicts the change over time in the computing capacity available for grid computing processing of the computing device 105 of the vehicle 10 based on the ``computing device information D12'' and ``operation management information D17'' of the vehicle 10 acquired in step S31.
具体的には、制御部505は、稼働管理情報D17に示された車両10の演算装置105の稼働状況から、車両10の演算装置105の計算能力の利用率の変化の傾向(パターン)を予測する。この演算装置105の計算能力の利用率の変化の傾向の予測は、機械学習により実現されてもよい。そして、制御部505は、車両10の演算装置105の計算能力の利用率の変化の傾向に基づいて、その車両10の演算装置105の計算能力に余裕がある期間(計算能力の利用率が100%未満である期間)を予測し、その期間を「その車両10の演算装置105の計算能力をグリッドコンピューティング処理に利用することが可能な期間」とする。例えば、制御部505は、車両10の演算装置105の計算能力の利用率が「30%」である期間を、車両10の演算装置105の計算能力の「70%」をグリッドコンピューティング処理において利用することが可能な期間とする。 Specifically, the control unit 505 predicts the trend (pattern) of changes in the utilization rate of the computing capacity of the computing device 105 of the vehicle 10 based on the operating status of the computing device 105 of the vehicle 10 indicated in the operation management information D17. This prediction of the trend of changes in the utilization rate of the computing capacity of the computing device 105 may be achieved by machine learning. Then, based on the trend of changes in the utilization rate of the computing capacity of the computing device 105 of the vehicle 10, the control unit 505 predicts a period during which the computing capacity of the computing device 105 of the vehicle 10 has spare capacity (a period during which the utilization rate of the computing capacity is less than 100%) and defines this period as a "period during which the computing capacity of the computing device 105 of the vehicle 10 can be used for grid computing processing." For example, the control unit 505 defines a period during which the utilization rate of the computing capacity of the computing device 105 of the vehicle 10 is 30% as a period during which 70% of the computing capacity of the computing device 105 of the vehicle 10 can be used for grid computing processing.
〈ステップS33〉
次に、制御部505は、ステップS32において予測された「演算装置105のグリッドコンピューティング処理において利用可能な計算能力の時間的変化」を示す能力予測情報D6を能力予測テーブルD56に登録(上書き)する。これにより、能力予測テーブルD56が更新される。
<Step S33>
Next, the control unit 505 registers (overwrites) the capacity prediction information D6 indicating the "change over time in the computing capacity available for grid computing processing of the computing device 105" predicted in step S32 in the capacity prediction table D56. This updates the capacity prediction table D56.
〔通信予測処理〕
次に、図11を参照して、通信予測処理について説明する。通信予測処理では、制御部505は、車両テーブルD52に登録された車両10の通信管理情報D18に基づいて、その車両10の通信状態の時間的変化を予測する。例えば、制御部505は、車両テーブルD52に登録された車両10の通信管理情報D18が更新されると、その車両10について以下の処理を行う。
[Communication prediction processing]
Next, the communication prediction process will be described with reference to Fig. 11. In the communication prediction process, the control unit 505 predicts a change over time in the communication state of the vehicle 10 based on the communication management information D18 of the vehicle 10 registered in the vehicle table D52. For example, when the communication management information D18 of the vehicle 10 registered in the vehicle table D52 is updated, the control unit 505 performs the following process for the vehicle 10.
〈ステップS41〉
まず、制御部505は、車両テーブルD52に登録された車両10の通信管理情報D18を取得する。なお、「通信管理情報の更新」と同様に、制御部505は、車両10の通信状態の推定に利用可能な情報に基づいて、車両テーブルD52に登録された車両10の通信管理情報D18を更新し、その更新後の通信管理情報D18を取得してもよい。
<Step S41>
First, the control unit 505 acquires the communication management information D18 of the vehicle 10 registered in the vehicle table D52. As in the "updating of communication management information," the control unit 505 may update the communication management information D18 of the vehicle 10 registered in the vehicle table D52 based on information that can be used to estimate the communication status of the vehicle 10, and acquire the updated communication management information D18.
〈ステップS42〉
次に、制御部505は、ステップS41において取得された車両10の通信管理情報D18に基づいて、車両10の通信状態の時間的変化を予測する。
<Step S42>
Next, the control unit 505 predicts a change over time in the communication state of the vehicle 10 based on the communication management information D18 of the vehicle 10 acquired in step S41.
具体的には、制御部505は、通信管理情報D18に示された車両の通信状態から、車両10の通信状態の変化の傾向(パターン)を予測する。この車両10の通信状態の変化の傾向の予測は、機械学習により実現されてもよい。そして、制御部505は、車両10の通信状態の変化の傾向に基づいて、車両10の通信状態の時間的変化(車両10の通信状態がどの時刻にどのような状態であるのか)を予測する。 Specifically, the control unit 505 predicts the trend (pattern) of changes in the communication state of the vehicle 10 from the vehicle's communication state indicated in the communication management information D18. This prediction of the trend of changes in the communication state of the vehicle 10 may be achieved by machine learning. Then, the control unit 505 predicts changes over time in the communication state of the vehicle 10 (what state the communication state of the vehicle 10 will be at what time) based on the trend of changes in the communication state of the vehicle 10.
〈ステップS43〉
次に、制御部505は、ステップS42において予測された「車両10の通信状態の時間的変化」を示す通信予測情報D7を通信予測テーブルD57に登録(上書き)する。これにより、通信予測テーブルD57が更新される。なお、通信管理情報D18に示された車両10の未来の通信状態(推定値)が十分に信頼できる場合は、その車両10の未来の通信状態が通信予測情報D7に登録されてもよい。
<Step S43>
Next, the control unit 505 registers (overwrites) the communication prediction information D7 indicating the "change over time in the communication state of the vehicle 10" predicted in step S42 in the communication prediction table D57. This updates the communication prediction table D57. Note that if the future communication state (estimated value) of the vehicle 10 indicated in the communication management information D18 is sufficiently reliable, the future communication state of the vehicle 10 may be registered in the communication prediction information D7.
〔マッチング処理〕
次に、図12を参照して、マッチング処理について説明する。マッチング処理は、受付処理において受け付けられたジョブデータD1に対し、複数の車両10のうちグリッドコンピューティング処理において利用可能な車両10を割り当てる処理である。例えば、制御部505は、ジョブ受付処理の完了後に、以下の処理を行う。
[Matching process]
Next, the matching process will be described with reference to Fig. 12. The matching process is a process of allocating vehicles 10 that can be used in grid computing processing from among the multiple vehicles 10 to the job data D1 accepted in the acceptance process. For example, after the job acceptance process is completed, the control unit 505 performs the following process.
〈ステップS51〉
まず、制御部505は、ジョブテーブルD54に登録されたジョブの中からマッチング処理の対象となるジョブを選択する。そして、制御部505は、記憶部504に記憶されたジョブデータD1の中からマッチング処理の対象となるジョブに対応するジョブデータD1を選択する。
<Step S51>
First, the control unit 505 selects a job to be subjected to the matching process from among the jobs registered in the job table D54. Then, the control unit 505 selects job data D1 corresponding to the job to be subjected to the matching process from among the job data D1 stored in the storage unit 504.
〈ステップS52〉
次に、制御部505は、「能力予測テーブルD56に登録された複数の車両10の各々のグリッドコンピューティング処理において利用可能な計算能力の時間的変化の予測結果」と「通信予測テーブルD57に登録された複数の車両10の各々の通信状態の時間的変化の予測結果」とに基づいて、複数の車両10の中から、ステップS51において選択されたジョブデータD1に対するグリッドコンピューティング処理において利用可能な車両10を選択する。
<Step S52>
Next, the control unit 505 selects a vehicle 10 from the multiple vehicles 10 that can be used in grid computing processing for the job data D1 selected in step S51 based on the ``prediction result of the change over time in the computing capacity available for grid computing processing for each of the multiple vehicles 10 registered in the capacity prediction table D56'' and the ``prediction result of the change over time in the communication status of each of the multiple vehicles 10 registered in the communication prediction table D57.''
具体的には、制御部505は、ジョブデータD1に対するグリッドコンピューティング処理が実行される計算予定期間を決定し、複数の車両10の中から計算予定期間において通信可能であり且つ計算能力を提供することが可能な車両10を検出する。そして、制御部505は、「グリッドコンピューティング処理に提供される計算能力の合計」が「グリッドコンピューティング処理においてジョブデータD1の計算に必要とされる計算能力」以上となるように、計算予定期間において計算能力を提供することが可能な車両10の中から、ジョブデータD1に割り当てられる車両10を選択する。 Specifically, the control unit 505 determines a planned calculation period during which grid computing processing for job data D1 will be executed, and detects from among the multiple vehicles 10 vehicles 10 that are capable of communication and providing computing power during the planned calculation period. The control unit 505 then selects vehicles 10 to be assigned to job data D1 from among the vehicles 10 that can provide computing power during the planned calculation period so that the "total computing power provided for grid computing processing" is equal to or greater than the "computing power required for calculating job data D1 in the grid computing processing."
〈ステップS53〉
次に、制御部505は、ステップS51において選択されたジョブデータD1に対し、ステップS52において選択された車両10を割り当てる。そして、制御部505は、どのジョブデータD1にどの車両10が割り当てられたのかを示すマッチング結果情報をマッチングテーブルD58に登録する。例えば、制御部505は、ジョブデータD1(ジョブ)に設定された受付番号と、そのジョブデータD1に割り当てられた車両10に設定された車両IDとを関連付けて、マッチングテーブルD58に登録する。
<Step S53>
Next, the control unit 505 assigns the vehicle 10 selected in step S52 to the job data D1 selected in step S51. Then, the control unit 505 registers matching result information indicating which vehicle 10 is assigned to which job data D1 in the matching table D58. For example, the control unit 505 associates the reception number set in the job data D1 (job) with the vehicle ID set for the vehicle 10 assigned to the job data D1, and registers them in the matching table D58.
〔グリッドコンピューティング処理〕
次に、図13を参照して、グリッドコンピューティング処理について説明する。グリッドコンピューティング処理では、複数の車両10のうち複数の利用可能な車両10にジョブデータD1を処理させる。例えば、制御部505は、マッチング処理の完了後に、以下の処理を行う。なお、グリッドコンピューティング処理は、複数の車両10のうち複数の利用可能な車両10に管理サーバ50により送信されたジョブデータD1を処理させる処理方法の一例である。
[Grid Computing Processing]
Next, the grid computing process will be described with reference to FIG. 13 . In the grid computing process, the job data D1 is processed by a plurality of available vehicles 10 among the plurality of vehicles 10. For example, the control unit 505 performs the following process after the matching process is completed. Note that the grid computing process is an example of a processing method in which the job data D1 transmitted by the management server 50 is processed by a plurality of available vehicles 10 among the plurality of vehicles 10.
〈ステップS61〉
まず、制御部505は、マッチングテーブルD58を参照し、グリッドコンピューティング処理の対象となるジョブデータD1を、マッチング処理においてそのジョブデータD1に割り当てられた車両10に分配する。具体的には、制御部505は、ジョブデータD1に割り当てられた車両10の各々に、そのジョブデータD1の一部を送信する。これにより、ジョブデータD1は、そのジョブデータD1に割り当てられた車両10により並列処理される。
<Step S61>
First, the control unit 505 refers to the matching table D58 and distributes the job data D1 to be subjected to the grid computing process to the vehicles 10 assigned to the job data D1 in the matching process. Specifically, the control unit 505 transmits a portion of the job data D1 to each of the vehicles 10 assigned to the job data D1. As a result, the job data D1 is processed in parallel by the vehicles 10 assigned to the job data D1.
〈ステップS62〉
次に、車両10の各々は、その車両10に送信された部分ジョブデータ(ジョブデータD1の一部)の計算が完了すると、その計算により得られた部分計算結果データ(計算結果データD2の一部)を管理サーバ50に送信する。管理サーバ50の制御部505は、車両10から送信された部分計算結果データを受信し、その部分計算結果データを記憶部504に記憶する。
<Step S62>
Next, when each vehicle 10 completes the calculation of the partial job data (part of job data D1) transmitted to that vehicle 10, it transmits the partial calculation result data (part of calculation result data D2) obtained by the calculation to management server 50. Control unit 505 of management server 50 receives the partial calculation result data transmitted from vehicle 10 and stores the partial calculation result data in memory unit 504.
〈ステップS63〉
制御部505は、ステップS61においてジョブデータD1が分配された車両10の全てが計算を完了しているか否かを判定する。車両10の全てが計算を完了している場合には、ステップS64の処理が行われ、そうでない場合には、ステップS62の処理が行われる。
<Step S63>
The control unit 505 determines whether or not all of the vehicles 10 to which the job data D1 has been distributed in step S61 have completed the calculations. If all of the vehicles 10 have completed the calculations, the process of step S64 is performed; if not, the process of step S62 is performed.
〈ステップS64〉
演算装置105の全てが計算を完了すると、制御部505は、記憶部504に記憶された部分計算結果データを結合することで、グリッドコンピューティング処理の対象となるジョブデータD1に対応する計算結果データD2(ジョブデータD1の計算の結果を示す計算結果データD2)を生成する。そして、制御部505は、グリッドコンピューティング処理の対象となるジョブデータD1に対応する計算結果データD2を、そのジョブデータD1の計算を依頼したクライアントのクライアントサーバ30に送信する。
<Step S64>
When all of the arithmetic devices 105 have completed the calculations, the control unit 505 generates calculation result data D2 (calculation result data D2 indicating the results of the calculation of job data D1) corresponding to the job data D1 that is the target of the grid computing process by combining the partial calculation result data stored in the storage unit 504. Then, the control unit 505 transmits the calculation result data D2 corresponding to the job data D1 that is the target of the grid computing process to the client server 30 of the client that requested the calculation of the job data D1.
〈ステップS65〉
次に、グリッドコンピューティング処理に車両10の演算装置105の計算能力を提供したユーザに対して、システム1を運営する事業者から報酬が付与される。ユーザに付与される報酬の例としては、システム1において利用可能なポイント、仮想通貨、商品の割引特典などが挙げられる。例えば、管理サーバ50の制御部505は、グリッドコンピューティング処理に車両10の演算装置105の計算能力を提供したユーザに対して報酬を付与するための処理を行う。報酬を付与するための処理の例としては、ユーザに設定された「ユーザID」とシステム1において利用可能な「ポイント」(または仮想通貨)とを関連付けてユーザテーブルD51に登録する処理、ユーザに所有されるユーザ端末20に商品の割引特典を示す情報を送信する処理などが挙げられる。なお、報酬を示す情報は、ジョブテーブルD54においてジョブ毎に登録されてもよい。
<Step S65>
Next, a reward is granted by the operator of the system 1 to a user who has provided the computing power of the arithmetic device 105 of the vehicle 10 for the grid computing process. Examples of rewards granted to a user include points, virtual currency, and product discount benefits that can be used in the system 1. For example, the control unit 505 of the management server 50 performs processing to grant a reward to a user who has provided the computing power of the arithmetic device 105 of the vehicle 10 for the grid computing process. Examples of the processing to grant a reward include a process of registering in the user table D51 a "user ID" set for the user and "points" (or virtual currency) that can be used in the system 1, and a process of transmitting information indicating a product discount benefit to the user terminal 20 owned by the user. Note that information indicating the reward may be registered for each job in the job table D54.
また、グリッドコンピューティング処理に車両10の演算装置105の計算能力を提供したユーザに対して、クライアントから報酬が付与されてもよい。例えば、クライアントサーバ30の制御部305は、グリッドコンピューティング処理に車両10の演算装置105の計算能力を提供したユーザに対して報酬を付与するための処理を実行してもよい。 Furthermore, a reward may be granted by the client to a user who provides the computing power of the computing device 105 of the vehicle 10 for grid computing processing. For example, the control unit 305 of the client server 30 may execute processing to grant a reward to a user who provides the computing power of the computing device 105 of the vehicle 10 for grid computing processing.
〔グリッドコンピューティング処理の特徴〕
次に、図14を参照して、グリッドコンピューティング処理の特徴について説明する。グリッドコンピューティング処理において、制御部505は、以下の処理を行う。
[Characteristics of grid computing processing]
Next, the characteristics of the grid computing process will be described with reference to Fig. 14. In the grid computing process, the control unit 505 performs the following processes.
なお、以下では、グリッドコンピューティング処理において利用可能な複数の車両10を「複数の利用可能な車両10」と記載する。この例では、「グリッドコンピューティング処理において利用可能な車両10」は、複数の車両10のうち、グリッドコンピューティング処理が行われる期間において、演算装置105の計算能力の利用率が100%未満であり、且つ、管理サーバ50または他の車両10と通信可能な車両10である。 Note that, hereinafter, multiple vehicles 10 available for use in grid computing processing will be referred to as "multiple available vehicles 10." In this example, a "vehicle 10 available for use in grid computing processing" is a vehicle 10 among multiple vehicles 10 whose computing device 105 has a utilization rate of less than 100% of the computing capacity during the period when grid computing processing is performed, and which is capable of communicating with the management server 50 or other vehicles 10.
図14に示すように、管理サーバ50の制御部505は、グリッドコンピューティング処理において処理しようとするジョブデータD1を、代表ノードN1に送信する。代表ノードN1は、複数の利用可能な車両10のうち管理サーバ50との間の通信安定度が予め定められた閾値を上回る車両10である。 As shown in FIG. 14, the control unit 505 of the management server 50 transmits job data D1 to be processed in grid computing processing to the representative node N1. The representative node N1 is a vehicle 10 among multiple available vehicles 10 whose communication stability with the management server 50 exceeds a predetermined threshold.
制御部505は、代表ノードN1が代表ノードN1に送信されたジョブデータD1(詳しくはジョブデータD1の一部である部分ジョブデータ)を計算ノードN2に送信するように、代表ノードN1を制御する。計算ノードN2は、複数の利用可能な車両10のうち代表ノードN1を除く他の車両10である。制御部505は、計算ノードN2に送信されたジョブデータD1(詳しくは部分ジョブデータ)を計算ノードN2に処理させる。計算ノードN2は、代表ノードN1から送信されたジョブデータを処理する非代表ノードの一例である。 The control unit 505 controls the representative node N1 so that the representative node N1 transmits the job data D1 (more specifically, partial job data that is part of the job data D1) transmitted to the representative node N1 to the calculation node N2. The calculation node N2 is one of the multiple available vehicles 10 other than the representative node N1. The control unit 505 causes the calculation node N2 to process the job data D1 (more specifically, partial job data) transmitted to the calculation node N2. The calculation node N2 is an example of a non-representative node that processes the job data transmitted from the representative node N1.
また、制御部505は、計算ノードN2がジョブデータD1の計算結果を示す計算結果データD2(詳しくは計算結果データD2の一部である部分計算結果データ)を代表ノードN1に送信するように、計算ノードN2を制御する。そして、制御部505は、代表ノードN1が代表ノードN1に送信された計算結果データ(詳しくは部分計算結果データ)を管理サーバ50に送信するように、代表ノードN1を制御する。 The control unit 505 also controls the calculation node N2 so that the calculation node N2 transmits calculation result data D2 (more specifically, partial calculation result data that is part of the calculation result data D2) indicating the calculation result of the job data D1 to the representative node N1. The control unit 505 then controls the representative node N1 so that the representative node N1 transmits the calculation result data (more specifically, partial calculation result data) transmitted to the representative node N1 to the management server 50.
なお、管理サーバ50と代表ノードN1は、通信網5(具体的には通信網5に設けられた基地局)を経由して通信する。代表ノードN1と計算ノードN2は、通信網5を経由せずに直接的に通信する。通信網5の例としては、通信事業者が提供する有料のキャリア通信網が挙げられる。 The management server 50 and representative node N1 communicate via a communication network 5 (specifically, a base station provided in the communication network 5). The representative node N1 and calculation node N2 communicate directly without going through the communication network 5. An example of the communication network 5 is a paid carrier communication network provided by a telecommunications company.
この例では、管理サーバ50と代表ノードN1の通信は、車両ネットワーク間通信(V2N)を利用する通信であり、具体的には、通信事業者が提供する有料のキャリア通信を利用する通信である。代表ノードN1と計算ノードN2の通信は、車車間通信(V2V)である。 In this example, communication between the management server 50 and representative node N1 is communication using vehicle-to-network (V2N) communication, specifically communication using paid carrier communication provided by a telecommunications carrier. Communication between the representative node N1 and calculation node N2 is vehicle-to-vehicle (V2V) communication.
〔ローカルエリアネットワーク〕
このように、代表ノードN1と計算ノードN2とにより、ローカルエリアネットワークが構成される。言い換えると、ローカルエリアネットワークを構成可能な複数の車両10の中から「代表ノードN1となる車両10」と「計算ノードN2となる車両10」とが選出される。そして、ローカルエリアネットワークによりジョブデータD1が処理される。
[Local Area Network]
In this way, a local area network is formed by the representative node N1 and the calculation node N2. In other words, a "vehicle 10 to serve as the representative node N1" and a "vehicle 10 to serve as the calculation node N2" are selected from a plurality of vehicles 10 that can form a local area network. Then, the job data D1 is processed by the local area network.
〔マッチング処理の詳細〕
マッチング処理において、管理サーバ50の制御部505は、複数の利用可能な車両10の中から「代表ノードN1として機能させる車両10」と「計算ノードN2として機能させる車両10」とを決定し、その決定の結果をジョブデータD1に関連付けてマッチングテーブルD58に登録する。
[Matching process details]
In the matching process, the control unit 505 of the management server 50 determines, from among multiple available vehicles 10, a "vehicle 10 to function as the representative node N1" and a "vehicle 10 to function as the calculation node N2," and associates the result of this determination with the job data D1 and registers it in the matching table D58.
具体的には、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において管理サーバ50との間の通信安定度が予め定められた閾値を上回る車両10を「代表ノードN1の候補」として選出する。次に、制御部505は、代表ノードN1の候補として選出された車両10の中から「代表ノードN1として機能させる車両10」を決定する。 Specifically, the control unit 505 refers to the communication prediction table D57 and selects, from among the multiple available vehicles 10, vehicles 10 whose communication stability with the management server 50 exceeds a predetermined threshold during the period in which grid computing processing is performed, as "candidates for representative node N1." Next, the control unit 505 determines, from among the vehicles 10 selected as candidates for representative node N1, a "vehicle 10 to function as representative node N1."
また、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において代表ノードN1と通信可能な車両10を「計算ノードN2の候補」として選出する。次に、制御部505は、能力予測テーブルD56を参照し、「グリッドコンピューティング処理に提供される計算ノードN2の計算能力の合計」が「グリッドコンピューティング処理においてジョブデータD1の計算に必要とされる計算能力」以上となるように、計算ノードN2の候補として選出された車両10の中から「計算ノードN2として機能させる車両10」を決定する。 The control unit 505 also references the communication prediction table D57 and selects, from among the multiple available vehicles 10, vehicles 10 that can communicate with the representative node N1 during the period in which the grid computing process is performed, as "candidates for computation node N2." Next, the control unit 505 references the capacity prediction table D56 and determines, from among the vehicles 10 selected as candidates for computation node N2, a "vehicle 10 to function as computation node N2" so that the "total computational capacity of computation nodes N2 provided for grid computing process" is equal to or greater than the "computational capacity required for calculating job data D1 in grid computing process."
次に、制御部505は、上記の決定の結果に基づいて、「代表ノードN1として機能させる車両10」および「計算ノードN2として機能させる車両10」を特定するためのノード情報と、代表ノードN1と計算ノードN2との対応関係(どの代表ノードN1とどの計算ノードN2とを通信させるのか)を示すリンク情報とを生成する。 Next, based on the results of the above determination, the control unit 505 generates node information for identifying the "vehicle 10 to function as the representative node N1" and the "vehicle 10 to function as the computation node N2," and link information indicating the correspondence between the representative node N1 and the computation node N2 (which representative node N1 will communicate with which computation node N2).
また、制御部505は、ジョブデータD1を複数の部分ジョブデータに分割する。そして、制御部505は、能力予測テーブルD56を参照し、複数の部分ジョブデータの各々に対して、その部分ジョブデータを処理させる計算ノードN2を決定する。部分ジョブデータに対する計算ノードN2の割り当てを完了すると、制御部505は、計算ノードN2と部分ジョブデータとの対応関係(どの計算ノードN2にどの部分ジョブデータを処理させるのか)を示す担当情報を生成する。 The control unit 505 also divides the job data D1 into multiple partial job data. Then, the control unit 505 references the capacity prediction table D56 and, for each of the multiple partial job data, determines the computation node N2 that will process that partial job data. After the computation node N2 has been assigned to the partial job data, the control unit 505 generates assignment information that indicates the correspondence between the computation node N2 and the partial job data (which computation node N2 is to process which partial job data).
次に、制御部505は、ノード情報とリンク情報と担当情報とをジョブデータD1に関連付けてマッチングテーブルD58に登録する。これにより、マッチングテーブルD58には、ジョブデータD1毎に、ノード情報とリンク情報と担当情報とが登録される。 Next, the control unit 505 associates the node information, link information, and responsibility information with the job data D1 and registers them in the matching table D58. As a result, the node information, link information, and responsibility information are registered in the matching table D58 for each job data D1.
〔グリッドコンピューティング処理の詳細〕
グリッドコンピューティング処理において、制御部505は、複数の利用可能な車両10のうち管理サーバ50との間の通信安定度が閾値を上回る車両10が「代表ノードN1」として機能し、複数の利用可能な車両10のうち代表ノードN1を除く他の車両10が「計算ノードN2」として機能するように、複数の利用可能な車両10を制御する。
[Details of grid computing processing]
In grid computing processing, the control unit 505 controls the multiple available vehicles 10 so that a vehicle 10 among the multiple available vehicles 10 whose communication stability with the management server 50 exceeds a threshold functions as a "representative node N1," and the other vehicles 10 among the multiple available vehicles 10 excluding the representative node N1 function as "computation nodes N2."
具体的には、制御部505は、マッチングテーブルD58に登録されたノード情報を参照し、複数の利用可能な車両10のうち「代表ノードN1として機能させようとする車両10」に対して、代表指令を送信する。代表指令は、車両10を代表ノードN1として機能させるための指令である。代表指令には、車両10を代表ノードN1として機能させるためのプログラムおよび情報が含まれてもよい。制御部505から送信された代表指令を受信した車両10は、その代表指令に応答して「代表ノードN1」として機能する。 Specifically, the control unit 505 references the node information registered in the matching table D58 and transmits a representative command to the "vehicle 10 that is to function as the representative node N1" from among the multiple available vehicles 10. The representative command is a command for causing the vehicle 10 to function as the representative node N1. The representative command may include a program and information for causing the vehicle 10 to function as the representative node N1. A vehicle 10 that receives the representative command transmitted from the control unit 505 functions as the "representative node N1" in response to the representative command.
また、制御部505は、マッチングテーブルD58に登録されたノード情報とリンク情報とを参照し、代表ノードN1に対して、その代表ノードN1に対応する「計算ノードN2として機能させようとする車両10」を示す従属情報と、計算指令とを送信する。計算指令は、車両10を計算ノードN2として機能させるための指令である。計算指令には、車両10を計算ノードN2として機能させるためのプログラムおよび情報が含まれてもよい。代表ノードN1は、従属情報に示された「計算ノードN2として機能させようとする車両10」に対して、計算指令を送信する。代表ノードN1から送信された計算指令を受信した車両10は、その計算指令に応答して「計算ノードN2」として機能する。 The control unit 505 also references the node information and link information registered in the matching table D58, and transmits to the representative node N1 dependency information indicating the "vehicle 10 to be made to function as computation node N2" corresponding to that representative node N1, and a computation command. The computation command is a command to cause the vehicle 10 to function as computation node N2. The computation command may include a program and information to cause the vehicle 10 to function as computation node N2. The representative node N1 transmits the computation command to the "vehicle 10 to be made to function as computation node N2" indicated in the dependency information. The vehicle 10 that receives the computation command transmitted from the representative node N1 functions as "computation node N2" in response to the computation command.
次に、制御部505は、ジョブデータD1を複数の部分ジョブデータに分割する。制御部505は、マッチングテーブルD58に登録された担当情報とリンク情報とを参照し、代表ノードN1に対して、複数の部分ジョブデータのうちその代表ノードN1に対応する計算ノードN2に処理させる部分ジョブデータと、その部分ジョブデータを処理させる計算ノードN2を示す送信先情報とを送信する。 Next, the control unit 505 divides the job data D1 into multiple partial job data. The control unit 505 references the responsibility information and link information registered in the matching table D58, and transmits to the representative node N1 the partial job data to be processed by the calculation node N2 corresponding to that representative node N1, as well as destination information indicating the calculation node N2 that will process the partial job data.
次に、代表ノードN1は、制御部505から送信された部分ジョブデータと送信先情報とを受信する。そして、代表ノードN1は、送信先情報を参照し、部分ジョブデータを、その部分ジョブデータに対応する計算ノードN2に送信する。具体的には、代表ノードN1は、部分ジョブデータを、送信先情報に示された「その部分ジョブデータを処理させる計算ノードN2」に送信する。 Next, the representative node N1 receives the partial job data and destination information sent from the control unit 505. Then, the representative node N1 references the destination information and sends the partial job data to the calculation node N2 that corresponds to that partial job data. Specifically, the representative node N1 sends the partial job data to the "calculation node N2 that will process that partial job data" indicated in the destination information.
図14の例では、ジョブデータD1を分割することにより得られた3つの部分ジョブデータを3つの計算ノードN2にそれぞれ処理させる。具体的には、図中の「1」と表記された第1番目の部分ジョブデータは、図中の「左側」に位置する第1番目の計算ノードN2により処理される。図中の「2」と表記された第2番目の部分ジョブデータは、図中の「下側」に位置する第2番目の計算ノードN2により処理される。図中の「3」と表記された第3番目のジョブデータは、図中の「右側」に位置する第3番目の計算ノードN2により処理される。 In the example of Figure 14, three partial job data obtained by dividing job data D1 are processed by three computation nodes N2, respectively. Specifically, the first partial job data, labeled "1" in the figure, is processed by the first computation node N2 located on the "left side" of the figure. The second partial job data, labeled "2" in the figure, is processed by the second computation node N2 located on the "bottom" of the figure. The third job data, labeled "3" in the figure, is processed by the third computation node N2 located on the "right side" of the figure.
そして、図14の例では、制御部505は、第1番目~第3番目の計算ノードN2に対応する代表ノードN1に対して、第1番目~第3番目の部分ジョブデータ(部分ジョブデータの集合体)と、送信先情報とを送信する。送信先情報は、第1番目~第3番目の部分ジョブデータを第1番目~第3番目の計算ノードN2にそれぞれ処理させることを示す。代表ノードN1は、制御部505から送信された3つの部分ジョブデータと送信先情報とを受信すると、送信先情報を参照し、第1番目~第3番目の部分ジョブデータを第1番目~第3番目の計算ノードN2にそれぞれ送信する。 In the example of FIG. 14, the control unit 505 transmits the first to third partial job data (a collection of partial job data) and destination information to the representative node N1 corresponding to the first to third computation nodes N2. The destination information indicates that the first to third partial job data are to be processed by the first to third computation nodes N2, respectively. Upon receiving the three partial job data and destination information transmitted from the control unit 505, the representative node N1 references the destination information and transmits the first to third partial job data to the first to third computation nodes N2, respectively.
次に、計算ノードN2は、代表ノードN1から送信された部分ジョブデータを受信し、その部分ジョブデータを計算する。これにより、部分ジョブデータの計算結果を示す部分計算結果データ(計算結果データD2の一部)が得られる。計算ノードN2は、部分計算結果データを代表ノードN1に送信する。 Next, computation node N2 receives the partial job data sent from representative node N1 and calculates that partial job data. This results in partial computation result data (part of computation result data D2) that indicates the computation results of the partial job data. Computation node N2 sends the partial computation result data to representative node N1.
次に、代表ノードN1は、計算ノードN2から送信された部分計算結果データを受信する。そして、代表ノードN1は、部分計算結果データを管理サーバ50に送信する。 Next, representative node N1 receives the partial calculation result data sent from calculation node N2. Then, representative node N1 sends the partial calculation result data to management server 50.
次に、管理サーバ50の制御部505は、代表ノードN1から送信された部分計算結果データを受信する。そして、制御部505は、複数の部分計算結果データを統合することで、ジョブデータD1の計算結果を示す計算結果データD2を生成する。 Next, the control unit 505 of the management server 50 receives the partial calculation result data sent from the representative node N1. The control unit 505 then integrates the multiple partial calculation result data to generate calculation result data D2 that indicates the calculation results of the job data D1.
〔実施形態の効果〕
以上のように、実施形態では、複数の利用可能な車両10のうち管理サーバ50との間の通信安定度が閾値を上回る車両10を「代表ノードN1」とすることにより、管理サーバ50と代表ノードN1との間の通信安定性を確保することができる。これにより、通信安定性が確保された通信経路を利用して、グリッドコンピューティング処理に関するデータ(ジョブデータおよび計算結果データ)を伝送することができる。
[Effects of the embodiment]
As described above, in the embodiment, by designating a vehicle 10 of a plurality of available vehicles 10 whose communication stability with the management server 50 exceeds a threshold as the "representative node N1," it is possible to ensure communication stability between the management server 50 and the representative node N1. This makes it possible to transmit data related to grid computing processing (job data and calculation result data) using a communication path with ensured communication stability.
このように、グリッドコンピューティング処理に関するデータが伝送される通信経路の通信安定性を確保することができるので、通信不良による不具合(例えばデータ伝送の長時間化など)の発生を低減することができる。これにより、グリッドコンピューティング処理のパフォーマンスを向上させることができる。 In this way, communication stability can be ensured for the communication paths over which data related to grid computing processing is transmitted, reducing the occurrence of problems caused by poor communication (such as prolonged data transmission times). This can improve the performance of grid computing processing.
また、実施形態では、管理サーバ50の制御部505と複数の計算ノードN2(非代表ノードの一例)とは、代表ノードN1を経由して間接的に通信する。このような構成により、管理サーバ50の制御部505と複数の計算ノードN2とが代表ノードN1を経由せずに直接的に通信する場合(すなわち管理サーバ50に通信が集中する場合)よりも、管理サーバ50の制御部505の通信負荷を低減することができる。 In addition, in the embodiment, the control unit 505 of the management server 50 and multiple calculation nodes N2 (an example of a non-representative node) communicate indirectly via the representative node N1. This configuration reduces the communication load on the control unit 505 of the management server 50 compared to when the control unit 505 of the management server 50 and multiple calculation nodes N2 communicate directly without going through the representative node N1 (i.e., when communication is concentrated on the management server 50).
また、実施形態では、管理サーバ50の制御部505と計算ノードN2とが直接的に通信することが困難である場合(例えば管理サーバ50と計算ノードN2との通信に利用される車両ネットワーク間通信における通信帯域が狭すぎる場合)であっても、管理サーバ50の制御部505と代表ノードN1とが通信可能であり、且つ、代表ノードN1と計算ノードN2とが通信可能であれば、管理サーバ50の制御部505から代表ノードN1を経由して計算ノードN2にジョブデータを送信することができる。このように、グリッドコンピューティング処理において、管理サーバ50の制御部505と直接的に通信することが困難である車両10を有効に利用することができる。 Furthermore, in an embodiment, even if it is difficult for the control unit 505 of the management server 50 and the calculation node N2 to communicate directly (for example, if the communication bandwidth for vehicle-to-vehicle network communications used for communication between the management server 50 and the calculation node N2 is too narrow), as long as the control unit 505 of the management server 50 and the representative node N1 can communicate and the representative node N1 and the calculation node N2 can communicate, job data can be sent from the control unit 505 of the management server 50 to the calculation node N2 via the representative node N1. In this way, in grid computing processing, vehicles 10 that have difficulty communicating directly with the control unit 505 of the management server 50 can be effectively utilized.
なお、通信網5を経由する通信(例えばキャリア通信)における通信安定度は、通信網5の利用状況に左右されやすい。例えば、通信網5を同時に利用する通信装置の数が多くなるほど、その通信網5を経由する通信における通信安定度が低くなりやすい。一方、通信網5を経由しない通信(例えば車車間通信)における通信安定度は、通信網5の利用状況に左右されない。 Note that the communication stability of communications via communication network 5 (e.g., carrier communications) is likely to be affected by the usage status of communication network 5. For example, the greater the number of communication devices simultaneously using communication network 5, the more likely the communication stability of communications via that communication network 5 will decrease. On the other hand, the communication stability of communications that do not go via communication network 5 (e.g., vehicle-to-vehicle communications) is not affected by the usage status of communication network 5.
実施形態では、管理サーバ50の制御部505と代表ノードN1は、通信網5を経由して通信する。代表ノードN1と計算ノードN2は、通信網5を経由せずに直接的に通信する。このような構成により、管理サーバ50の制御部505と複数の計算ノードN2とが通信網5を経由して通信する場合よりも、通信網5を利用する車両10の数を減らすことができる。これにより、グリッドコンピューティングにおける通信安定性の確保を容易にすることができる。 In this embodiment, the control unit 505 of the management server 50 and the representative node N1 communicate via the communication network 5. The representative node N1 and the calculation node N2 communicate directly without going through the communication network 5. With this configuration, the number of vehicles 10 using the communication network 5 can be reduced compared to when the control unit 505 of the management server 50 and multiple calculation nodes N2 communicate via the communication network 5. This makes it easier to ensure communication stability in grid computing.
また、実施形態では、制御部505は、グリッドコンピューティング処理において、計算結果データ(詳しくは部分計算結果データ)を代表ノードN1に送信するように計算ノードN2を制御し、代表ノードN1に送信された計算結果データを管理サーバ50に送信するように代表ノードN1を制御する。このような構成により、管理サーバ50と代表ノードN1との間の通信(通信安定性が確保された通信)を利用して計算結果データを送信することができる。 Furthermore, in an embodiment, in grid computing processing, the control unit 505 controls the calculation node N2 to send calculation result data (more specifically, partial calculation result data) to the representative node N1, and controls the representative node N1 to send the calculation result data sent to the representative node N1 to the management server 50. With this configuration, the calculation result data can be sent using communication between the management server 50 and the representative node N1 (communication with ensured communication stability).
また、実施形態では、制御部505は、複数の利用可能な車両10のうち管理サーバ50との間の通信安定度が閾値を上回る車両10を「代表ノードN1として機能させる車両10」に決定し、複数の利用可能な車両10のうち代表ノードN1と通信可能な車両10を「計算ノードN2として機能させる車両10」に決定する。このような構成により、制御部505(管理側)が代表ノードN1と計算ノードN2とを予め決定することで、「通信網5を経由する通信経路」と「通信網5を経由しない通信経路」とを決定することができる。そして、管理サーバ50との通信安定性が高い車両10を代表ノードN1にすることで、通信経路全体としての通信安定性を高めることができる。 In addition, in an embodiment, the control unit 505 determines, from among the multiple available vehicles 10, a vehicle 10 whose communication stability with the management server 50 exceeds a threshold value as the "vehicle 10 to function as the representative node N1," and determines, from among the multiple available vehicles 10, a vehicle 10 that can communicate with the representative node N1 as the "vehicle 10 to function as the calculation node N2." With this configuration, the control unit 505 (management side) determines the representative node N1 and calculation node N2 in advance, making it possible to determine a "communication route via the communication network 5" and a "communication route that does not go through the communication network 5." Then, by designating a vehicle 10 with high communication stability with the management server 50 as the representative node N1, it is possible to improve the communication stability of the entire communication route.
また、実施形態では、制御部505は、ジョブデータD1を分割することにより得られる複数の部分ジョブデータの各々に対し、その部分ジョブデータを処理させる計算ノードN2を決定する。このような構成により、制御部505(管理側)が計算ノードN2に割り当てる部分ジョブデータを予め決定することで、制御部505(管理側)が各通信経路における通信量を制御することができる。 In addition, in an embodiment, the control unit 505 determines the computation node N2 that will process each of the multiple partial job data obtained by dividing the job data D1. With this configuration, the control unit 505 (management side) determines in advance the partial job data to be assigned to the computation node N2, allowing the control unit 505 (management side) to control the communication volume on each communication path.
また、実施形態では、制御部505は、グリッドコンピューティング処理において、代表ノードN1に対して、複数の部分ジョブデータのうちその代表ノードN1に対応する計算ノードN2に処理させる部分ジョブデータと、その部分ジョブデータを処理させる計算ノードN2を示す送信先情報とを送信する。このような構成により、どの部分ジョブデータをどの計算ノードN2に送信するのかを、代表ノードN1に適切に指示することができる。 Furthermore, in an embodiment, in grid computing processing, the control unit 505 transmits to the representative node N1 partial job data to be processed by the computation node N2 corresponding to the representative node N1, among multiple partial job data, and transmission destination information indicating the computation node N2 to process the partial job data. With this configuration, it is possible to appropriately instruct the representative node N1 which partial job data to send to which computation node N2.
また、実施形態では、代表ノードN1は、グリッドコンピューティング処理において、制御部505から送信された部分ジョブデータを、送信先情報に示されたその部分ジョブデータを処理させる計算ノードN2に送信する。このような構成により、代表ノードN1から計算ノードN2に部分ジョブデータを適切に送信することができる。 Furthermore, in an embodiment, in grid computing processing, the representative node N1 transmits partial job data transmitted from the control unit 505 to the calculation node N2 that is to process the partial job data, as indicated in the destination information. With this configuration, partial job data can be appropriately transmitted from the representative node N1 to the calculation node N2.
(実施形態の変形例1)
図15に示すように、計算ノードN2(非代表ノードの一例)は、代表ノードN1を基準とする通信可能範囲R1内に位置する車両10であってもよい。
(First Modification of the Embodiment)
As shown in FIG. 15, a calculation node N2 (an example of a non-representative node) may be a vehicle 10 located within a communication range R1 based on the representative node N1.
〔グリッドコンピューティング処理〕
実施形態の変形例1のグリッドコンピューティング処理において、管理サーバ50の制御部505は、複数の利用可能な車両10のうち、管理サーバ50との間の通信安定度が予め定められた閾値を上回る車両10が「代表ノードN1」として機能し、複数の利用可能な車両10のうち、代表ノードN1を除く他の車両10であり且つ代表ノードN1を基準とする通信可能範囲R1内に位置する車両10が「計算ノードN2」として機能するように、複数の利用可能な車両10を制御する。
[Grid Computing Processing]
In the grid computing process of the first variant of the embodiment, the control unit 505 of the management server 50 controls the multiple available vehicles 10 so that, among the multiple available vehicles 10, a vehicle 10 whose communication stability with the management server 50 exceeds a predetermined threshold functions as a "representative node N1," and the other vehicles 10 among the multiple available vehicles 10 other than the representative node N1 and located within the communication range R1 based on the representative node N1 function as a "computation node N2."
〔マッチング処理〕
実施形態の変形例1のマッチング処理において、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において代表ノードN1と通信可能な車両10を選出する。次に、制御部505は、位置予測テーブルD55を参照し、その選出された車両10の中から、グリッドコンピューティング処理が行われる期間において代表ノードN1を基準とする通信可能範囲R1内に位置する車両10を「計算ノードN2の候補」として選出する。次に、実施形態と同様に、制御部505は、計算ノードN2の候補として選出された車両10の中から「計算ノードN2として機能させる車両10」を決定する。
[Matching process]
In the matching process of the first modified example of the embodiment, the control unit 505 refers to the communication prediction table D57 and selects, from among a plurality of available vehicles 10, vehicles 10 that can communicate with the representative node N1 during the period in which the grid computing process is performed. Next, the control unit 505 refers to the position prediction table D55 and selects, from among the selected vehicles 10, vehicles 10 that are located within a communication range R1 based on the representative node N1 during the period in which the grid computing process is performed, as "candidates for the computation node N2." Next, as in the embodiment, the control unit 505 determines, from among the vehicles 10 selected as candidates for the computation node N2, a "vehicle 10 to function as the computation node N2."
または、実施形態の変形例1のマッチング処理において、制御部505は、通信予測テーブルD57と位置予測テーブルD55を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において管理サーバ50との間の通信安定度が閾値を上回る車両10であり、且つ、その車両10を基準とする通信可能範囲R1内に位置する車両10の数が予め定められた下限数を上回る車両10を「代表ノードN1の候補」として選出する。次に、制御部505は、代表ノードN1の候補として選出された車両10の中から「代表ノードN1として機能させる車両10」を決定する。次に、実施形態と同様に、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から「計算ノードN2として機能させる車両10」を決定する。 Alternatively, in the matching process of the first modified embodiment, the control unit 505 references the communication prediction table D57 and the position prediction table D55, and selects, from among the multiple available vehicles 10, vehicles 10 whose communication stability with the management server 50 exceeds a threshold value during the period in which grid computing processing is performed, and for which the number of vehicles 10 located within a communication range R1 based on that vehicle 10 exceeds a predetermined lower limit, as "candidates for representative node N1." Next, the control unit 505 determines, from among the vehicles 10 selected as candidates for representative node N1, a "vehicle 10 to function as representative node N1." Next, as in the embodiment, the control unit 505 references the communication prediction table D57, and selects, from among the multiple available vehicles 10, a "vehicle 10 to function as computation node N2."
〔通信可能範囲〕
通信可能範囲R1は、代表ノードN1と計算ノードN2(非代表ノードの一例)とが通信可能となり得る範囲である。この例では、通信可能範囲R1は、車両10が通信網5を経由せずに代表ノードN1と直接的に通信することができる範囲であり、具体的には、車両10が代表ノードN1と車車間通信を行うことができる範囲である。例えば、通信可能範囲R1は、代表ノードN1となる車両10を中心とする円形状の範囲であってもよい。
[Communication range]
The communication range R1 is the range in which the representative node N1 and the computation node N2 (an example of a non-representative node) can communicate. In this example, the communication range R1 is the range in which the vehicle 10 can communicate directly with the representative node N1 without going through the communication network 5, and more specifically, is the range in which the vehicle 10 can perform vehicle-to-vehicle communication with the representative node N1. For example, the communication range R1 may be a circular range centered on the vehicle 10 that is the representative node N1.
また、通信可能範囲R1は、代表ノードN1と計算ノードN2(非代表ノードの一例)との間の通信安定度が予め定められた閾値を上回る範囲であってもよい。通信可能範囲R1に関する閾値は、代表ノードN1となる車両10の選出の際に基準となる閾値と同じ値であってもよいし、異なる値であってもよい。 Furthermore, the communication range R1 may be a range in which the communication stability between the representative node N1 and the calculation node N2 (an example of a non-representative node) exceeds a predetermined threshold. The threshold for the communication range R1 may be the same as the threshold used as the reference when selecting the vehicle 10 that will become the representative node N1, or it may be a different value.
また、通信可能範囲R1は、代表ノードN1となる車両10の通信性能に応じて設定されてもよい。例えば、代表ノードN1となる車両10の通信性能が高くなるほど、その車両10を基準とする通信可能範囲R1が広くなる。 The communication range R1 may also be set according to the communication performance of the vehicle 10 that will be the representative node N1. For example, the higher the communication performance of the vehicle 10 that will be the representative node N1, the wider the communication range R1 based on that vehicle 10.
なお、通信可能範囲R1は、車両10が代表ノードN1から送信された確認信号(例えばPING信号)に応答して返信信号を代表ノードN1に送信することができる範囲であるといえる。また、代表ノードN1は、返信信号とともに車両10に関する情報(例えば車両状態情報D13、位置管理情報D16、稼働管理情報D17、通信管理情報D18など)を車両10に返送させてもよい。また、代表ノードN1は、返信信号を受信した後に、その返信信号を送信した車両10との通信における通信帯域を測定するためにバーストデータを送信してもよい。 The communication range R1 can be said to be the range within which the vehicle 10 can transmit a reply signal to the representative node N1 in response to a confirmation signal (e.g., a PING signal) transmitted from the representative node N1. The representative node N1 may also cause the vehicle 10 to transmit information regarding the vehicle 10 (e.g., vehicle status information D13, location management information D16, operation management information D17, communication management information D18, etc.) along with the reply signal. After receiving the reply signal, the representative node N1 may also transmit burst data to measure the communication bandwidth for communication with the vehicle 10 that transmitted the reply signal.
また、通信可能範囲R1は、代表ノードN1の周辺に存在する障害物に応じて変化してもよい。障害物の例としては、電波を遮る遮蔽物(例えばビル)、ノイズを発生する建設物(例えば電波塔)などが挙げられる。例えば、代表ノードN1から見て障害物の後方のエリアにおいて、障害物がない場合よりも、通信可能範囲R1が狭くなる(通信可能範囲R1の外縁が代表ノードN1に近くなる)ようにしてもよい。 The communication range R1 may also change depending on obstacles present around the representative node N1. Examples of obstacles include objects that block radio waves (e.g., buildings) and structures that generate noise (e.g., radio towers). For example, in an area behind an obstacle as viewed from the representative node N1, the communication range R1 may be narrower than when there is no obstacle (the outer edge of the communication range R1 may be closer to the representative node N1).
〔代表ノードと非代表ノードとの間の通信安定度〕
なお、代表ノードN1と計算ノードN2(非代表ノードの一例)との間の通信状態は、代表ノードN1と計算ノードN2との間の距離に応じて変化し得る。例えば、代表ノードN1と計算ノードN2との間の距離を除く他の通信環境条件が同一である場合、代表ノードN1と計算ノードN2との間の距離が長くなるほど、代表ノードN1と計算ノードN2との間の通信安定度が低くなる。
[Communication stability between representative node and non-representative node]
Furthermore, the communication state between the representative node N1 and the computation node N2 (an example of a non-representative node) can change depending on the distance between the representative node N1 and the computation node N2. For example, if the communication environment conditions other than the distance between the representative node N1 and the computation node N2 are the same, the longer the distance between the representative node N1 and the computation node N2, the lower the communication stability between the representative node N1 and the computation node N2.
〔実施形態の変形例1の効果〕
実施形態の変形例1では、実施形態の効果と同様の効果を得ることができる。
[Effects of Modification 1 of the Embodiment]
In the first modification of the embodiment, the same effects as those of the embodiment can be obtained.
また、実施形態の変形例1では、代表ノードN1を基準とする通信可能範囲R1内に位置する車両10を「計算ノードN2(非代表ノードの一例)」とすることにより、代表ノードN1と計算ノードN2との間の距離を制限することができる。これにより、代表ノードN1と計算ノードN2との間の通信安定性を確保することができる。 Furthermore, in the first modified embodiment, by designating a vehicle 10 located within the communication range R1 based on the representative node N1 as a "computation node N2 (an example of a non-representative node)," it is possible to limit the distance between the representative node N1 and the computation node N2. This makes it possible to ensure communication stability between the representative node N1 and the computation node N2.
このように、管理サーバ50と代表ノードN1との間の通信安定性に加えて、代表ノードN1と計算ノードN2(非代表ノードの一例)との間の通信安定性を確保することができるので、通信不良による不具合(例えばデータ伝送の長時間化など)の発生をさらに低減することができる。これにより、グリッドコンピューティング処理のパフォーマンスをさらに向上させることができる。 In this way, in addition to ensuring communication stability between the management server 50 and the representative node N1, it is also possible to ensure communication stability between the representative node N1 and the calculation node N2 (an example of a non-representative node), thereby further reducing the occurrence of problems caused by poor communication (such as prolonged data transmission times). This further improves the performance of grid computing processing.
(実施形態の変形例2)
図16に示すように、非代表ノードとして、計算ノードN2の他に、中継ノードN3、ストレージノードN4が設定されてよい。
(Modification 2 of the embodiment)
As shown in FIG. 16, in addition to the calculation node N2, a relay node N3 and a storage node N4 may be set as non-representative nodes.
〔グリッドコンピューティング処理の特徴〕
実施形態の変形例2のグリッドコンピューティング処理において、管理サーバ50の制御部505は、中継ノードN3が中継ノードN3に送信されたジョブデータを非代表ノード(例えば計算ノードN2)に送信するように、中継ノードN3を制御する。また、制御部505は、中継ノードN3が中継ノードN3に送信された計算結果データを代表ノードN1に送信するように、中継ノードN3を制御する。
[Characteristics of grid computing processing]
In the grid computing process of the second modification of the embodiment, the control unit 505 of the management server 50 controls the relay node N3 so that the relay node N3 transmits the job data transmitted to the relay node N3 to a non-representative node (for example, the calculation node N2). The control unit 505 also controls the relay node N3 so that the relay node N3 transmits the calculation result data transmitted to the relay node N3 to the representative node N1.
なお、代表ノードN1と中継ノードN3は、通信網5を経由せずに直接的に通信する。この例では、代表ノードN1と中継ノードN3の通信は、車車間通信(V2V)である。 Note that representative node N1 and relay node N3 communicate directly without going through communication network 5. In this example, communication between representative node N1 and relay node N3 is vehicle-to-vehicle communication (V2V).
また、中継ノードN3から送信されたジョブデータを処理する別の中継ノードN3が設けられてもよい。中継ノードN3と別の中継ノードN3の通信は、代表ノードN1と中継ノードN3の通信と同様である。 In addition, another relay node N3 may be provided to process job data transmitted from the relay node N3. Communication between the relay node N3 and the other relay node N3 is similar to communication between the representative node N1 and the relay node N3.
実施形態の変形例2のグリッドコンピューティング処理において、制御部505は、ストレージノードN4に送信されたデータをストレージノードN4に記憶させる。ストレージノードN4に送信されるデータの例としては、部分計算結果データ(計算結果データD2の一部)、部分ジョブデータ(ジョブデータD1の一部)の計算途中の結果を示す部分途中結果データ、計算ノードN2に送信することが予約された部分ジョブデータなどが挙げられる。 In the grid computing process of the second variation of the embodiment, the control unit 505 stores data transmitted to storage node N4 in storage node N4. Examples of data transmitted to storage node N4 include partial calculation result data (part of calculation result data D2), partial interim result data indicating the results of partial job data (part of job data D1), and partial job data scheduled to be transmitted to calculation node N2.
なお、中継ノードN3とストレージノードN4は、通信網5を経由せずに直接的に通信する。この例では、中継ノードN3とストレージノードN4の通信は、車車間通信(V2V)である。 Note that relay node N3 and storage node N4 communicate directly without going through communication network 5. In this example, communication between relay node N3 and storage node N4 is vehicle-to-vehicle communication (V2V).
また、ストレージノードN4は、中継ノードN3となる車両10だけでなく、代表ノードN1となる車両10、計算ノードN2となる車両10,その他の車両10とデータを送受信してもよい。これらの車両10とストレージノードN4の通信は、中継ノードN3とストレージノードN4の通信と同様である。 In addition, storage node N4 may send and receive data not only with vehicle 10 that serves as relay node N3, but also with vehicle 10 that serves as representative node N1, vehicle 10 that serves as calculation node N2, and other vehicles 10. Communication between these vehicles 10 and storage node N4 is similar to communication between relay node N3 and storage node N4.
〔マッチング処理の詳細〕
実施形態の変形例2のマッチング処理において、管理サーバ50の制御部505は、複数の利用可能な車両10の中から「代表ノードN1として機能させる車両10」と「計算ノードN2として機能させる車両10」と「中継ノードN3として機能させる車両10」と「ストレージノードN4として機能させる車両10」とを決定し、その決定の結果をジョブデータD1に関連付けてマッチングテーブルD58に登録する。
[Matching process details]
In the matching process of the second variant of the embodiment, the control unit 505 of the management server 50 determines from among the multiple available vehicles 10, a "vehicle 10 to function as the representative node N1," a "vehicle 10 to function as the calculation node N2," a "vehicle 10 to function as the relay node N3," and a "vehicle 10 to function as the storage node N4," and associates the results of the determination with the job data D1 and registers them in the matching table D58.
具体的には、実施形態の変形例1と同様に、制御部505は、複数の利用可能な車両10の中から「代表ノードN1として機能させる車両10」を決定する。 Specifically, as in the first variant of the embodiment, the control unit 505 determines the "vehicle 10 to function as the representative node N1" from among multiple available vehicles 10.
次に、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において代表ノードN1と通信可能な車両10を「中継ノードN3の候補」として選出する。次に、制御部505は、中継ノードN3の候補として選出された車両10の中から「中継ノードN3として機能させる車両10」を決定する。 Next, the control unit 505 refers to the communication prediction table D57 and selects, from among the multiple available vehicles 10, vehicles 10 that can communicate with the representative node N1 during the period in which grid computing processing is performed, as "candidates for relay node N3." Next, the control unit 505 determines, from among the vehicles 10 selected as candidates for relay node N3, the "vehicle 10 to function as relay node N3."
次に、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において代表ノードN1または中継ノードN3と通信可能な車両10を「計算ノードN2の候補」として選出する。次に、実施形態と同様に、制御部505は、計算ノードN2の候補として選出された車両10の中から「計算ノードN2として機能させる車両10」を決定する。 Next, the control unit 505 refers to the communication prediction table D57 and selects, from among the multiple available vehicles 10, vehicles 10 that can communicate with the representative node N1 or relay node N3 during the period in which grid computing processing is performed, as "candidates for computation node N2." Next, as in the embodiment, the control unit 505 determines, from among the vehicles 10 selected as candidates for computation node N2, a "vehicle 10 to function as computation node N2."
また、制御部505は、通信予測テーブルD57を参照し、複数の利用可能な車両10の中から、グリッドコンピューティング処理が行われる期間において利用される車両10(代表ノードN1と計算ノードN2と中継ノードN3)の少なくとも1つと通信可能な車両10を「ストレージノードN4の候補」として選出する。次に、制御部505は、ストレージノードN4の候補として選出された車両10の中から「ストレージノードN4として機能させる車両10」を決定する。 The control unit 505 also references the communication prediction table D57 and selects, from among the multiple available vehicles 10, vehicles 10 that can communicate with at least one of the vehicles 10 (representative node N1, calculation node N2, and relay node N3) that will be used during the period in which grid computing processing is performed, as "candidates for storage node N4." Next, the control unit 505 determines, from among the vehicles 10 selected as candidates for storage node N4, the "vehicle 10 to function as storage node N4."
次に、制御部505は、上記の決定の結果に基づいて、「代表ノードN1として機能させる車両10」と「計算ノードN2として機能させる車両10」と「中継ノードN3として機能させる車両10」と「ストレージノードN4として機能させる車両10」を特定するためのノード情報と、代表ノードN1と計算ノードN2と中継ノードN3とストレージノードN4との対応関係を示すリンク情報とを生成する。 Next, based on the results of the above determination, the control unit 505 generates node information for identifying the "vehicle 10 to function as the representative node N1," the "vehicle 10 to function as the calculation node N2," the "vehicle 10 to function as the relay node N3," and the "vehicle 10 to function as the storage node N4," as well as link information indicating the correspondence between the representative node N1, the calculation node N2, the relay node N3, and the storage node N4.
次に、実施形態と同様に、制御部505は、ジョブデータD1を分割することにより得られる複数の部分ジョブデータの各々に対して、その部分ジョブデータを処理させる計算ノードN2を決定し、計算ノードN2と部分ジョブデータとの対応関係を示す担当情報を生成する。 Next, as in the embodiment, the control unit 505 determines the computation node N2 that will process each of the multiple partial job data obtained by dividing the job data D1, and generates assignment information that indicates the correspondence between the computation node N2 and the partial job data.
次に、実施形態と同様に、制御部505は、ノード情報とリンク情報と担当情報とをジョブデータD1に関連付けてマッチングテーブルD58に登録する。 Next, as in the embodiment, the control unit 505 associates the node information, link information, and responsibility information with the job data D1 and registers them in the matching table D58.
〔グリッドコンピューティング処理の詳細〕
実施形態の変形例2のグリッドコンピューティング処理は、代表ノードN1に関する処理が実施形態のグリッドコンピューティング処理と異なる。また、実施形態の変形例2のグリッドコンピューティング処理では、実施形態のグリッドコンピューティング処理に加えて、中継ノードN3およびストレージノードN4に関する処理が行われる。実施形態の変形例2のグリッドコンピューティング処理のその他の処理は、実施形態のグリッドコンピューティング処理と同様である。
[Details of grid computing processing]
The grid computing processing of the second modification of the embodiment differs from the grid computing processing of the embodiment in the processing related to the representative node N1. Furthermore, in the grid computing processing of the second modification of the embodiment, in addition to the grid computing processing of the embodiment, processing related to the relay node N3 and the storage node N4 is performed. Other processing of the grid computing processing of the second modification of the embodiment is similar to the grid computing processing of the embodiment.
実施形態の変形例2のグリッドコンピューティング処理では、管理サーバ50から代表ノードN1を経由して「中継ノードN3として機能させようとする車両10」に中継指令が送信される。中継指令は、車両10を中継ノードN3として機能させるための指令である。中継指令には、車両10を中継ノードN3として機能させるためのプログラムおよび情報が含まれてもよい。中継指令を受信した車両10は、その中継指令に応答して「中継ノードN3」として機能する。 In the grid computing process of the second variant of the embodiment, a relay command is sent from the management server 50 to the "vehicle 10 to be made to function as a relay node N3" via the representative node N1. The relay command is a command to make the vehicle 10 function as a relay node N3. The relay command may include a program and information to make the vehicle 10 function as a relay node N3. The vehicle 10 that receives the relay command functions as the "relay node N3" in response to the relay command.
同様に、管理サーバ50から代表ノードN1などを経由して「ストレージノードN4として機能させようとする車両10」にストレージ指令が送信される。ストレージ指令は、車両10をストレージノードN4として機能させるための指令である。ストレージ指令には、車両10をストレージノードN4として機能させるためのプログラムおよび情報が含まれてもよい。ストレージ指令を受信した車両10は、そのストレージ指令に応答して「ストレージノードN4」として機能する。 Similarly, a storage command is sent from the management server 50 to the "vehicle 10 that is to function as storage node N4" via the representative node N1, etc. The storage command is a command to cause the vehicle 10 to function as storage node N4. The storage command may include a program and information to cause the vehicle 10 to function as storage node N4. The vehicle 10 that receives the storage command functions as "storage node N4" in response to the storage command.
また、代表ノードN1は、中継ノードN3に対し、その代表ノードN1に送信された部分ジョブデータのうちその中継ノードN3に対応する計算ノードN2に処理させる部分ジョブデータと、その部分ジョブデータを処理させる計算ノードN2を示す中継先情報とを送信する。なお、中継先情報は、代表ノードN1により生成されてもよいし、制御部505により生成されて代表ノードN1に送信されてもよい。 Furthermore, the representative node N1 transmits to the relay node N3 the partial job data transmitted to the representative node N1 that is to be processed by the calculation node N2 corresponding to the relay node N3, and relay destination information indicating the calculation node N2 that is to process the partial job data. Note that the relay destination information may be generated by the representative node N1, or may be generated by the control unit 505 and transmitted to the representative node N1.
次に、中継ノードN3は、代表ノードN1から送信された部分ジョブデータと中継先情報を受信する。そして、中継ノードN3は、中継先情報を参照し、部分ジョブデータを、その部分ジョブデータに対応する計算ノードN2に送信する。具体的には、中継ノードN3は、部分ジョブデータを、中継先情報に示された「その部分ジョブデータを処理させる計算ノードN2」に送信する。 Next, relay node N3 receives the partial job data and relay destination information sent from representative node N1. Then, relay node N3 references the relay destination information and sends the partial job data to the calculation node N2 that corresponds to that partial job data. Specifically, relay node N3 sends the partial job data to the "calculation node N2 that will process that partial job data" indicated in the relay destination information.
中継ノードN3に対応する計算ノードN2は、中継ノードN3から送信された部分ジョブデータを受信し、その部分ジョブデータを計算し、その計算結果を示す部分計算結果データを中継ノードN3に送信する。中継ノードN3は、計算ノードN2から送信された部分計算結果データを受信し、部分計算結果データを代表ノードN1に送信する。代表ノードN1は、中継ノードN3から送信された部分計算結果データを受信し、その部分計算結果データを管理サーバ50に送信する。 The calculation node N2 corresponding to the relay node N3 receives the partial job data sent from the relay node N3, calculates the partial job data, and sends partial calculation result data indicating the calculation results to the relay node N3. The relay node N3 receives the partial calculation result data sent from the calculation node N2 and sends the partial calculation result data to the representative node N1. The representative node N1 receives the partial calculation result data sent from the relay node N3 and sends the partial calculation result data to the management server 50.
ストレージノードN4は、他の車両10(図15の例では中継ノードN3)からストレージノードN4に送信されたデータを記憶する。そして、ストレージノードN4は、他の車両10からのデータの送信要求に応答して、ストレージノードN4に記憶されているデータを他の車両10に送信する。 Storage node N4 stores data transmitted to storage node N4 from another vehicle 10 (relay node N3 in the example of Figure 15). Then, in response to a data transmission request from another vehicle 10, storage node N4 transmits the data stored in storage node N4 to the other vehicle 10.
〔実施形態の変形例2の効果〕
実施形態の変形例2では、実施形態と同様の効果を得ることができる。
[Effects of Modification 2 of the Embodiment]
In the second modification of the embodiment, the same effects as those of the embodiment can be obtained.
また、実施形態の変形例2では、中継ノードN3を経由して代表ノードN1と複数の非代表ノード(図16の例では計算ノードN2およびストレージノードN4)とが間接的に通信する。このような構成により、中継ノードN3を経由せずに代表ノードN1と複数の非代表ノードとが直接的に通信する場合(すなわち代表ノードN1に通信が集中する場合)よりも、代表ノードN1の通信負荷を低減することができる。 Furthermore, in a second variant of the embodiment, the representative node N1 and multiple non-representative nodes (computation node N2 and storage node N4 in the example of FIG. 16) communicate indirectly via relay node N3. With this configuration, the communication load on the representative node N1 can be reduced compared to when the representative node N1 and multiple non-representative nodes communicate directly without going through relay node N3 (i.e., when communication is concentrated on the representative node N1).
また、実施形態の変形例2では、代表ノードN1と計算ノードN2(非代表ノードの一例)とが直接的に通信することが困難である場合であっても、代表ノードN1と中継ノードN3とが通信可能であり、且つ、中継ノードN3と計算ノードN2とが通信可能であれば、代表ノードN1から中継ノードN3を経由して計算ノードN2にジョブデータを送信することができる。このように、グリッドコンピューティング処理において、代表ノードN1と直接的に通信することが困難である車両10を有効に利用することができる。 Furthermore, in the second modification of the embodiment, even if it is difficult for the representative node N1 and the calculation node N2 (an example of a non-representative node) to communicate directly, if the representative node N1 and the relay node N3 can communicate and the relay node N3 and the calculation node N2 can communicate, job data can be sent from the representative node N1 to the calculation node N2 via the relay node N3. In this way, in grid computing processing, it is possible to effectively utilize vehicles 10 that have difficulty communicating directly with the representative node N1.
また、実施形態の変形例2では、ストレージノードN4を設けることにより、グリッドコンピューティング処理に関するデータをストレージノードN4に一時的に記憶することができる。 Furthermore, in the second variant of the embodiment, by providing storage node N4, data related to grid computing processing can be temporarily stored in storage node N4.
(実施形態の変形例3)
図17に示すように、複数の代表ノードN1が設けられてもよい。
(Modification 3 of the embodiment)
As shown in FIG. 17, multiple representative nodes N1 may be provided.
実施形態の変形例3のグリッドコンピューティング処理において、管理サーバ50の制御部505は、ジョブデータD1を複数(図17の例では2つ)の部分ジョブデータに分割し、その複数の部分ジョブデータを複数(図17の例では2つ)の代表ノードN1にそれぞれ送信する。 In the grid computing process of the third variant of the embodiment, the control unit 505 of the management server 50 divides the job data D1 into multiple (two in the example of FIG. 17) partial job data and transmits the multiple partial job data to multiple (two in the example of FIG. 17) representative nodes N1, respectively.
そして、制御部505は、複数の代表ノードN1の各々から管理サーバ50に送信された部分計算結果データを統合することで計算結果データD2を生成する。 The control unit 505 then generates calculation result data D2 by integrating the partial calculation result data sent to the management server 50 from each of the multiple representative nodes N1.
〔実施形態の変形例3〕
実施形態の変形例3では、実施形態と同様の効果を得ることができる。
[Modification 3 of the embodiment]
In the third modification of the embodiment, the same effects as those of the embodiment can be obtained.
また、実施形態の変形例3では、複数の代表ノードN1を設けることにより、代表ノードN1が1つだけしか設けられない場合よりも、代表ノードN1の1つ当たりの通信負荷を低減することができる。 Furthermore, in the third variant of the embodiment, by providing multiple representative nodes N1, the communication load per representative node N1 can be reduced compared to when only one representative node N1 is provided.
(マッチング処理の変形例)
以上の説明において、図12に示したマッチング処理の代わりに、図18に示したマッチング処理が行われてもよい。この変形例では、管理サーバ50の制御部505は、以下の処理を適宜(例えば定期的に)行う。
(Modification of Matching Process)
In the above description, the matching process shown in Fig. 18 may be performed instead of the matching process shown in Fig. 12. In this modification, the control unit 505 of the management server 50 performs the following process as appropriate (for example, periodically).
なお、以下の説明では、同一期間において、通信可能であり、且つ、グリッドコンピューティング処理に計算能力を提供することができる複数の車両10の組合せを「グリッド群」と記載する。 In the following description, a combination of multiple vehicles 10 that are capable of communicating and providing computing power for grid computing processing during the same period will be referred to as a "grid group."
〈ステップS55〉
まず、制御部505は、「能力予測テーブルD56に登録された複数の車両10の各々のグリッドコンピューティング処理において利用可能な計算能力の時間的変化の予測結果」と「通信予測テーブルD57に登録された複数の車両10の各々の通信状態の時間的変化の予測結果」とに基づいて、複数のグリッド群を準備する。
<Step S55>
First, the control unit 505 prepares multiple grid groups based on the ``prediction results of the temporal changes in the computing capacity available for grid computing processing of each of the multiple vehicles 10 registered in the capacity prediction table D56'' and the ``prediction results of the temporal changes in the communication status of each of the multiple vehicles 10 registered in the communication prediction table D57.''
複数のグリッド群の各々は、「グリッドコンピューティング処理に計算能力を提供することができる期間」および「グリッドコンピューティング処理に提供することができる計算能力の合計」の少なくとも一方が異なる。 Each of the multiple grid groups differs in at least one of the "period during which computing power can be provided to grid computing processes" and the "total amount of computing power that can be provided to grid computing processes."
〈ステップS56〉
次に、制御部505は、ジョブテーブルD54に登録されたジョブの中からマッチング処理の対象となるジョブを選択する。そして、制御部505は、記憶部504に記憶されたジョブデータD1の中からマッチング処理の対象となるジョブに対応するジョブデータD1を選択する。
<Step S56>
Next, the control unit 505 selects a job to be subjected to the matching process from among the jobs registered in the job table D54. Then, the control unit 505 selects job data D1 corresponding to the job to be subjected to the matching process from among the job data D1 stored in the storage unit 504.
〈ステップS57〉
次に、制御部505は、複数のグリッド群の中から、ステップS56において選択されたジョブデータD1に対するグリッドコンピューティング処理において利用するグリッド群を選択する。
<Step S57>
Next, the control unit 505 selects, from the plurality of grid groups, a grid group to be used in the grid computing process for the job data D1 selected in step S56.
具体的には、制御部505は、ジョブデータD1に対するグリッドコンピューティング処理が実行される計算予定期間を決定し、複数のグリッド群の中から計算予定期間において利用可能なグリッド群を選択する。そして、制御部505は、「グリッドコンピューティング処理に提供される計算能力の合計」が「グリッドコンピューティング処理においてジョブデータD1の計算に必要とされる計算能力」以上となるように、計算予定期間において利用可能なグリッド群の中から、そのジョブデータD1に割り当てられるグリッド群を選択する。 Specifically, the control unit 505 determines a planned calculation period during which grid computing processing for job data D1 will be executed, and selects a grid group that can be used during the planned calculation period from among multiple grid groups. The control unit 505 then selects a grid group to be assigned to job data D1 from among the grid groups that can be used during the planned calculation period so that the "total computing capacity provided to the grid computing processing" is equal to or greater than the "computing capacity required for computing job data D1 in the grid computing processing."
次に、制御部505は、複数のグリッド群の中から選択されたグリッドを、ステップS56において選択されたジョブデータD1に割り当てる。そして、制御部505は、どのジョブデータD1にどの車両10が割り当てられたのかを示すマッチング結果情報をマッチングテーブルD58に登録する。 Next, the control unit 505 assigns a grid selected from the plurality of grid groups to the job data D1 selected in step S56. The control unit 505 then registers matching result information indicating which vehicle 10 is assigned to which job data D1 in the matching table D58.
(その他の実施形態)
以上の説明では、管理サーバ50から代表ノードN1にジョブデータD1(またはジョブデータD1の一部)が送信される場合を例に挙げたが、これに限定されない。例えば、
管理サーバ50から代表ノードN1にジョブデータD1の一部が送信されるとともに、管理サーバ50から代表ノードN1を経由せずに「代表ノードN1ではない他の車両10(例えば計算ノードN2やストレージノードN4など)」にジョブデータD1の別の一部が送信されてもよい。
(Other embodiments)
In the above explanation, an example has been given in which job data D1 (or a part of job data D1) is transmitted from management server 50 to representative node N1, but the present invention is not limited to this. For example,
A portion of the job data D1 may be sent from the management server 50 to the representative node N1, and another portion of the job data D1 may be sent from the management server 50 to "another vehicle 10 that is not the representative node N1 (for example, a calculation node N2 or a storage node N4)" without going through the representative node N1.
また、以上の説明では、管理サーバ50の制御部505が位置予測処理を行う場合を例に挙げたが、これに限定されない。例えば、位置予測処理は、車両10の演算装置105により行われてもよい。この場合、演算装置105は、位置予測処理により得られた位置予測情報D5を管理サーバ50に送信してもよい。管理サーバ50の制御部505は、車両10から送信された位置予測情報D5を位置予測テーブルD55に登録(上書き)することで位置予測テーブルD55を更新してもよい。稼働予測処理および通信予測処理についても同様である。 Furthermore, while the above explanation has been given as an example in which the control unit 505 of the management server 50 performs the position prediction process, this is not limiting. For example, the position prediction process may be performed by the calculation device 105 of the vehicle 10. In this case, the calculation device 105 may transmit position prediction information D5 obtained by the position prediction process to the management server 50. The control unit 505 of the management server 50 may update the position prediction table D55 by registering (overwriting) the position prediction information D5 transmitted from the vehicle 10 in the position prediction table D55. The same applies to the operation prediction process and the communication prediction process.
また、以上の説明では、制御部505が単一の管理サーバ50に集約される場合を例に挙げたが、これに限定されない。例えば、制御部505は、通信網5を経由して互いに通信する複数の管理サーバ50(図示省略)に分散されてもよい。 Furthermore, while the above description has been given of an example in which the control unit 505 is consolidated into a single management server 50, this is not limiting. For example, the control unit 505 may be distributed across multiple management servers 50 (not shown) that communicate with each other via the communication network 5.
また、以上の説明において、記憶部504は、単一の記憶装置により構成されてもよいし、複数の記憶装置により構成されてもよい。複数の記憶装置は、単一の管理サーバ50に集約されてもよいし、通信網5を経由して互いに通信する複数の管理サーバ50(図示省略)に分散されてもよい。 Furthermore, in the above description, the memory unit 504 may be configured as a single storage device or as multiple storage devices. The multiple storage devices may be consolidated into a single management server 50, or may be distributed across multiple management servers 50 (not shown) that communicate with each other via the communication network 5.
また、以上の説明において、制御部505は、単一の制御ユニットにより構成されてもよいし、複数の制御ユニットにより構成されてもよい。複数の制御ユニットは、単一の管理サーバ50に集約されてもよいし、通信網5を経由して互いに通信する複数の管理サーバ50(図示省略)に分散されてもよい。 Furthermore, in the above description, the control unit 505 may be configured as a single control unit or may be configured as multiple control units. The multiple control units may be consolidated into a single management server 50, or may be distributed across multiple management servers 50 (not shown) that communicate with each other via the communication network 5.
また、以上の説明において、演算装置105は、単一の演算ユニットにより構成されてもよいし、複数の演算ユニットにより構成されてもよい。 Furthermore, in the above description, the arithmetic device 105 may be configured with a single arithmetic unit or multiple arithmetic units.
また、以上の説明では、演算装置105が搭載される移動体の例として、車両10(具体的には自動四輪車)を挙げたが、これに限定されない。演算装置105は、車両10ではない他の移動体に搭載されてもよい。このような移動体の例としては、輸送用機械、携帯情報端末などが挙げられる。輸送用機械の例としては、自動二輪車、鉄道車両、船舶、航空機、ドローンなどが挙げられる。車両は、輸送用機械の一例である。携帯情報端末の例としては、ノート型パーソナルコンピュータ、タブレット、スマートフォンなどが挙げられる。 In the above explanation, a vehicle 10 (specifically, a four-wheeled motor vehicle) has been given as an example of a mobile body on which the computing device 105 is mounted, but this is not limiting. The computing device 105 may also be mounted on a mobile body other than a vehicle 10. Examples of such mobile bodies include transportation machinery and mobile information terminals. Examples of transportation machinery include motorcycles, railroad vehicles, ships, aircraft, and drones. A vehicle is one example of transportation machinery. Examples of mobile information terminals include a notebook personal computer, a tablet, and a smartphone.
また、以上の説明において、グリッドコンピューティング処理に対し、車両10に搭載された演算装置105の計算能力だけでなく、他の演算装置(図示省略)の計算能力も供給されてもよい。このような他の演算装置は、据置型の演算装置(例えばデスクトップ型パーソナルコンピュータ)であってもよい。 Furthermore, in the above description, the grid computing process may be provided with the computing power of not only the computing device 105 installed in the vehicle 10, but also the computing power of another computing device (not shown). Such another computing device may be a stationary computing device (e.g., a desktop personal computer).
また、以上の実施形態を適宜組み合わせて実施してもよい。以上の実施形態は、本質的に好ましい例示であって、ここに開示する技術、その適用物、あるいはその用途の範囲を制限することを意図するものではない。 The above embodiments may also be implemented in appropriate combinations. The above embodiments are essentially preferred examples and are not intended to limit the scope of the technology disclosed herein, its applications, or its uses.
以上説明したように、ここに開示する技術は、グリッドコンピューティングの技術として有用である。 As explained above, the technology disclosed here is useful as grid computing technology.
1 システム
10 車両
105 演算装置
20 ユーザ端末
30 クライアントサーバ
50 管理サーバ
501 入力部
502 出力部
503 通信部
504 記憶部
505 制御部
D1 ジョブデータ
D2 計算結果データ
N1 代表ノード
N2 計算ノード(非代表ノード)
N3 中継ノード(非代表ノード)
N4 ストレージノード(非代表ノード)
1 System 10 Vehicle 105 Computing device 20 User terminal 30 Client server 50 Management server 501 Input unit 502 Output unit 503 Communication unit 504 Storage unit 505 Control unit D1 Job data D2 Calculation result data N1 Representative node N2 Calculation node (non-representative node)
N3 Relay node (non-representative node)
N4 Storage node (non-representative node)
Claims (8)
前記グリッドコンピューティング処理において、前記ジョブデータを前記複数の利用可能な移動体のうち前記管理装置との間の通信安定度が予め定められた閾値を上回る移動体である代表ノードに送信し、前記代表ノードに送信されたジョブデータを前記複数の利用可能な移動体のうち前記代表ノードを除く他の移動体である非代表ノードに送信するように前記代表ノードを制御し、前記非代表ノードに送信されたジョブデータを前記非代表ノードに処理させる制御部を備え、
前記制御部と前記代表ノードは、通信網を経由して通信し、
前記代表ノードと前記非代表ノードは、前記通信網を経由せずに直接的に通信する
ことを特徴とする管理装置。 A management device that manages a grid computing process in which job data is processed by a plurality of available mobile objects among a plurality of mobile objects each having a computing device,
a control unit that, in the grid computing processing, transmits the job data to a representative node that is a mobile body of the plurality of available mobile bodies and that has communication stability with the management device that exceeds a predetermined threshold, controls the representative node to transmit the job data transmitted to the representative node to non-representative nodes that are other mobile bodies of the plurality of available mobile bodies excluding the representative node, and causes the non-representative nodes to process the job data transmitted to the non-representative nodes,
the control unit and the representative node communicate with each other via a communication network,
A management device characterized in that the representative node and the non-representative nodes communicate directly without going through the communication network.
前記制御部は、前記グリッドコンピューティング処理において、前記ジョブデータの計算結果を示す計算結果データを前記代表ノードに送信するように前記非代表ノードを制御し、前記代表ノードに送信された計算結果データを前記管理装置に送信するように前記代表ノードを制御する
ことを特徴とする管理装置。 2. The management device of claim 1,
The control unit controls the non-representative node to send calculation result data indicating the calculation result of the job data to the representative node in the grid computing processing, and controls the representative node to send the calculation result data sent to the representative node to the management device.
前記制御部は、前記複数の利用可能な移動体のうち前記管理装置との間の通信安定度が前記閾値を上回る移動体を、前記代表ノードとして機能させる移動体に決定し、前記複数の利用可能な移動体のうち前記代表ノードと通信可能な移動体を、前記非代表ノードとして機能させる移動体に決定する
ことを特徴とする管理装置。 3. The management device according to claim 1,
The control unit determines a mobile body among the plurality of available mobile bodies whose communication stability with the management device exceeds the threshold value as the mobile body to function as the representative node, and determines a mobile body among the plurality of available mobile bodies that can communicate with the representative node as the mobile body to function as the non-representative node.
前記制御部は、前記ジョブデータを分割することにより得られる複数の部分ジョブデータの各々に対し、当該部分ジョブデータを処理させる前記非代表ノードを決定する
ことを特徴とする管理装置。 4. The management device of claim 3,
The management device is characterized in that the control unit determines, for each of a plurality of partial job data obtained by dividing the job data, the non-representative node that is to process the partial job data.
前記制御部は、前記グリッドコンピューティング処理において、前記代表ノードに対して、前記複数の部分ジョブデータのうち当該代表ノードに対応する前記非代表ノードに処理させる部分ジョブデータと、当該部分ジョブデータを処理させる前記非代表ノードを示す送信先情報とを送信する
ことを特徴とする管理装置。 5. The management device of claim 4,
A management device characterized in that, in the grid computing processing, the control unit transmits to the representative node partial job data from among the plurality of partial job data to be processed by the non-representative node corresponding to the representative node, and destination information indicating the non-representative node to process the partial job data.
前記代表ノードは、前記グリッドコンピューティング処理において、前記制御部から送信された部分ジョブデータを、前記送信先情報に示された当該部分ジョブデータを処理させる前記非代表ノードに送信する
ことを特徴とする管理装置。 6. The management device of claim 5,
A management device characterized in that, in the grid computing processing, the representative node transmits partial job data transmitted from the control unit to the non-representative node that is to process the partial job data indicated in the destination information.
前記非代表ノードは、前記代表ノードを基準とする通信可能範囲内に位置する
ことを特徴とする管理装置。 In any one of claims 1 to 6, the management device
A management device characterized in that the non-representative nodes are located within a communication range based on the representative node.
前記管理装置により、前記ジョブデータを、前記複数の利用可能な移動体のうち前記管理装置との間の通信安定度が予め定められた閾値を上回る移動体である代表ノードに送信し、
前記代表ノードにより、前記代表ノードに送信されたジョブデータを、前記複数の利用可能な移動体のうち前記代表ノードを除く他の移動体である非代表ノードに送信し、
前記非代表ノードにより、前記非代表ノードに送信されたジョブデータを処理し、
前記管理装置と前記代表ノードは、通信網を経由して通信し、
前記代表ノードと前記非代表ノードは、前記通信網を経由せずに直接的に通信する
ことを特徴とする処理方法。 A processing method for causing a plurality of available mobile objects among a plurality of mobile objects each having a computing device to process job data transmitted by a management device, the method comprising:
transmitting the job data by the management device to a representative node that is a mobile object among the plurality of available mobile objects and whose communication stability with the management device exceeds a predetermined threshold;
The representative node transmits the job data transmitted to the representative node to non-representative nodes which are other mobile bodies other than the representative node among the plurality of available mobile bodies,
The non-representative node processes the job data transmitted to the non-representative node;
the management device and the representative node communicate via a communication network,
A processing method characterized in that the representative node and the non-representative node communicate directly without going through the communication network.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2021158380A JP7729149B2 (en) | 2021-09-28 | 2021-09-28 | Management device and processing method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2021158380A JP7729149B2 (en) | 2021-09-28 | 2021-09-28 | Management device and processing method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2023048838A JP2023048838A (en) | 2023-04-07 |
| JP7729149B2 true JP7729149B2 (en) | 2025-08-26 |
Family
ID=85779819
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2021158380A Active JP7729149B2 (en) | 2021-09-28 | 2021-09-28 | Management device and processing method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP7729149B2 (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2002198886A (en) | 2000-12-22 | 2002-07-12 | Nippon Telegr & Teleph Corp <Ntt> | Network lead vehicle group forming communication system |
| JP2005208756A (en) | 2004-01-20 | 2005-08-04 | Sony Corp | Distributed processing system and method, distributed processing program, and data processing apparatus |
| JP2006081163A (en) | 2004-08-13 | 2006-03-23 | Advanced Telecommunication Research Institute International | Wireless device and wireless network system including the same |
| JP2007129521A (en) | 2005-11-04 | 2007-05-24 | Nippon Seiki Co Ltd | On-vehicle data communication device and data communication method |
| US20200128066A1 (en) | 2018-10-19 | 2020-04-23 | Toyota Motor North America, Inc. | Using predictive analytics to determine expected use patterns of vehicles to recapture under-utilized computational resources of vehicles |
-
2021
- 2021-09-28 JP JP2021158380A patent/JP7729149B2/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2002198886A (en) | 2000-12-22 | 2002-07-12 | Nippon Telegr & Teleph Corp <Ntt> | Network lead vehicle group forming communication system |
| JP2005208756A (en) | 2004-01-20 | 2005-08-04 | Sony Corp | Distributed processing system and method, distributed processing program, and data processing apparatus |
| JP2006081163A (en) | 2004-08-13 | 2006-03-23 | Advanced Telecommunication Research Institute International | Wireless device and wireless network system including the same |
| JP2007129521A (en) | 2005-11-04 | 2007-05-24 | Nippon Seiki Co Ltd | On-vehicle data communication device and data communication method |
| US20200128066A1 (en) | 2018-10-19 | 2020-04-23 | Toyota Motor North America, Inc. | Using predictive analytics to determine expected use patterns of vehicles to recapture under-utilized computational resources of vehicles |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2023048838A (en) | 2023-04-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN120883227A (en) | Scheduling systems and methods for distributed and unreliable electric vehicle nodes used for computational workloads. | |
| Baumann et al. | Connected vehicle: Ontology, taxonomy and use cases | |
| JP7729149B2 (en) | Management device and processing method | |
| JP7729150B2 (en) | Management device and processing method | |
| JP7782185B2 (en) | Management device and processing method | |
| JP7786101B2 (en) | Management device and processing method | |
| EP4322080B1 (en) | ADMINISTRATIVE SYSTEM AND ADMINISTRATIVE PROCEDURES | |
| US20240211317A1 (en) | Management system and management method | |
| JP7841244B2 (en) | Control device and processing method | |
| JP7782205B2 (en) | Management device and management method | |
| JP7729178B2 (en) | Management device and management method | |
| JP7760908B2 (en) | Management system, management device, and management method | |
| US20240193004A1 (en) | Management system, and management method | |
| EP4322004B1 (en) | Grid computing management system and management method therefor | |
| EP4322079B1 (en) | Management system, and management method | |
| JP7760856B2 (en) | Management system and management method, and vehicle computing device | |
| JP7786070B2 (en) | Vehicle computing device, vehicle participation estimation method and estimation system | |
| JP7786069B2 (en) | Vehicle computing device and information processing method | |
| JP7746812B2 (en) | Management device and management method | |
| JP2023034411A (en) | Management apparatus and management method |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20240723 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20250530 |
|
| 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: 20250715 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20250728 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 7729149 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |