Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP7794017B2 - Information processing program, information providing program, information processing system, information processing method, and information processing device - Google Patents
[go: Go Back, main page]

JP7794017B2 - Information processing program, information providing program, information processing system, information processing method, and information processing device - Google Patents

Information processing program, information providing program, information processing system, information processing method, and information processing device

Info

Publication number
JP7794017B2
JP7794017B2 JP2022026860A JP2022026860A JP7794017B2 JP 7794017 B2 JP7794017 B2 JP 7794017B2 JP 2022026860 A JP2022026860 A JP 2022026860A JP 2022026860 A JP2022026860 A JP 2022026860A JP 7794017 B2 JP7794017 B2 JP 7794017B2
Authority
JP
Japan
Prior art keywords
information processing
data file
divided data
files
data files
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
Application number
JP2022026860A
Other languages
Japanese (ja)
Other versions
JP2023123032A (en
Inventor
圭介 澤田
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Yokogawa Electric Corp
Original Assignee
Yokogawa Electric Corp
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Yokogawa Electric Corp filed Critical Yokogawa Electric Corp
Priority to JP2022026860A priority Critical patent/JP7794017B2/en
Publication of JP2023123032A publication Critical patent/JP2023123032A/en
Application granted granted Critical
Publication of JP7794017B2 publication Critical patent/JP7794017B2/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Landscapes

  • Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)

Description

本発明は、情報処理プログラム、情報提供プログラム、情報処理システム、情報処理方法および情報処理装置に関する。 The present invention relates to an information processing program, an information provision program, an information processing system, an information processing method, and an information processing device.

従来、防犯カメラが収集した動画ファイルは、防犯カメラと接続されたエッジゲートウェイ等のエッジ(Edge)装置のストレージに任意の単位(例:1分ごと)で動画ファイルが保存されており、クライアント(Client)装置の要求(例:30分、1時間)に応じてエッジ装置が動画ファイルを連結し、クライアント装置へダウンロードを実行している。 Traditionally, video files collected by security cameras are stored in arbitrary units (e.g., every minute) in the storage of an edge device, such as an edge gateway, connected to the security camera. The edge device then concatenates the video files in response to a request from the client device (e.g., 30 minutes, 1 hour), and downloads them to the client device.

特開2004-146874号公報Japanese Patent Application Laid-Open No. 2004-146874 特開2011-192021号公報JP 2011-192021 A 特開2005-301346号公報Japanese Patent Application Laid-Open No. 2005-301346

しかしながら、従来技術では、大容量の動画ファイルの効率的なダウンロードを実現することが難しい。なぜならば、従来技術では、エッジ装置とクライアント装置との間のネットワークの帯域や速度、通信品質に制限がある環境では、ダウンロードの途中で通信の切断やタイムアウトにより、ダウンロードが失敗する場合がある。このとき、利用者は、再度最初から動画ファイルのダウンロードが必要となり、作業効率が非常に悪い。 However, with conventional technology, it is difficult to efficiently download large video files. This is because, in environments where the network bandwidth, speed, and communication quality between the edge device and the client device are limited, conventional technology can cause the download to fail mid-download due to a communication disconnection or timeout. When this happens, the user must download the video file again from the beginning, resulting in extremely poor work efficiency.

本発明は、上記に鑑みてなされたものであって、大容量の動画ファイルの効率的なダウンロードを実現することを目的とする。 The present invention was made in consideration of the above, and aims to enable efficient downloading of large video files.

また、本発明は、コンピュータに、収集されたデータファイルを保持する情報処理装置に、前記データファイルの送信要求を送信し、前記データファイルが所定間隔で分割された複数の分割データファイルを、前記情報処理装置から順次受信して、前記コンピュータの所定領域に格納し、前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、処理を実行させる情報処理プログラムを提供する。 The present invention also provides an information processing program that causes a computer to execute the following process: send a request to an information processing device that holds collected data files; sequentially receive multiple split data files, obtained by dividing the data file at predetermined intervals, from the information processing device; store the split data files in a predetermined area of the computer; and, upon completion of reception of the multiple split data files, generate a new data file by combining the multiple split data files that have been received and stored in the predetermined area.

また、本発明は、コンピュータに、収集機器から各データファイルを受信し、前記各データファイルを所定間隔で分割した複数の分割データファイルを生成し、クライアント装置から所定のデータファイルの送信要求を受信した場合には、前記所定のデータファイルが受信済みか否かを判定し、前記所定のデータファイルが受信済みである場合には、前記所定のデータファイルを分割した複数の分割データファイルを、前記クライアント装置に順次送信し、前記所定のデータファイルが受信済みではない場合には、前記所定のデータファイルを前記収集機器から受信し、受信した前記所定のデータファイルから前記複数の分割データファイルを生成し、前記クライアント装置に順次送信する、処理を実行させる情報提供プログラムを提供する。 The present invention also provides an information provision program that causes a computer to execute the following processes: receive each data file from a collection device; generate a plurality of split data files by dividing each data file at predetermined intervals; when a request to send a predetermined data file is received from a client device, determine whether the predetermined data file has already been received; if the predetermined data file has already been received, sequentially transmit the plurality of split data files obtained by dividing the predetermined data file to the client device; and if the predetermined data file has not already been received, receive the predetermined data file from the collection device, generate the plurality of split data files from the received predetermined data file, and sequentially transmit them to the client device.

また、本発明は、第1の情報処理装置と第2の情報処理装置とを有する情報処理システムにおいて、前記第1の情報処理装置は、収集機器からデータファイルを受信し、受信された前記データファイルを所定間隔で分割した分割データファイルを生成する、制御部を有し、前記第2の情報処理装置は、前記第1の情報処理装置に、前記データファイルの送信要求を送信し、前記データファイルが所定間隔で分割された複数の分割データファイルを、前記第1の情報処理装置から順次受信して、所定領域に格納し、前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、制御部を有する、情報処理システムを提供する。 The present invention also provides an information processing system having a first information processing device and a second information processing device, wherein the first information processing device has a control unit that receives a data file from a collection device and generates split data files by dividing the received data file at predetermined intervals, and the second information processing device has a control unit that transmits a request to the first information processing device to send the data file, sequentially receives from the first information processing device multiple split data files obtained by dividing the data file at predetermined intervals and stores them in a predetermined area, and, when reception of the multiple split data files is complete, generates the data file by combining the multiple split data files that have been received and stored in the predetermined area.

また、本発明は、コンピュータが、データファイルを収集して保持する情報処理装置に、前記データファイルの送信要求を送信し、前記データファイルが所定間隔で分割された複数の分割データファイルを、前記情報処理装置から順次受信して、前記コンピュータの所定領域に格納し、前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、処理を実行する情報処理方法を提供する。 The present invention also provides an information processing method in which a computer sends a request to an information processing device that collects and stores data files to send the data files; sequentially receives from the information processing device multiple split data files obtained by dividing the data files at predetermined intervals and stores them in a predetermined area of the computer; and, when reception of the multiple split data files is complete, generates a data file by combining the multiple split data files that have been received and stored in the predetermined area.

また、本発明は、データファイルを収集して保持する情報処理装置に、前記データファイルの送信要求を送信し、前記データファイルが所定間隔で分割された複数の分割データファイルを、前記情報処理装置から順次受信して、前記コンピュータの所定領域に格納し、前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、制御部を有する情報処理装置を提供する。 The present invention also provides an information processing device having a control unit that sends a request to an information processing device that collects and stores data files to send the data files, sequentially receives multiple split data files obtained by dividing the data files at predetermined intervals from the information processing device, stores the split data files in a predetermined area of the computer, and, when reception of the multiple split data files is complete, generates the data file by combining the multiple split data files that have been received and stored in the predetermined area.

本発明によれば、大容量の動画ファイルの効率的なダウンロードを実現することができるという効果がある。 The present invention has the advantage of enabling efficient downloading of large video files.

実施形態1に係る情報処理システムの構成例を示す図である。1 is a diagram illustrating an example of the configuration of an information processing system according to a first embodiment. 参考技術の情報処理システムを説明する図である。FIG. 1 is a diagram illustrating an information processing system of a reference technology. 実施形態1に係る各装置の構成例を示すブロック図である。FIG. 2 is a block diagram illustrating an example of the configuration of each device according to the first embodiment. 実施形態1に係る情報処理の流れの一例を示すシーケンス図である。FIG. 4 is a sequence diagram illustrating an example of a flow of information processing according to the first embodiment. 実施形態2に係る情報処理システムの構成例を示す図である。FIG. 10 is a diagram illustrating an example of the configuration of an information processing system according to a second embodiment. 実施形態2に係るサーバの構成例を示すブロック図である。FIG. 10 is a block diagram illustrating an example of the configuration of a server according to a second embodiment. 実施形態2に係る情報処理の具体例1を示す図である。FIG. 10 is a diagram illustrating a specific example 1 of information processing according to the second embodiment. 実施形態2に係る情報処理の具体例2を示す図である。FIG. 10 is a diagram illustrating a specific example 2 of information processing according to the second embodiment. 実施形態2に係る情報処理の流れの一例を示すシーケンス図である。FIG. 10 is a sequence diagram illustrating an example of the flow of information processing according to the second embodiment. ハードウェア構成例を説明する図である。FIG. 2 is a diagram illustrating an example of a hardware configuration.

以下に、本発明の一実施形態に係る情報処理プログラム、情報提供プログラム、情報処理システム、情報処理方法および情報処理装置を、図面を参照して詳細に説明する。なお、本発明は、以下に説明する実施形態により限定されるものではない。 Below, an information processing program, information provision program, information processing system, information processing method, and information processing device according to one embodiment of the present invention will be described in detail with reference to the drawings. Note that the present invention is not limited to the embodiment described below.

〔実施形態1〕
以下に、実施形態1に係る情報処理システム100-1の構成、各装置の構成、各処理の流れを順に説明し、最後に実施形態1の効果を説明する。
[Embodiment 1]
The configuration of the information processing system 100-1 according to the first embodiment, the configuration of each device, and the flow of each process will be described below in order, and finally, the effects of the first embodiment will be described.

〔1.情報処理システム100-1の構成〕
図1を用いて、実施形態1に係る情報処理システム100-1の構成を詳細に説明する。図1は、実施形態に係る情報処理システム100-1の構成例を示す図である。以下に、情報処理システム100-1全体の構成例、情報処理システム100-1の処理、参考技術の情報処理システム100-Pの処理および問題点を順に説明し、最後に情報処理システム100-1の効果について説明する。なお、実施形態1では、カメラ30が収集した動画ファイルのダウンロードを一例にして説明するが、データファイルを限定するものではなく、画像ファイルや音声ファイル等の様々なデータファイルの情報処理に適用することができる。
1. Configuration of Information Processing System 100-1
The configuration of an information processing system 100-1 according to the first embodiment will be described in detail using FIG. 1. FIG. 1 is a diagram showing an example of the configuration of the information processing system 100-1 according to the embodiment. Below, an example of the overall configuration of the information processing system 100-1, the processing of the information processing system 100-1, and the processing and problems of the information processing system 100-P of the reference technology will be described in order, and finally, the effects of the information processing system 100-1 will be described. Note that in the first embodiment, the downloading of a video file collected by the camera 30 will be described as an example, but the present invention is not limited to data files, and can be applied to information processing of various data files such as image files and audio files.

(1-1.情報処理システム100-1全体の構成例)
情報処理システム100-1は、利用者Uが使用するクライアント装置である利用者端末10、エッジゲートウェイであるエッジ装置20および収集機器であるカメラ30を有する。ここで、利用者端末10とエッジ装置20とカメラ30とは、図示しない所定の通信網(ネットワーク)を介して、有線または無線により通信可能に接続される。例えば、利用者端末10とエッジ装置20とは、LTE(Long Term Evolution)や閉域網等の通信網によって接続される。また、エッジ装置20とカメラ30とは、イーサネット(Ethernet)(登録商標)等の構内通信網によって接続される。
(1-1. Example of the overall configuration of the information processing system 100-1)
The information processing system 100-1 includes a user terminal 10, which is a client device used by a user U, an edge device 20, which is an edge gateway, and a camera 30, which is a collection device. The user terminal 10, the edge device 20, and the camera 30 are connected to each other via a predetermined communication network (not shown) via wired or wireless communication. For example, the user terminal 10 and the edge device 20 are connected by a communication network such as LTE (Long Term Evolution) or a closed area network. The edge device 20 and the camera 30 are also connected by an in-house communication network such as Ethernet (registered trademark).

図1に示した情報処理システム100-1には、複数台の利用者端末10、複数台のエッジ装置20または複数台のカメラ30が含まれてもよい。また、エッジ装置20は、カメラ30と統合された構成であってもよい。 The information processing system 100-1 shown in FIG. 1 may include multiple user terminals 10, multiple edge devices 20, or multiple cameras 30. The edge device 20 may also be integrated with the camera 30.

(1-2.情報処理システム100-1全体の処理)
上記のような情報処理システム100-1全体の処理について説明する。なお、下記のステップS1~S9は、異なる順序で実行することもできる。また、下記のステップS1~S9のうち、省略される処理があってもよい。
(1-2. Overall processing of the information processing system 100-1)
The overall processing of the information processing system 100-1 as described above will be described. Note that the following steps S1 to S9 may be executed in a different order. Also, some of the following steps S1 to S9 may be omitted.

まず、カメラ30は、動画ファイルを収集する(ステップS1)。次に、エッジ装置20は、カメラ30が収集した動画ファイルを受信する(ステップS2)。このとき、エッジ装置20は、カメラ30からストリーム配信された動画ファイルを受信するが、特に限定されず、カメラ30の記憶部に記憶された動画ファイルを受信することもできる。 First, the camera 30 collects video files (step S1). Next, the edge device 20 receives the video files collected by the camera 30 (step S2). At this time, the edge device 20 receives video files streamed from the camera 30, but this is not limited thereto and the edge device 20 can also receive video files stored in the memory unit of the camera 30.

続いて、エッジ装置20は、受信した動画ファイルを分割動画ファイルとして保存する(ステップS3)。このとき、エッジ装置20は、任意の時間単位で分割された分割動画ファイル(例:1分)を時系列順に保存する。図1で示すように、エッジ装置20は、「12:01」の1分間の「データ01」、「12:02」の1分間の「データ02」、「12:03」の1分間の「データ03」・・・を分割動画ファイルとして保存する。また、エッジ装置20は、一定のデータ容量ごとに分割動画ファイルを保存することもできる。 The edge device 20 then saves the received video file as divided video files (step S3). At this time, the edge device 20 saves the divided video files, which have been divided into arbitrary time units (e.g., 1 minute), in chronological order. As shown in Figure 1, the edge device 20 saves "Data 01" for the 1 minute at "12:01," "Data 02" for the 1 minute at "12:02," "Data 03" for the 1 minute at "12:03," and so on, as divided video files. The edge device 20 can also save divided video files for each fixed data capacity.

利用者端末10は、エッジ装置20に対して、任意の期間(例:1時間)の動画ファイルの送信をリクエスト(要求)する(ステップS4)。一方、エッジ装置20は、利用者端末10のリクエストに応じて、利用者端末10に対して、分割動画ファイルを順次送信する(ステップS5)。すなわち、エッジ装置20は、利用者端末10が「12:01」~「13:00」までの1時間の動画データをリクエストしていた場合には、「12:01」の1分間の「データ01」、「12:02」の1分間の「データ02」、「12:03」の1分間の「データ03」、・・・「13:00」の1分間の「データ60」の順に、分割動画ファイルを送信する。 The user terminal 10 requests the edge device 20 to send video files for an arbitrary period (e.g., one hour) (step S4). Meanwhile, the edge device 20 sequentially sends divided video files to the user terminal 10 in response to the user terminal 10's request (step S5). That is, if the user terminal 10 requests one hour of video data from 12:01 to 13:00, the edge device 20 will send the divided video files in the following order: "Data 01" for the one minute at 12:01, "Data 02" for the one minute at 12:02, "Data 03" for the one minute at 12:03, ... "Data 60" for the one minute at 13:00.

利用者端末10は、受信した分割動画ファイルをキャッシュする(ステップS6)。すなわち、利用者端末10は、受信した分割動画ファイルを利用者端末10内のキャッシュ領域にキャッシュデータとして格納する。このとき、利用者端末10は、キャッシュ領域以外の記憶領域に分割動画ファイルを格納することもできる。さらに、利用者端末10は、格納したキャッシュデータ等の分割動画ファイルのデータ容量が記憶領域の容量を超過した場合には、最も参照回数が少ない、または格納されたタイミングが最も古い分割動画ファイルから削除することもできる。 The user terminal 10 caches the received divided video files (step S6). That is, the user terminal 10 stores the received divided video files as cache data in a cache area within the user terminal 10. At this time, the user terminal 10 can also store the divided video files in a storage area other than the cache area. Furthermore, if the data volume of the stored divided video files, such as cache data, exceeds the capacity of the storage area, the user terminal 10 can delete the divided video files that have been referenced the least number of times or that were stored the oldest.

このとき、利用者端末10は、通信エラー等が発生することにより、リクエストした期間の分割動画ファイルの受信が完了しない場合には、未受信部分の分割動画ファイルを特定する(ステップS7)。そして、利用者端末10は、エッジ装置20に対して、未受信部分の分割動画ファイルの送信をリクエストする(ステップS8)。例えば、利用者端末10は、「12:03」の1分間の「データ03」までの分割動画ファイルを受信している場合には、「12:04」の1分間の「データ04」から再度送信するように、エッジ装置20に対して、再送要求を送信する。すなわち、利用者端末10は、通信エラー等が発生し、ダウンロードが失敗したとしても、ダウンロードを途中から再開することができる。 At this time, if the user terminal 10 is unable to complete reception of the divided video files for the requested period due to a communication error or the like, it identifies the divided video files that have not been received (step S7). The user terminal 10 then requests the edge device 20 to transmit the divided video files that have not been received (step S8). For example, if the user terminal 10 has received the divided video files up to "Data 03" for the one minute at "12:03," it sends a retransmission request to the edge device 20 to request that the divided video files be retransmitted from "Data 04" for the one minute at "12:04." In other words, even if a communication error or the like occurs and the download fails, the user terminal 10 can resume the download from where it left off.

最後に、利用者端末10は、リクエストした期間の分割動画ファイルの受信が完了した場合には、受信した分割動画ファイルを時系列順に結合し、大容量の動画ファイルを生成する(ステップS9)。 Finally, when the user terminal 10 has completed receiving the split video files for the requested period, it combines the received split video files in chronological order to generate a large-capacity video file (step S9).

(1-3.情報処理システム100-P)
図2を用いて、参考技術の情報処理について説明した上で、参考技術の問題点について説明する。図2は、参考技術の情報処理システムを説明する図である。なお、参考技術の情報処理システム100-P全体の構成例(利用者端末10-P、エッジ装置20-P、カメラ30)は、上述した情報処理システム100-1全体の構成例と共通するので、説明を省略する。
(1-3. Information Processing System 100-P)
The information processing of the reference technology will be explained using Figure 2, and then the problems of the reference technology will be explained. Figure 2 is a diagram illustrating an information processing system of the reference technology. Note that an example of the overall configuration of the information processing system 100-P of the reference technology (user terminal 10-P, edge device 20-P, camera 30) is common to the example of the overall configuration of the information processing system 100-1 described above, and therefore a description thereof will be omitted.

(1-3-1.参考技術の情報処理)
まず、カメラ30は、動画ファイルを収集する(ステップS11)。次に、エッジ装置20-Pは、カメラ30が収集した動画ファイルを受信する(ステップS12)。続いて、エッジ装置20-Pは、受信した動画ファイルを分割動画ファイルとして保存する(ステップS13)。なお、上記ステップS11~S13の処理は、上述した情報処理システム100-1におけるステップS1~S3の処理と共通する。
(1-3-1. Information processing of reference technology)
First, the camera 30 collects video files (step S11). Next, the edge device 20-P receives the video files collected by the camera 30 (step S12). Next, the edge device 20-P saves the received video files as divided video files (step S13). Note that the processes of steps S11 to S13 are common to the processes of steps S1 to S3 in the information processing system 100-1 described above.

利用者端末10-Pは、エッジ装置20-Pに対して、任意の期間(例:1時間)の動画ファイルの送信をリクエストする(ステップS14)。一方、エッジ装置20-Pは、利用者端末10のリクエストに応じて、カメラ30から受信した分割動画ファイルを時系列順に結合し、大容量の動画ファイルを生成する(ステップS15)。そして、エッジ装置20-Pは、利用者端末10に対して、結合した大容量の動画ファイルのバイナリデータを順番に送信する(ステップ16)。 The user terminal 10-P requests the edge device 20-P to send video files for a given period (e.g., one hour) (step S14). Meanwhile, in response to the request from the user terminal 10, the edge device 20-P combines the split video files received from the camera 30 in chronological order to generate a large-capacity video file (step S15). The edge device 20-P then sequentially transmits the binary data of the combined large-capacity video files to the user terminal 10 (step 16).

このとき、利用者端末10-Pは、通信エラー等が発生することによりリクエストした期間の動画ファイルの受信が完了しない場合には、再度エッジ装置20-Pに任意の期間の動画ファイルの送信をリクエストする必要がある。すなわち、利用者端末10-Pは、通信エラー等の発生によりダウンロードが失敗した場合には、ダウンロードを最初からやり直す必要がある。 At this time, if the user terminal 10-P is unable to complete receiving the video files for the requested period due to a communication error or other problem, it must again request the edge device 20-P to send the video files for the desired period. In other words, if the download fails due to a communication error or other problem, the user terminal 10-P must restart the download from the beginning.

(1-3-2.参考技術の問題点)
上述してきたように、情報処理システム100-Pでは、エッジ装置20-Pと利用者端末10-Pとの間のネットワークの帯域、速度、または通信品質に制限がある際には、ダウンロードの途中で通信の切断やタイムアウトにより、ダウンロードが失敗する場合がある。その際は、利用者Uは、再度最初から動画ファイルのダウンロードが必要となり、作業効率が非常に悪いという問題点がある。特に、公衆回線(3G、LTE)や個々の企業で構築した閉域網を利用した遠隔監視システムにおいて、上記の問題点が顕著となる。また、通信時に費用が発生する通信環境の場合は、不要なコストも発生する。
(1-3-2. Problems with the reference technology)
As described above, in the information processing system 100-P, if there are limitations on the bandwidth, speed, or communication quality of the network between the edge device 20-P and the user terminal 10-P, the download may fail due to a communication interruption or timeout during the download. In such a case, the user U must download the video file again from the beginning, resulting in a problem of extremely poor work efficiency. This problem is particularly pronounced in remote monitoring systems that use public lines (3G, LTE) or private networks established by individual companies. Furthermore, in a communication environment where communication costs are incurred, unnecessary costs may also be incurred.

(1-4.情報処理システム100-1の効果)
上述した情報処理システム100-1では、エッジ装置20は、カメラ30から動画ファイルを受信し、受信した動画ファイルを所定間隔で分割した分割動画ファイルを生成する。また、利用者端末10は、エッジ装置20に動画ファイルの送信要求を送信し、複数の分割動画ファイルを、エッジ装置20から順次受信して、キャッシュ領域に格納し、すべての分割動画ファイルの受信が完了した場合には、受信した分割動画ファイルを結合した大容量動画ファイルを生成する。また、利用者端末10は、分割動画ファイルの受信中に通信エラーが発生した場合に、キャッシュ領域に格納された分割動画ファイルのうち最新の分割動画ファイルを特定し、特定した最新の分割動画ファイルの次の分割動画ファイルからの再送要求をエッジ装置20に送信する。
(1-4. Effects of Information Processing System 100-1)
In the information processing system 100-1 described above, the edge device 20 receives a video file from the camera 30 and generates divided video files by dividing the received video file at predetermined intervals. The user terminal 10 also transmits a video file transmission request to the edge device 20, sequentially receives multiple divided video files from the edge device 20, stores them in a cache area, and, when reception of all divided video files is complete, generates a large-capacity video file by combining the received divided video files. If a communication error occurs while receiving divided video files, the user terminal 10 identifies the most recent divided video file among the divided video files stored in the cache area and transmits a retransmission request to the edge device 20, starting with the divided video file next to the most recent divided video file identified.

このため、情報処理システム100-1では、通信品質が低いネットワーク環境下に配置されたエッジ装置20から任意期間の動画ファイルを取得する際に、途中でダウンロードが失敗した場合であっても、取得に失敗した動画ファイルからダウンロード再開が可能であり、ダウンロードを最初から再実施する必要が無い。 For this reason, in the information processing system 100-1, even if the download fails midway when acquiring a video file of a given period from an edge device 20 located in a network environment with low communication quality, the download can be resumed from the video file that failed to be acquired, eliminating the need to restart the download from the beginning.

また、情報処理システム100-1では、再度、同じ期間の大容量動画ファイルが必要な際は、利用者端末10内部のキャッシュから動画ファイルを取得出来るので、エッジ装置20への不要な通信が発生しない。したがって、情報処理システム100-1では、参考技術で発生した大容量動画ファイルのダウンロードにおける非効率なダウンロード作業を抑制し、大容量動画ファイルの効率的なダウンロードを実現することができる。 Furthermore, in the information processing system 100-1, when a large-capacity video file from the same period is required again, the video file can be obtained from the cache within the user terminal 10, so unnecessary communication with the edge device 20 does not occur. Therefore, the information processing system 100-1 can suppress the inefficient downloading work that occurs when downloading large-capacity video files in the reference technology, and achieve efficient downloading of large-capacity video files.

また、情報処理システム100-1では、任意期間の大容量動画ファイルを取得し、当該動画を確認後、当初の期間より長く、または短く動画を取得したい際は、未ダウンロードの動画ファイルのみで指定の大容量動画ファイルをローカルに保存することが可能である。したがって、情報処理システム100-1では、エッジ装置20と利用者端末10との間の冗長なダウンロードを抑制することができる。 In addition, the information processing system 100-1 can acquire a large-capacity video file of any duration, and after reviewing the video, if you want to acquire a video for a longer or shorter period than the original, you can locally save the specified large-capacity video file with only the undownloaded video files. Therefore, the information processing system 100-1 can reduce redundant downloads between the edge device 20 and the user terminal 10.

〔2.情報処理システム100-1の各装置の構成〕
図3を用いて、図1に示した情報処理システム100-1が有する各装置の機能構成について説明する。図3は、実施形態に係る各装置の構成例を示すブロック図である。以下では、実施形態1に係る情報処理システム100-1全体の構成例を説明した上で、実施形態1に係る利用者端末10の構成例、エッジ装置20の構成例およびカメラ30の構成例について詳細に説明する。
2. Configuration of each device in the information processing system 100-1
The functional configuration of each device included in the information processing system 100-1 shown in Fig. 1 will be described using Fig. 3. Fig. 3 is a block diagram showing an example configuration of each device according to an embodiment. Below, an example configuration of the entire information processing system 100-1 according to the first embodiment will be described, and then an example configuration of the user terminal 10, the edge device 20, and the camera 30 according to the first embodiment will be described in detail.

(2-1.情報処理システム100-1全体の構成例)
図3に示すように、情報処理システム100-1は、利用者端末10、エッジ装置20およびカメラ30を有する。利用者端末10とエッジ装置20とは、LTEや閉域網等の通信網Nによって通信可能に接続されている。また、エッジ装置20とカメラ30とは、イーサネット(登録商標)等の通信網によって通信可能に接続されている。
(2-1. Example of the overall configuration of the information processing system 100-1)
3, the information processing system 100-1 includes a user terminal 10, an edge device 20, and a camera 30. The user terminal 10 and the edge device 20 are communicatively connected to each other via a communication network N such as LTE or a closed area network. The edge device 20 and the camera 30 are communicatively connected to each other via a communication network such as Ethernet (registered trademark).

(2-2.利用者端末10の構成例)
まず、図3を用いて、情報処理装置である利用者端末10の構成例について説明する。利用者端末10は、通信部11、キャッシュ領域12、記憶部13および制御部14を有する。なお、利用者端末10は、利用者Uから各種操作を受け付ける入力部(例えば、キーボードやマウス等)や、各種情報を表示するための表示部(例えば、液晶ディスプレイ等)を有してもよい。
(2-2. Example of configuration of user terminal 10)
First, an example of the configuration of a user terminal 10, which is an information processing device, will be described using Fig. 3. The user terminal 10 has a communication unit 11, a cache area 12, a storage unit 13, and a control unit 14. The user terminal 10 may also have an input unit (e.g., a keyboard, a mouse, etc.) that accepts various operations from the user U, and a display unit (e.g., a liquid crystal display, etc.) that displays various information.

(2-2-1.通信部11)
通信部11は、他の装置との間でのデータ通信を司る。例えば、通信部11は、ルータ等を介して、各通信装置との間でデータ通信を行う。また、通信部11は、図示しないオペレータの端末との間でデータ通信を行うことができる。
(2-2-1. Communication unit 11)
The communication unit 11 controls data communication with other devices. For example, the communication unit 11 performs data communication with each communication device via a router, etc. The communication unit 11 can also perform data communication with an operator's terminal (not shown).

(2-2-2.キャッシュ領域12)
キャッシュ領域12は、キャッシュデータを記憶する。例えば、キャッシュ領域12は、後述する制御部14の格納部14cによって格納された、分割動画ファイルのキャッシュデータを記憶する。
(2-2-2. Cache area 12)
The cache area 12 stores cache data, for example, cache data of divided video files stored by a storage unit 14c of the control unit 14 (to be described later).

(2-2-3.記憶部13)
記憶部13は、制御部14が動作する際に参照する各種情報や、制御部14が動作した際に取得した各種情報を記憶する。記憶部13は、データファイル記憶部13aを有する。ここで、記憶部13は、例えば、RAM(Random Access Memory)、フラッシュメモリ等の半導体メモリ素子、または、ハードディスク、光ディスク等の記憶装置等で実現され得る。なお、図3の例では、記憶部13は、利用者端末10の内部に設置されているが、利用者端末10の外部に設置されてもよいし、複数の記憶部が設置されていてもよい。
(2-2-3. Storage unit 13)
The storage unit 13 stores various information referenced by the control unit 14 when it operates and various information acquired when the control unit 14 operates. The storage unit 13 includes a data file storage unit 13a. Here, the storage unit 13 may be realized by, for example, a semiconductor memory element such as a random access memory (RAM) or a flash memory, or a storage device such as a hard disk or an optical disk. In the example of FIG. 3, the storage unit 13 is installed inside the user terminal 10, but it may also be installed outside the user terminal 10, or multiple storage units may be installed.

(2-2-3-1.データファイル記憶部13a)
データファイル記憶部13aは、動画、画像、音声等のデータファイルを記憶する。例えば、データファイル記憶部13aは、後述する制御部14の生成部14dによって生成された、複数の分割動画ファイルを結合した大容量の動画ファイルを記憶する。
(2-2-3-1. Data file storage unit 13a)
The data file storage unit 13a stores data files such as videos, images, audio, etc. For example, the data file storage unit 13a stores a large-capacity video file generated by a generation unit 14d of the control unit 14 (described later) by combining multiple split video files.

(2-2-4.制御部14)
制御部14は、当該利用者端末10全体の制御を司る。制御部14は、送信部14a、受信部14b、格納部14c、生成部14d、特定部14eおよび削除部14fを有する。ここで、制御部14は、例えば、CPU(Central Processing Unit)やMPU(Micro Processing Unit)等の電子回路やASIC(Application Specific Integrated Circuit)やFPGA(Field Programmable Gate Array)等の集積回路により実現され得る。
(2-2-4. Control unit 14)
The control unit 14 is responsible for overall control of the user terminal 10. The control unit 14 has a transmitting unit 14a, a receiving unit 14b, a storing unit 14c, a generating unit 14d, an identifying unit 14e, and a deleting unit 14f. Here, the control unit 14 can be realized by, for example, an electronic circuit such as a CPU (Central Processing Unit) or an MPU (Micro Processing Unit), or an integrated circuit such as an ASIC (Application Specific Integrated Circuit) or an FPGA (Field Programmable Gate Array).

(2-2-4-1.送信部14a)
送信部14aは、収集された動画、画像、音声等のデータファイルを保持する情報処理装置に、データファイルの送信要求を送信する。例えば、送信部14aは、収集された動画ファイルを保持するエッジ装置20に、「データ01」~「データ60」の1時間分の動画ファイルの送信要求を送信する。また、送信部14aは、特定された最新の分割データファイルの次の分割データファイルからの再送要求を情報処理装置に送信する。例えば、送信部14aは、分割動画ファイルの受信中に通信エラーが発生した場合に、「データ03」まで分割動画ファイルが受信済みであったときには、「データ04」からの分割動画ファイルの再送要求をエッジ装置20に送信する。
(2-2-4-1. Transmitting unit 14a)
The transmitter 14a transmits a request to transmit data files to an information processing device that holds collected data files such as video, images, and audio. For example, the transmitter 14a transmits a request to transmit one hour's worth of video files, "Data 01" to "Data 60," to the edge device 20 that holds the collected video files. The transmitter 14a also transmits a retransmission request for the divided data file next to the latest identified divided data file to the information processing device. For example, if a communication error occurs while receiving divided video files, and divided video files up to "Data 03" have already been received, the transmitter 14a transmits a retransmission request for divided video files starting from "Data 04" to the edge device 20.

(2-2-4-2.受信部14b)
受信部14bは、データファイルが所定間隔で分割された複数の分割データファイルを、情報処理装置から順次受信する。例えば、受信部14bは、1分単位で分割された分割動画ファイル「データ01」、「データ02」、・・・「データ60」を、エッジ装置20から順次受信する。ここで、分割されたデータファイルの間隔は、一定間隔には限られず、データ送受信のプロトコルとしてあらかじめ規定されているものであれば、一定でなくてもよい。
(2-2-4-2. Receiving unit 14b)
The receiving unit 14b sequentially receives a plurality of divided data files, which are obtained by dividing a data file at a predetermined interval, from the information processing device. For example, the receiving unit 14b sequentially receives divided video files "Data 01,""Data02," ... "Data 60," which are divided in one-minute increments, from the edge device 20. Here, the intervals between the divided data files are not limited to a fixed interval, and do not have to be fixed as long as they are specified in advance as a data transmission/reception protocol.

(2-2-4-3.格納部14c)
格納部14cは、受信した分割データファイルを所定領域に格納する。例えば、格納部14cは、複数の分割データファイルそれぞれをキャッシュデータとしてキャッシュ領域に格納する。また、格納部14cは、受信した複数の分割データファイルを記憶部13に格納することもできる。
(2-2-4-3. Storage section 14c)
The storage unit 14c stores the received divided data files in a predetermined area. For example, the storage unit 14c stores each of the multiple divided data files in a cache area as cache data. The storage unit 14c can also store the received multiple divided data files in the memory unit 13.

(2-2-4-4.生成部14d)
生成部14dは、複数の分割データファイルの受信が完了した場合には、所定領域に格納される受信済みの複数の分割データファイルを結合したデータファイルを生成する。例えば、生成部14dは、複数の分割データファイルの受信が完了した場合には、キャッシュ領域に格納される受信済みの複数の分割データファイルを結合したデータファイルを生成する。すなわち、生成部14dは、「データ01」~「データ60」の1時間分の動画ファイルの送信を要求していた場合には、「データ01」、「データ02」、・・・「データ60」を時系列順に結合し、1時間分の動画ファイルを生成する。また、生成部14dは、生成したデータファイルをデータファイル記憶部13aに格納する。
(2-2-4-4. Generation unit 14d)
When the generation unit 14d has completed receiving multiple split data files, it generates a data file by combining the multiple split data files that have already been received and stored in a specified area. For example, when the generation unit 14d has completed receiving multiple split data files, it generates a data file by combining the multiple split data files that have already been received and stored in a cache area. That is, if the generation unit 14d has requested the transmission of one hour's worth of video files, "Data 01" to "Data 60," it combines "Data 01,""Data02," ... "Data 60" in chronological order to generate one hour's worth of video file. The generation unit 14d also stores the generated data file in the data file storage unit 13a.

(2-2-4-5.特定部14e)
特定部14eは、複数の分割データファイルの受信中に通信エラーが発生した場合に、所定領域に格納された分割データファイルのうち最新の分割データファイルを特定する。例えば、特定部14eは、キャッシュ領域に格納された分割動画ファイルを確認し、「データ01」、「データ02」、「データ03」がキャッシュ領域に記憶されている場合には、「データ01」~「データ60」の分割動画ファイルのうち、「データ03」が最新の分割動画ファイルであると特定する。
(2-2-4-5. Specification part 14e)
When a communication error occurs during reception of a plurality of divided data files, the identifying unit 14e identifies the newest divided data file among the divided data files stored in a predetermined area. For example, the identifying unit 14e checks the divided moving image files stored in the cache area, and if "Data 01,""Data02," and "Data 03" are stored in the cache area, the identifying unit 14e identifies "Data 03" as the newest divided moving image file among the divided moving image files "Data 01" to "Data 60."

(2-2-4-6.削除部14f)
削除部14fは、キャッシュ領域に格納されるキャッシュデータのデータサイズの総和が閾値を超過した場合には、キャッシュデータのうち参照回数が最も少ないキャッシュデータまたは作成日時が最も古いキャッシュデータを削除する。例えば、削除部14fは、「データ01」、「データ02」、・・・「データ60」を時系列順に受信し、キャッシュ領域に格納していた場合には、最も古い「データ01」を削除する。
(2-2-4-6. Deletion unit 14f)
When the total data size of the cache data stored in the cache area exceeds a threshold, the deletion unit 14f deletes the cache data that has been referenced the least or the cache data that has the oldest creation date and time. For example, when the deletion unit 14f receives "Data 01,""Data02," ... "Data 60" in chronological order and stores them in the cache area, it deletes the oldest "Data 01."

(2-3.エッジ装置20の構成例)
次に、図3を用いて、情報提供装置であるエッジ装置20の構成例について説明する。エッジ装置20は、通信部21、記憶部22および制御部23を有する。なお、エッジ装置20は、エッジ装置20の管理者等から各種操作を受け付ける入力部(例えば、キーボードやマウス等)や、各種情報を表示するための表示部(例えば、液晶ディスプレイ等)を有してもよい。
(2-3. Configuration example of edge device 20)
Next, a configuration example of the edge device 20, which is an information providing device, will be described with reference to Fig. 3. The edge device 20 has a communication unit 21, a storage unit 22, and a control unit 23. The edge device 20 may also have an input unit (e.g., a keyboard, a mouse, etc.) that accepts various operations from an administrator of the edge device 20, and a display unit (e.g., a liquid crystal display, etc.) that displays various information.

(2-3-1.通信部21)
通信部21は、他の装置との間でのデータ通信を司る。例えば、通信部21は、ルータ等を介して、各通信装置との間でデータ通信を行う。また、通信部21は、図示しないオペレータの端末との間でデータ通信を行うことができる。
(2-3-1. Communication unit 21)
The communication unit 21 controls data communication with other devices. For example, the communication unit 21 performs data communication with each communication device via a router, etc. The communication unit 21 can also perform data communication with an operator's terminal (not shown).

(2-3-2.記憶部22)
記憶部22は、制御部23が動作する際に参照する各種情報や、制御部23が動作した際に取得した各種情報を記憶する。記憶部22は、分割データファイル記憶部22aを有する。ここで、記憶部22は、例えば、RAM、フラッシュメモリ等の半導体メモリ素子、または、ハードディスク、光ディスク等の記憶装置等で実現され得る。なお、図3の例では、記憶部22は、エッジ装置20の内部に設置されているが、エッジ装置20の外部に設置されてもよいし、複数の記憶部が設置されていてもよい。
(2-3-2. Storage unit 22)
The storage unit 22 stores various information referenced by the control unit 23 when it operates and various information acquired when the control unit 23 operates. The storage unit 22 includes a divided data file storage unit 22a. Here, the storage unit 22 may be realized by, for example, a semiconductor memory element such as a RAM or a flash memory, or a storage device such as a hard disk or an optical disk. Note that, in the example of FIG. 3, the storage unit 22 is installed inside the edge device 20, but it may also be installed outside the edge device 20, or multiple storage units may be installed.

(2-3-2-1.分割データファイル記憶部22a)
分割データファイル記憶部22aは、動画、画像、音声等の分割データファイルを記憶する。例えば、分割データファイル記憶部22aは、後述する制御部23の生成部23bによって生成された、複数の分割動画ファイルを時系列順に記憶する。
(2-3-2-1. Divided data file storage unit 22a)
The divided data file storage unit 22a stores divided data files of moving images, images, audio, etc. For example, the divided data file storage unit 22a stores, in chronological order, a plurality of divided moving image files generated by a generating unit 23b of the control unit 23, which will be described later.

(2-3-3.制御部23)
制御部23は、当該エッジ装置20全体の制御を司る。制御部23は、受信部23a、生成部23b、判定部23cおよび送信部23dを有する。ここで、制御部23は、例えば、CPUやMPU等の電子回路やASICやFPGA等の集積回路により実現され得る。
(2-3-3. Control unit 23)
The control unit 23 controls the entire edge device 20. The control unit 23 has a receiving unit 23 a, a generating unit 23 b, a determining unit 23 c, and a transmitting unit 23 d. Here, the control unit 23 can be realized by, for example, an electronic circuit such as a CPU or an MPU, or an integrated circuit such as an ASIC or an FPGA.

(2-3-3-1.受信部23a)
受信部23aは、収集機器から、動画、画像、音声等の各データファイルを受信する。例えば、受信部23aは、収集機器であるカメラ30から、ストリーム配信による動画ファイルを受信する。
(2-3-3-1. Receiving unit 23a)
The receiving unit 23a receives data files such as video, image, and audio from the collecting device. For example, the receiving unit 23a receives a video file via streaming distribution from the camera 30, which is a collecting device.

(2-3-3-2.生成部23b)
生成部23bは、各データファイルを所定間隔で分割した複数の分割データファイルを生成する。例えば、生成部23bは、「データ01」~「データ60」の1時間分の動画ファイルを1分単位で分割し、複数の分割動画ファイル「データ01」、「データ02」、・・・「データ60」を生成し、分割データファイル記憶部22aに格納する。また、生成部23bは、所定のデータ容量単位で分割された分割動画ファイルを生成し、分割データファイル記憶部22aに格納することもできる。ここで、データファイルを分割する間隔は、一定間隔には限られず、データ送受信のプロトコルとしてあらかじめ規定されているものであれば、一定でなくてもよい。
(2-3-3-2. Generation unit 23b)
The generation unit 23b generates a plurality of split data files by dividing each data file at a predetermined interval. For example, the generation unit 23b divides a one-hour moving image file, "Data 01" to "Data 60," into one-minute increments to generate a plurality of split moving image files, "Data 01,""Data02," ... "Data 60," which are stored in the split data file storage unit 22a. The generation unit 23b can also generate split moving image files divided in predetermined data capacity units and store them in the split data file storage unit 22a. Here, the intervals at which the data files are divided are not limited to a fixed interval and do not have to be fixed as long as they are specified in advance as a data transmission/reception protocol.

(2-3-3-3.判定部23c)
判定部23cは、クライアント装置から所定のデータファイルの送信要求を受信した場合には、所定のデータファイルが受信済みか否かを判定する。例えば、判定部23cは、利用者端末10から「データ01」~「データ60」の1時間分の動画ファイルの送信要求を受信した場合には、分割データファイル記憶部22aを参照し、「データ01」、「データ02」、・・・「データ60」の分割動画ファイルの有無を判定する。
(2-3-3-3. Determination unit 23c)
When the determination unit 23c receives a request to send a predetermined data file from a client device, the determination unit 23c determines whether the predetermined data file has already been received. For example, when the determination unit 23c receives a request to send one hour's worth of video files "DATA 01" to "DATA 60" from the user terminal 10, the determination unit 23c refers to the divided data file storage unit 22a and determines whether the divided video files "DATA 01,""DATA02," ..., "DATA 60" exist.

(2-3-3-4.送信部23d)
送信部23dは、所定のデータファイルが受信済みである場合には、所定のデータファイルを分割した複数の分割データファイルを、クライアント装置に順次送信する。例えば、送信部23dは、1分単位で分割された分割動画ファイル「データ01」、「データ02」、・・・「データ60」を、利用者端末10に順次送信する。一方、送信部23dは、所定のデータファイルが受信済みではない場合には、収集機器から受信された所定のデータファイルを分割して生成された複数の分割データファイルを、クライアント装置に順次送信する。例えば、送信部23dは、利用者端末10によって送信要求された「データ61」~「データ70」の動画ファイルが受信済みではない場合には、カメラ30から受信部23aによって「データ61」~「データ70」の動画ファイルとして受信され、生成部23bによって生成された「データ61」、「データ62」、・・・「データ70」の分割動画ファイルを、利用者端末10に順次送信する。
(2-3-3-4. Transmitting unit 23d)
If the specified data file has already been received, the transmitting unit 23d sequentially transmits to the client device multiple split data files obtained by dividing the specified data file. For example, the transmitting unit 23d sequentially transmits to the user terminal 10 split moving image files "DATA 01,""DATA02," ... "DATA 60" divided in one-minute increments. On the other hand, if the specified data file has not already been received, the transmitting unit 23d sequentially transmits to the client device multiple split data files generated by dividing the specified data file received from the collection device. For example, if the moving image files "DATA 61" to "DATA 70" requested for transmission by the user terminal 10 have not already been received, the transmitting unit 23d sequentially transmits to the user terminal 10 the split moving image files "DATA 61,""DATA62," ... "DATA 70" received from the camera 30 by the receiving unit 23a as moving image files "DATA 61" to "DATA 70" and generated by the generating unit 23b.

(2-4.カメラ30の構成例)
次に、図3を用いて、収集機器であるカメラ30の構成例について説明する。カメラ30は、収集部31を有する。なお、カメラ30は、カメラ30の管理者等から各種操作を受け付ける入力部(例えば、キーボードやマウス等)や、各種情報を表示するための表示部(例えば、液晶ディスプレイ等)や、収集したデータファイルを記憶する記憶部を有してもよい。
(2-4. Configuration example of camera 30)
Next, an example configuration of the camera 30, which is a collection device, will be described using Fig. 3. The camera 30 has a collection unit 31. The camera 30 may also have an input unit (e.g., a keyboard, a mouse, etc.) that accepts various operations from an administrator of the camera 30, a display unit (e.g., a liquid crystal display, etc.) that displays various information, and a storage unit that stores collected data files.

(2-4-1.収集部31)
収集部31は、データファイルを収集する。例えば、収集部31は、動画、画像、音声等のデータファイルを収集する。また、収集部31は、収集したデータファイルをエッジ装置20に送信する。さらに、収集部31は、収集したデータファイルを各種サーバ等のエッジ装置20以外の情報提供装置に送信することもできる。
(2-4-1. Collection unit 31)
The collection unit 31 collects data files. For example, the collection unit 31 collects data files such as video, image, and audio. The collection unit 31 also transmits the collected data files to the edge device 20. Furthermore, the collection unit 31 can also transmit the collected data files to information providing devices other than the edge device 20, such as various servers.

〔3.情報処理システム100-1の処理の流れ〕
図4を用いて、実施形態1に係る情報処理システム100-1の処理の流れについて説明する。図4は、実施形態1に係る情報処理の流れの一例を示すシーケンス図である。なお、下記のステップS101~S111の処理は、異なる順序で実行することもできる。また、下記のステップS101~S111の処理のうち、省略される処理があってもよい。
3. Processing flow of information processing system 100-1
The processing flow of the information processing system 100-1 according to the first embodiment will be described with reference to Fig. 4. Fig. 4 is a sequence diagram showing an example of the flow of information processing according to the first embodiment. Note that the processing of steps S101 to S111 below can be executed in a different order. Also, some of the processing of steps S101 to S111 below may be omitted.

(3-1.分割データファイル生成処理)
まず、カメラ30は、収集した動画ファイルをストリーム配信する(ステップS101)。次に、エッジ装置20は、当該動画ファイルを受信し(ステップS102)、受信した動画ファイルから所定の時間単位で分割した分割動画ファイルを生成する(ステップS103)。
(3-1. Split data file generation process)
First, the camera 30 streams the collected video file (step S101). Next, the edge device 20 receives the video file (step S102) and generates divided video files by dividing the received video file into predetermined time units (step S103).

(3-2.分割データファイル送信処理)
利用者端末10は、任意の期間(例:1時間)の動画ファイルのダウンロードを実行する(ステップS104)。このとき、利用者端末10は、エッジ装置20に対して当該動画ファイルのダウンロードをリクエストする(ステップS105)。一方、エッジ装置20は、利用者端末10のリクエストに応じて、利用者端末10に対して分割動画ファイルを順次送信する(ステップS106)。このとき、利用者端末10は、受信した分割動画ファイルをキャッシュする。
(3-2. Divided data file transmission process)
The user terminal 10 downloads a video file for an arbitrary period (e.g., one hour) (step S104). At this time, the user terminal 10 requests the edge device 20 to download the video file (step S105). Meanwhile, the edge device 20 sequentially transmits the divided video files to the user terminal 10 in response to the request from the user terminal 10 (step S106). At this time, the user terminal 10 caches the received divided video files.

(3-3.データファイル生成処理)
ここで、エッジ装置20と利用者端末10との間で、通信エラーが発生した場合(ステップ107)、利用者端末10は、キャッシュを確認することによって未ダウンロードの分割動画ファイルを特定する(ステップS108)。続いて、利用者端末10は、エッジ装置20に対して、未ダウンロードの分割動画ファイルのダウンロードを再リクエストする(ステップS109)。そして、エッジ装置20は、リクエストされた動画ファイルのうち未ダウンロードの分割動画ファイルを送信する(ステップS110)。最後に、利用者端末10は、リクエストした期間の分割動画ファイルの受信が完了した場合には、受信した分割動画ファイルを結合し、大容量動画ファイルを生成する(ステップS111)。
(3-3. Data file generation process)
If a communication error occurs between the edge device 20 and the user terminal 10 (step 107), the user terminal 10 identifies any divided video files that have not yet been downloaded by checking its cache (step S108). The user terminal 10 then re-requests the edge device 20 to download the divided video files that have not yet been downloaded (step S109). The edge device 20 then transmits the divided video files that have not yet been downloaded from the requested video files (step S110). Finally, when the user terminal 10 has completed receiving all the divided video files for the requested period, it combines the received divided video files to generate a large-capacity video file (step S111).

〔4.実施形態1の効果〕
最後に、実施形態1の効果について説明する。以下では、実施形態1に係る処理に対応する効果1~5について説明する。
4. Effects of the First Embodiment
Finally, the effects of the first embodiment will be described. Effects 1 to 5 corresponding to the processing according to the first embodiment will be described below.

(4-1.効果1)
第1に、上述した実施形態1に係る処理では、収集されたデータファイルを保持するエッジ装置20に、当該データファイルの送信要求を送信し、当該データファイルが所定間隔で分割された複数の分割データファイルを、エッジ装置20から順次受信して、利用者端末10の所定領域に格納し、当該分割データファイルの受信が完了した場合には、所定領域に格納した受信済みの当該分割データファイルを結合したデータファイルを生成する。このため、本処理では、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-1. Effect 1)
First, in the process according to the first embodiment described above, a request to transmit the collected data file is sent to the edge device 20 that holds the data file, and multiple split data files obtained by dividing the data file at predetermined intervals are sequentially received from the edge device 20 and stored in a predetermined area of the user terminal 10. When reception of the split data files is complete, a data file is generated by combining the received split data files stored in the predetermined area. Therefore, this process enables efficient downloading of large video files.

(4-2.効果2)
第2に、上述した実施形態1に係る処理では、複数の分割データファイルの受信中に通信エラーが発生した場合に、所定領域に格納した分割データファイルのうち最新の分割データファイルを特定し、特定した最新の分割データファイルの次の分割データファイルからの再送要求を前記情報処理装置に送信する。このため、本処理では、通信エラーが発生した場合でも、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-2. Effect 2)
Second, in the process according to the first embodiment, if a communication error occurs during reception of a plurality of divided data files, the latest divided data file among the divided data files stored in a predetermined area is identified, and a retransmission request is sent to the information processing device, starting with the divided data file next to the latest divided data file. Therefore, in this process, even if a communication error occurs, efficient downloading of large video files can be achieved.

(4-3.効果3)
第3に、上述した実施形態1に係る処理では、複数の分割データファイルそれぞれをキャッシュデータとして利用者端末10のキャッシュ領域に格納し、分割データファイルの受信が完了した場合には、キャッシュ領域に格納した受信済みの分割データファイルを結合したデータファイルを生成する。このため、本処理では、キャッシュデータを用いて、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-3. Effect 3)
Third, in the process according to the first embodiment described above, each of the divided data files is stored as cache data in the cache area of the user terminal 10, and when reception of the divided data files is completed, a data file is generated by combining the received divided data files stored in the cache area. Therefore, in this process, the cache data can be used to efficiently download large video files.

(4-4.効果4)
第4に、上述した実施形態1に係る処理では、キャッシュ領域に格納したキャッシュデータのデータサイズの総和が閾値を超過した場合には、キャッシュデータのうち参照回数が最も少ないキャッシュデータまたは作成日時が最も古いキャッシュデータを削除する。このため、本処理では、キャッシュデータを管理することによって、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-4. Effect 4)
Fourth, in the process according to the first embodiment described above, if the total data size of the cache data stored in the cache area exceeds a threshold, the cache data that has been referenced the least or the cache data that has the oldest creation date and time is deleted. Therefore, in this process, by managing the cache data, it is possible to efficiently download large video files.

(4-5.効果5)
第5に、上述した実施形態1に係る処理では、カメラ30から各データファイルを受信し、各データファイルを所定間隔で分割した複数の分割データファイルを生成し、利用者端末10から所定のデータファイルの送信要求を受信した場合には、所定のデータファイルが受信済みか否かを判定し、所定のデータファイルが受信済みである場合には、所定のデータファイルを分割した複数の分割データファイルを、利用者端末10に順次送信し、所定のデータファイルが受信済みではない場合には、所定のデータファイルをカメラ30から受信し、受信した所定のデータファイルから複数の分割データファイルを生成し、利用者端末10に順次送信する。このため、本処理では、受信済みのデータファイルを判定することによって、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-5. Effect 5)
Fifth, in the process according to the first embodiment described above, each data file is received from the camera 30, and a plurality of split data files are generated by dividing each data file at a predetermined interval. When a request to send a predetermined data file is received from the user terminal 10, it is determined whether the predetermined data file has already been received, and if the predetermined data file has already been received, the plurality of split data files obtained by dividing the predetermined data file are sequentially transmitted to the user terminal 10. If the predetermined data file has not yet been received, the predetermined data file is received from the camera 30, and a plurality of split data files are generated from the received predetermined data file and sequentially transmitted to the user terminal 10. Therefore, in this process, by determining which data files have already been received, efficient downloading of large video files can be achieved.

〔実施形態2〕
上述してきた実施形態1の構成に加えて、動画ファイルの取得処理およびキャッシュ保存処理を実行するサーバ装置を、エッジ装置20と利用者端末10との間に配置することにより、複数クライアントによる大容量動画ファイルのダウンロード要求において、エッジ装置20への不要な通信を抑制することが可能となる。そこで、実施形態2では、エッジ装置20と利用者端末10との間にサーバ40が配置された情報処理の例について説明する。
[Embodiment 2]
In addition to the configuration of the first embodiment described above, by disposing a server device that executes video file acquisition processing and cache storage processing between the edge device 20 and the user terminal 10, it becomes possible to suppress unnecessary communication to the edge device 20 when multiple clients request download of large video files. Therefore, in the second embodiment, an example of information processing in which a server 40 is disposed between the edge device 20 and the user terminal 10 will be described.

以下に、実施形態2に係る情報処理システム100-2の構成、サーバ40の構成、各処理の流れを順に説明し、最後に実施形態2の効果を説明する。なお、上述した実施形態1と同様の構成や処理については説明を省略する。 Below, we will explain the configuration of the information processing system 100-2 and server 40 according to the second embodiment, as well as the flow of each process, and finally explain the effects of the second embodiment. Note that we will omit explanations of configurations and processes that are similar to those of the first embodiment described above.

〔1.情報処理システム100-2の構成〕
図5を用いて、実施形態2に係る情報処理システム100-2の構成を詳細に説明する。図5は、実施形態2に係る情報処理システム100-2の構成例を示す図である。以下に、情報処理システム100-2全体の構成例、情報処理システム100-2の処理を順に説明し、最後に情報処理システム100-2の効果について説明する。なお、実施形態2では、実施形態1と同様にカメラ30が収集した動画ファイルのダウンロードを一例にして説明するが、データファイルを限定するものではなく、画像ファイルや音声ファイル等の様々なデータファイルの情報処理に適用することができる。
1. Configuration of Information Processing System 100-2
The configuration of the information processing system 100-2 according to the second embodiment will be described in detail using FIG. 5. FIG. 5 is a diagram showing an example of the configuration of the information processing system 100-2 according to the second embodiment. Below, an example of the overall configuration of the information processing system 100-2, the processing of the information processing system 100-2, and finally the effects of the information processing system 100-2 will be described. Note that in the second embodiment, as in the first embodiment, downloading a video file collected by the camera 30 will be described as an example, but the present invention is not limited to data files, and can be applied to information processing of various data files such as image files and audio files.

(1-1.情報処理システム100-2全体の構成例)
情報処理システム100-2は、利用者Uが使用するクライアント装置である利用者端末10、エッジゲートウェイであるエッジ装置20、収集機器であるカメラ30およびサーバ40を有する。ここで、利用者端末10とエッジ装置20とカメラ30とサーバ40とは、図示しない所定の通信網を介して、有線または無線により通信可能に接続される。例えば、サーバ40とエッジ装置20とは、LTEや閉域網等の広域通信網によって接続される。また、サーバ40と利用者端末10とは、イントラネット(Intranet)によって接続される。また、エッジ装置20とカメラ30とは、イーサネット(登録商標)等の構内通信網によって接続される。
(1-1. Example of the overall configuration of the information processing system 100-2)
The information processing system 100-2 includes a user terminal 10, which is a client device used by a user U, an edge device 20, which is an edge gateway, a camera 30, which is a collection device, and a server 40. The user terminal 10, the edge device 20, the camera 30, and the server 40 are communicatively connected via a predetermined communication network (not shown), either wired or wirelessly. For example, the server 40 and the edge device 20 are connected via a wide area communication network such as LTE or a closed area network. The server 40 and the user terminal 10 are connected via an intranet. The edge device 20 and the camera 30 are connected via an in-house communication network such as Ethernet (registered trademark).

図5に示した情報処理システム100-2には、複数台の利用者端末10、複数台のエッジ装置20、複数台のカメラ30または複数台のサーバ40が含まれてもよい。また、エッジ装置20は、カメラ30と統合された構成であってもよい。また、エッジ装置20は、サーバ40と統合された構成であってもよい。 The information processing system 100-2 shown in FIG. 5 may include multiple user terminals 10, multiple edge devices 20, multiple cameras 30, or multiple servers 40. The edge device 20 may also be configured to be integrated with the camera 30. The edge device 20 may also be configured to be integrated with the server 40.

(1-2.情報処理システム100-2全体の処理)
上記のような情報処理システム100-2全体の処理について説明する。なお、下記のステップS21~S30は、異なる順序で実行することもできる。また、下記のステップS21~S30のうち、省略される処理があってもよい。
(1-2. Overall processing of the information processing system 100-2)
The overall processing of the information processing system 100-2 as described above will be described. Note that the following steps S21 to S30 may be executed in a different order. Also, some of the following steps S21 to S30 may be omitted.

まず、カメラ30は、動画ファイルを収集する(ステップS21)。次に、エッジ装置20は、カメラ30が収集した動画ファイルを受信する(ステップS22)。このとき、エッジ装置20は、カメラ30からストリーム配信された動画ファイルを受信するが、特に限定されず、カメラ30の記憶部に記憶された動画ファイルを受信することもできる。 First, the camera 30 collects video files (step S21). Next, the edge device 20 receives the video files collected by the camera 30 (step S22). At this time, the edge device 20 receives video files streamed from the camera 30, but this is not limited thereto and the edge device 20 can also receive video files stored in the memory unit of the camera 30.

続いて、エッジ装置20は、受信した動画ファイルを分割動画ファイルとして保存する(ステップS23)。このとき、エッジ装置20は、任意の時間単位で分割された分割動画ファイル(例:1分)を時系列順に保存する。図5で示すように、エッジ装置20は、「12:01」の1分間の「データ01」、「12:02」の1分間の「データ02」、「12:03」の1分間の「データ03」・・・を分割動画ファイルとして保存する。また、エッジ装置20は、一定のデータ容量ごとに分割動画ファイルを保存することもできる。 The edge device 20 then saves the received video file as divided video files (step S23). At this time, the edge device 20 saves the divided video files, which have been divided into arbitrary time units (e.g., 1 minute), in chronological order. As shown in Figure 5, the edge device 20 saves "Data 01" for the 1 minute at "12:01," "Data 02" for the 1 minute at "12:02," "Data 03" for the 1 minute at "12:03," and so on, as divided video files. The edge device 20 can also save divided video files for each fixed data capacity.

そして、サーバ40は、エッジ装置20が生成した分割動画ファイルを受信する(ステップS24)。また、サーバ40は、受信した分割動画ファイルをキャッシュする(ステップS25)。すなわち、サーバ40は、受信した分割動画ファイルをサーバ40内のキャッシュ領域にキャッシュデータとして格納する。このとき、サーバ40は、キャッシュ領域以外の記憶領域に分割動画ファイルを格納することもできる。 Then, the server 40 receives the divided video files generated by the edge device 20 (step S24). The server 40 also caches the received divided video files (step S25). That is, the server 40 stores the received divided video files as cache data in a cache area within the server 40. At this time, the server 40 can also store the divided video files in a storage area other than the cache area.

利用者端末10は、サーバ40に対して、任意の期間(例:1時間)の動画ファイルの送信をリクエストする(ステップS26)。サーバ40は、リクエストされた動画ファイルのキャッシュを確認する(ステップS27)。このとき、サーバ40は、エッジ装置20に対して、キャッシュにない分割動画ファイルの送信をリクエストし、当該分割動画ファイルを受信し、キャッシュする(ステップS28)。そして、サーバ40は、利用者端末10に対して、受信した分割動画ファイルを送信する(ステップS29)。このとき、サーバ40は、受信済みの分割動画ファイルを先に送信してもよいし、リクエストされた分割動画ファイルをすべて受信してから分割動画ファイルを送信してもよい。 The user terminal 10 requests the server 40 to send video files for an arbitrary period (e.g., one hour) (step S26). The server 40 checks the cache of the requested video files (step S27). At this time, the server 40 requests the edge device 20 to send any divided video files that are not in the cache, receives the divided video files, and caches them (step S28). The server 40 then transmits the received divided video files to the user terminal 10 (step S29). At this time, the server 40 may first transmit the divided video files that have already been received, or may transmit the divided video files after receiving all of the requested divided video files.

最後に、利用者端末10は、リクエストした期間の分割動画ファイルの受信が完了した場合には、受信した分割動画ファイルを時系列順に結合し、大容量の動画ファイルを生成する(ステップS30)。 Finally, when the user terminal 10 has completed receiving the split video files for the requested period, it combines the received split video files in chronological order to generate a large-capacity video file (step S30).

(1-3.情報処理システム100-2の効果)
上述した情報処理システム100-2では、エッジ装置20は、カメラ30から動画ファイルを受信し、受信した動画ファイルを所定間隔で分割した分割動画ファイルを生成し、サーバ40に送信する。また、サーバ40は、受信した分割動画ファイルをキャッシュ領域に格納する。一方、利用者端末10は、サーバ40に、動画ファイルの送信要求を送信し、複数の分割動画ファイルを、サーバ40から受信する。サーバ40は未受信部分の分割動画ファイルを利用者端末10に送信する。このとき、サーバ40は、送信要求された動画ファイルをキャッシュ領域に保持していない場合には、未受信部分の分割動画ファイルをエッジ装置20に送信要求して受信する。そして、利用者端末10は、すべての分割動画ファイルの受信が完了した場合には、受信した分割データファイルを結合した大容量動画ファイルを生成する。
(1-3. Effects of Information Processing System 100-2)
In the information processing system 100-2 described above, the edge device 20 receives a video file from the camera 30, divides the received video file at predetermined intervals to generate divided video files, and transmits the divided video files to the server 40. The server 40 stores the received divided video files in a cache area. Meanwhile, the user terminal 10 transmits a video file transmission request to the server 40 and receives multiple divided video files from the server 40. The server 40 transmits the divided video files of the unreceived portions to the user terminal 10. At this time, if the video file requested to be transmitted is not stored in the cache area, the server 40 requests the edge device 20 to transmit the divided video files of the unreceived portions, and receives them. Then, when the user terminal 10 has completed receiving all the divided video files, it generates a large-capacity video file by combining the received divided data files.

このため、情報処理システム100-2では、上述した情報処理システム100-1の効果に加えて、複数のクライアントが重複した期間の動画を取得したい際であっても、サーバ40における未ダウンロードの動画ファイルをエッジ装置20から取得するだけで、指定の大容量動画ファイルをローカルに保存することが可能となる。また、情報処理システム100-2では、より高い可用性が求められる際には、複数台のサーバ40で同じエッジ装置20群と接続し、クライアントは動作しているサーバ40にアクセスすることで冗長化が実現可能となる。 For this reason, in addition to the effects of information processing system 100-1 described above, information processing system 100-2 allows multiple clients to locally store specified large-capacity video files, even when they wish to obtain video from overlapping periods, simply by obtaining undownloaded video files from server 40 from edge device 20. Furthermore, when higher availability is required, information processing system 100-2 can achieve redundancy by connecting multiple servers 40 to the same group of edge devices 20, and clients can access the operating servers 40.

〔2.情報処理システム100-2の各装置の構成〕
図6を用いて、図5に示した情報処理システム100-2が有する各装置の機能構成について説明する。図6は、実施形態に係るサーバ40の構成例を示すブロック図である。以下では、実施形態2に係る情報処理システム100-2全体の構成例を説明した上で、実施形態2に係るサーバ40の構成例および具体例について詳細に説明する。なお、利用者端末10、エッジ装置20およびカメラ30の構成および処理については、上述した実施形態1に係る情報処理システム100-1と共通するので、説明を省略する。
2. Configuration of each device in the information processing system 100-2
The functional configuration of each device included in the information processing system 100-2 shown in FIG. 5 will be described using FIG. 6. FIG. 6 is a block diagram showing an example configuration of the server 40 according to the embodiment. Below, an example configuration of the entire information processing system 100-2 according to the second embodiment will be described, followed by a detailed description of an example configuration and specific examples of the server 40 according to the second embodiment. Note that the configurations and processing of the user terminal 10, edge device 20, and camera 30 are common to those of the information processing system 100-1 according to the first embodiment described above, and therefore will not be described here.

(2-1.情報処理システム100-2全体の構成例)
情報処理システム100-2は、利用者端末10、エッジ装置20、カメラ30およびサーバ40を有する。利用者端末10とサーバ40とは、イントラネット等の通信網によって通信可能に接続されている。エッジ装置20とサーバ40とは、LTEや閉域網等の通信網によって通信可能に接続されている。また、エッジ装置20とカメラ30とは、イーサネット(登録商標)等の通信網によって通信可能に接続されている。
(2-1. Example of the overall configuration of the information processing system 100-2)
The information processing system 100-2 has a user terminal 10, an edge device 20, a camera 30, and a server 40. The user terminal 10 and the server 40 are communicatively connected via a communication network such as an intranet. The edge device 20 and the server 40 are communicatively connected via a communication network such as LTE or a closed area network. The edge device 20 and the camera 30 are communicatively connected via a communication network such as Ethernet (registered trademark).

(2-2.サーバ40の構成例)
図6を用いて、情報提供装置であるサーバ40の構成例について説明する。サーバ40は、通信部41、キャッシュ領域42および制御部43を有する。なお、サーバ40は、サーバ40の管理者等から各種操作を受け付ける入力部(例えば、キーボードやマウス等)や、各種情報を表示するための表示部(例えば、液晶ディスプレイ等)や、各種データを記憶する記憶部を有してもよい。
(2-2. Example of the configuration of the server 40)
An example configuration of a server 40, which is an information providing device, will be described with reference to Fig. 6. The server 40 has a communication unit 41, a cache area 42, and a control unit 43. The server 40 may also have an input unit (e.g., a keyboard, a mouse, etc.) that accepts various operations from an administrator of the server 40, a display unit (e.g., a liquid crystal display, etc.) that displays various information, and a storage unit that stores various data.

(2-2-1.通信部41)
通信部41は、他の装置との間でのデータ通信を司る。例えば、通信部41は、ルータ等を介して、各通信装置との間でデータ通信を行う。また、通信部41は、図示しないオペレータの端末との間でデータ通信を行うことができる。
(2-2-1. Communication unit 41)
The communication unit 41 controls data communication with other devices. For example, the communication unit 41 performs data communication with each communication device via a router, etc. The communication unit 41 can also perform data communication with an operator's terminal (not shown).

(2-2-2.キャッシュ領域42)
キャッシュ領域42は、キャッシュデータを記憶する。例えば、キャッシュ領域42は、後述する制御部43の格納部43bによって格納された、分割動画ファイルのキャッシュデータを記憶する。
(2-2-2. Cache area 42)
The cache area 42 stores cache data, for example, cache data of divided video files stored by a storage unit 43b of the control unit 43 (to be described later).

(2-2-3.制御部43)
制御部43は、当該サーバ40全体の制御を司る。制御部43は、受信部43a、格納部43b、判定部43c、送信部43dおよび削除部43eを有する。ここで、制御部43は、例えば、CPUやMPU等の電子回路やASICやFPGA等の集積回路により実現され得る。
(2-2-3. Control unit 43)
The control unit 43 controls the entire server 40. The control unit 43 has a receiving unit 43a, a storage unit 43b, a determining unit 43c, a transmitting unit 43d, and a deleting unit 43e. Here, the control unit 43 can be realized by, for example, an electronic circuit such as a CPU or an MPU, or an integrated circuit such as an ASIC or an FPGA.

(2-2-3-1.受信部43a)
受信部43aは、データファイルが所定間隔で分割された複数の分割データファイルを、情報処理装置から順次受信する。例えば、受信部43aは、1分単位で分割された分割動画ファイル「データ01」、「データ02」、・・・「データ60」を、エッジ装置20から順次受信する。また、受信部43aは、収集機器であるカメラ30から各データファイルを受信することもできる。このとき、受信部43aは、所定間隔で分割されていないデータファイルを受信した場合には、分割された複数の分割データファイルを生成することもできる。ここで、分割されたデータファイルの間隔は、一定間隔には限られず、データ送受信のプロトコルとしてあらかじめ規定されているものであれば、一定でなくてもよい。
(2-2-3-1. Receiving unit 43a)
The receiving unit 43a sequentially receives from the information processing device a plurality of split data files, each of which is obtained by splitting a data file at a predetermined interval. For example, the receiving unit 43a sequentially receives split video files "Data 01,""Data02," ... "Data 60," each of which is split in one-minute increments, from the edge device 20. The receiving unit 43a can also receive each data file from the camera 30, which is a collection device. In this case, if the receiving unit 43a receives a data file that is not split at a predetermined interval, it can also generate a plurality of split data files. Here, the intervals between the split data files are not limited to a fixed interval and do not have to be fixed as long as they are predefined as a data transmission/reception protocol.

受信部43aは、クライアント装置から所定のデータファイルの送信要求を受信する。また、受信部43aは、クライアント装置から所定のデータファイルの再送要求を受信する。 The receiving unit 43a receives a request to send a specified data file from a client device. The receiving unit 43a also receives a request to resend a specified data file from a client device.

さらに、受信部43aは、複数の情報処理装置のうち、クライアント装置によって送信要求されたデータファイルを保持する対象装置を特定し、特定した対象装置から、当該データファイルの複数の分割データファイルを受信する。例えば、受信部43aは、複数のエッジ装置20のうち、利用者端末10によって送信要求された動画ファイルを保持するエッジ装置20を特定し、特定したエッジ装置20から当該動画ファイルの分割動画ファイルを受信する。 Furthermore, the receiving unit 43a identifies, from among the multiple information processing devices, a target device that holds the data file requested to be sent by the client device, and receives multiple split data files of the data file from the identified target device. For example, the receiving unit 43a identifies, from among the multiple edge devices 20, an edge device 20 that holds a video file requested to be sent by the user terminal 10, and receives the split video files of the video file from the identified edge device 20.

(2-2-3-2.格納部43b)
格納部43bは、受信した複数の分割データファイルを所定領域に格納する。例えば、格納部43bは、複数の分割データファイルそれぞれをキャッシュデータとしてキャッシュ領域に格納する。また、格納部43bは、受信した複数の分割データファイルを図示しない記憶部に格納することもできる。
(2-2-3-2. Storage section 43b)
The storage unit 43b stores the received divided data files in a predetermined area. For example, the storage unit 43b stores each of the divided data files in a cache area as cache data. The storage unit 43b can also store the received divided data files in a memory unit (not shown).

(2-2-3-3.判定部43c)
判定部43cは、クライアント装置から所定のデータファイルの送信要求を受信した場合には、所定のデータファイルが受信済みか否かを判定する。例えば、判定部43cは、利用者端末10から「データ01」~「データ60」の1時間分の動画ファイルの送信要求を受信した場合には、キャッシュ領域42を参照し、「データ01」、「データ02」、・・・「データ60」の分割動画ファイルの有無を判定する。
(2-2-3-3. Determination unit 43c)
When the determination unit 43c receives a request to send a predetermined data file from a client device, the determination unit 43c determines whether the predetermined data file has already been received. For example, when the determination unit 43c receives a request to send one hour's worth of video files "Data 01" to "Data 60" from the user terminal 10, the determination unit 43c refers to the cache area 42 and determines whether or not the divided video files "Data 01,""Data02," ..., "Data 60" exist.

判定部43cは、クライアント装置から所定のデータファイルの送信要求を受信した場合には、クライアント装置が提供条件を満たすか否かを判定する。例えば、判定部43cは、送信要求を送信した利用者端末10が「外部クライアント」、「社内クライアント」等の提供条件を満たすか否かを判定する。さらに、判定部43cは、提供条件を満たさない場合には、クライアント装置への所定のデータファイルの提供を抑制し、提供条件を満たす場合には、所定のデータファイルが受信済みか否かを判定する。例えば、判定部43cは、送信を要求された動画ファイルが「社内向け」であり、送信を要求した利用者端末10が「外部クライアント」であった場合には、提供条件を満たさないと判定し、当該動画ファイルの分割動画ファイルを送信しない。一方、判定部43cは、送信を要求された動画ファイルが「社内向け」であり、送信を要求した利用者端末10が「社内クライアント」であった場合には、提供条件を満たすと判定し、当該動画ファイルの分割動画ファイルを送信する。 When the determination unit 43c receives a request to send a specified data file from a client device, it determines whether the client device satisfies the provision conditions. For example, the determination unit 43c determines whether the user terminal 10 that sent the transmission request satisfies the provision conditions, such as "external client" or "internal client." Furthermore, if the provision conditions are not met, the determination unit 43c refrains from providing the specified data file to the client device, and if the provision conditions are met, it determines whether the specified data file has already been received. For example, if the video file requested to be sent is "for internal use" and the user terminal 10 that requested the transmission is an "external client," the determination unit 43c determines that the provision conditions are not met and does not send the divided video files of the video file. On the other hand, if the video file requested to be sent is "for internal use" and the user terminal 10 that requested the transmission is an "internal client," the determination unit 43c determines that the provision conditions are met and sends the divided video files of the video file.

(2-2-3-4.送信部43d)
送信部43dは、所定のデータファイルが受信済みである場合には、所定のデータファイルを分割した複数の分割データファイルを、クライアント装置に順次送信する。例えば、送信部43dは、1分単位で分割された分割動画ファイル「データ01」、「データ02」、・・・「データ60」を、利用者端末10に順次送信する。一方、送信部43dは、所定のデータファイルが受信済みではない場合には、所定のデータファイルを分割して生成された複数の分割データファイルを、クライアント装置に順次送信する。例えば、送信部23dは、利用者端末10によって送信要求された「データ61」~「データ70」の動画ファイルが受信済みではない場合には、エッジ装置20から受信部43aによって受信された「データ61」、「データ62」、・・・「データ70」の分割動画ファイルを、利用者端末10に順次送信する。
(2-2-3-4. Transmitting unit 43d)
If the specified data file has already been received, the transmitter 43d sequentially transmits to the client device multiple split data files obtained by dividing the specified data file. For example, the transmitter 43d sequentially transmits to the user terminal 10 split video files "Data 01,""Data02," ... "Data 60" that have been divided in one-minute increments. On the other hand, if the specified data file has not yet been received, the transmitter 43d sequentially transmits to the client device multiple split data files generated by dividing the specified data file. For example, if the video files "Data 61" to "Data 70" requested for transmission by the user terminal 10 have not yet been received, the transmitter 43d sequentially transmits to the user terminal 10 the split video files "Data 61,""Data62," ... "Data 70" received by the receiver 43a from the edge device 20.

送信部43dは、収集された動画、画像、音声等のデータファイルを保持する情報処理装置に、データファイルの送信要求を送信する。例えば、送信部43dは、収集された動画ファイルを保持するエッジ装置20に、「データ01」~「データ60」の1時間分の動画ファイルの送信要求を送信する。また、送信部43dは、特定された最新の分割データファイルの次の分割データファイルからの再送要求を情報処理装置に送信する。例えば、送信部43dは、分割動画ファイルの受信中に通信エラーが発生した場合に、「データ03」まで分割動画ファイルが受信済みであったときには、「データ04」からの分割動画ファイルの再送要求をエッジ装置20に送信する。 The transmitting unit 43d transmits a request to transmit data files to an information processing device that holds the collected data files, such as video, images, and audio. For example, the transmitting unit 43d transmits a request to transmit one hour's worth of video files, "Data 01" to "Data 60," to the edge device 20 that holds the collected video files. The transmitting unit 43d also transmits a request to retransmit the split data file following the latest identified split data file to the information processing device. For example, if a communication error occurs while receiving split video files, and split video files up to "Data 03" have already been received, the transmitting unit 43d transmits a request to retransmit split video files starting from "Data 04" to the edge device 20.

(2-2-3-5.削除部43e)
削除部43eは、キャッシュ領域に格納されるキャッシュデータのデータサイズの総和が閾値を超過した場合には、キャッシュデータのうち参照回数が最も少ないキャッシュデータまたは作成日時が最も古いキャッシュデータを削除する。例えば、削除部43eは、「データ01」、「データ02」、・・・「データ60」を時系列順に受信し、キャッシュ領域に格納していた場合には、最も古い「データ01」を削除する。
(2-2-3-5. Deletion section 43e)
When the sum of the data sizes of the cache data stored in the cache area exceeds a threshold, the deletion unit 43e deletes the cache data that has been referenced the least or the cache data that has the oldest creation date and time. For example, when the deletion unit 43e receives "Data 01,""Data02," ... "Data 60" in chronological order and stores them in the cache area, it deletes the oldest "Data 01."

(2-3.サーバ40の情報処理の具体例)
図7~図8を用いて、上述してきたサーバ40の情報処理の具体例について説明する。図7~図8は、実施形態2に係る情報処理の具体例を示す図である。以下では、複数のサーバ40を多段に配置する具体例1、および複数のサーバ40による提供範囲を限定する具体例2について説明する。
(2-3. Specific example of information processing by server 40)
Specific examples of the information processing of the server 40 described above will be described using Figures 7 and 8. Figures 7 and 8 are diagrams showing specific examples of information processing according to embodiment 2. Below, specific example 1 in which multiple servers 40 are arranged in multiple tiers, and specific example 2 in which the range of services provided by the multiple servers 40 is limited will be described.

(2-3-1.具体例1)
図7を用いて、複数のサーバ40を多段に配置する、サーバ40の情報処理の具体例1について説明する。図7で示すように、カメラ30-1~30-100の100台のカメラ30は、エッジ装置20Aに接続されている。また、カメラ30-101~30-200の100台のカメラ30は、エッジ装置20Bに接続されている。ここで、サーバ40Aは、エッジ装置20Aと接続され、サーバ40Bは、エッジ装置20Bと接続され、サーバ40Cは、サーバ40Aおよびサーバ40Bと接続されている。さらに、サーバ40Cは、利用者UAの利用者端末10A、利用者UBの利用者端末10B、利用者UCの利用者端末10Cおよび利用者UDの利用者端末10Dと接続されている。
(2-3-1. Specific Example 1)
7, a specific example 1 of information processing by a server 40 in which multiple servers 40 are arranged in multiple tiers will be described. As shown in FIG. 7, 100 cameras 30, cameras 30-1 to 30-100, are connected to an edge device 20A. Also, 100 cameras 30, cameras 30-101 to 30-200, are connected to an edge device 20B. Here, server 40A is connected to edge device 20A, server 40B is connected to edge device 20B, and server 40C is connected to servers 40A and 40B. Furthermore, server 40C is connected to user terminal 10A of user UA, user terminal 10B of user UB, user terminal 10C of user UC, and user terminal 10D of user UD.

ここで、利用者UAが利用者端末10Aを介して、カメラ30-1~30-100が収集した動画ファイルをリクエストする例を考える。サーバ40Cは、利用者端末10Aから送信要求を受信し、分割動画ファイルを保持しているエッジ装置20Aを特定し、サーバ40Aを介してエッジ装置20Aからカメラ30-1~30-100が収集した動画ファイルの分割動画ファイルを受信し、当該分割動画ファイルを利用者端末10Aに送信する。 Here, consider an example in which user UA requests video files collected by cameras 30-1 to 30-100 via user terminal 10A. Server 40C receives the transmission request from user terminal 10A, identifies edge device 20A that holds the divided video files, receives the divided video files of the video files collected by cameras 30-1 to 30-100 from edge device 20A via server 40A, and transmits the divided video files to user terminal 10A.

一方、利用者UBが利用者端末10Bを介して、カメラ30-101~30-200が収集した動画ファイルをリクエストする例を考える。サーバ40Cは、利用者端末10Bから送信要求を受信し、分割動画ファイルを保持しているエッジ装置20Bを特定し、サーバ40Bを介してエッジ装置20Bからカメラ30-101~30-200が収集した動画ファイルの分割動画ファイルを受信し、当該分割動画ファイルを利用者端末10Bに送信する。 Now consider an example in which user UB requests video files collected by cameras 30-101 to 30-200 via user terminal 10B. Server 40C receives the transmission request from user terminal 10B, identifies edge device 20B that holds the divided video files, receives the divided video files of the video files collected by cameras 30-101 to 30-200 from edge device 20B via server 40B, and transmits the divided video files to user terminal 10B.

上記のように具体例1で示す情報処理では、多数のカメラ収容が必要である大規模システムにおいて、サーバ40(40A、40B、40C)を多段に配置することにより、クライアントからは単体のサーバ40Cを介してすべてのカメラ30(30-1~30-200)の動画ファイルを参照することが可能となる。 As described above, in the information processing shown in Specific Example 1, in a large-scale system that requires the accommodation of a large number of cameras, by arranging servers 40 (40A, 40B, 40C) in multiple tiers, clients can access video files from all cameras 30 (30-1 to 30-200) via a single server 40C.

(2-3-2.具体例2)
図8を用いて、複数のサーバ40による提供範囲を限定する、サーバ40の情報処理の具体例2について説明する。図8で示すように、カメラ30-1~30-100の100台のカメラ30は、エッジ装置20Aに接続されている。このとき、カメラ30-1~30-10の10台のカメラ30は、外部公開用のカメラとして提供する条件が付与されている。また、カメラ30-1~30-100の100台のカメラ30は、社内向けのカメラとして提供する条件が付与されている。ここで、サーバ40Dおよびサーバ40Eは、エッジ装置20Aと接続されている。さらに、サーバ40Dは、利用者UAの利用者端末10Aおよび利用者UBの利用者端末10Bと接続され、サーバ40Eは、利用者UCの利用者端末10Cおよび利用者UDの利用者端末10Dと接続されている。
(2-3-2. Specific Example 2)
Specific example 2 of information processing by server 40, which limits the scope of information provided by multiple servers 40, will be described using FIG. 8. As shown in FIG. 8, 100 cameras 30, cameras 30-1 to 30-100, are connected to edge device 20A. At this time, 10 cameras 30, cameras 30-1 to 30-10, are assigned a condition to be provided as cameras for public access. Furthermore, 100 cameras 30, cameras 30-1 to 30-100, are assigned a condition to be provided as cameras for internal use. Here, servers 40D and 40E are connected to edge device 20A. Furthermore, server 40D is connected to user terminal 10A of user UA and user terminal 10B of user UB, and server 40E is connected to user terminal 10C of user UC and user terminal 10D of user UD.

ここで、利用者端末10Aおよび利用者端末10Bが外部クライアントであり、利用者端末10Cおよび利用者端末10Dが社内クライアントである例を考える。利用者UAが利用者端末10Aを介して、外部公開用カメラであるカメラ30-1~30-10が収集した動画ファイルをリクエストした場合には、外部公開用のサーバ40Dは、利用者端末10Aが提供条件を満たしているので、当該動画ファイルの分割動画ファイルを利用者端末10Aに送信する。一方、利用者UAが利用者端末10Aを介して、社内向けカメラのみであるカメラ30-11~30-100が収集した動画ファイルをリクエストした場合には、サーバ40Dは、利用者端末10Aが提供条件を満たしていないので、当該動画ファイルの分割動画ファイルを利用者端末10Aに送信しない。なお、社内クライアントである利用者端末10Cおよび利用者端末10Dは、社内向けのサーバ40Eを介して、すべてのカメラ30が収集した動画ファイルを取得することができる。 Here, consider an example in which user terminals 10A and 10B are external clients, and user terminals 10C and 10D are internal clients. When user UA requests, via user terminal 10A, video files collected by cameras 30-1 to 30-10, which are externally accessible cameras, server 40D for external access sends divided video files of the video file to user terminal 10A because user terminal 10A meets the provision conditions. On the other hand, when user UA requests, via user terminal 10A, video files collected by cameras 30-11 to 30-100, which are internally accessible cameras only, server 40D does not send divided video files of the video file to user terminal 10A because user terminal 10A does not meet the provision conditions. User terminals 10C and 10D, which are internal clients, can obtain video files collected by all cameras 30 via internal server 40E.

上記のように具体例2で示す情報処理では、外部への動画ファイルを公開する場合においても、異なるアドレスを持つサーバ40(40D、40E)ごとに公開範囲を限定することが可能である。すなわち、具体例2で示す情報処理では、物理的に異なるサーバ40を用いることで、より高いセキュリティが提供可能となる。 As described above, in the information processing shown in Specific Example 2, even when releasing video files to the outside world, it is possible to limit the scope of release for each server 40 (40D, 40E) with a different address. In other words, in the information processing shown in Specific Example 2, using physically different servers 40 makes it possible to provide higher security.

〔3.情報処理システム100-2の処理の流れ〕
図9を用いて、実施形態2に係る情報処理システム100-2の処理の流れについて説明する。図9は、実施形態2に係る情報処理の流れの一例を示すシーケンス図である。なお、下記のステップS201~S213の処理は、異なる順序で実行することもできる。また、下記のステップS201~S213の処理のうち、省略される処理があってもよい。
3. Processing flow of information processing system 100-2
The processing flow of the information processing system 100-2 according to the second embodiment will be described with reference to Fig. 9. Fig. 9 is a sequence diagram showing an example of the flow of information processing according to the second embodiment. Note that the processing of steps S201 to S213 below can be executed in a different order. Also, some of the processing of steps S201 to S213 below may be omitted.

(3-1.分割データファイル送信処理)
まず、カメラ30は、収集した動画ファイルをストリーム配信する。次に、エッジ装置20は、当該動画ファイルを受信し、受信した動画ファイルから所定の時間単位で分割した分割動画ファイルを生成し、当該分割動画ファイルをサーバ40に送信する(ステップS201)。このとき、サーバ40は、受信した分割動画ファイルをキャッシュする。
(3-1. Divided data file transmission process)
First, the camera 30 streams the collected video file. Next, the edge device 20 receives the video file, divides the received video file into divided video files at predetermined time intervals, and transmits the divided video files to the server 40 (step S201). At this time, the server 40 caches the received divided video files.

(3-2.データファイル生成処理1)
利用者端末10Aは、任意の期間(例:1時間)の動画ファイルのダウンロードを実行する(ステップS202)。このとき、利用者端末10Aは、サーバ40に対して、当該動画ファイルのダウンロードをリクエストする(ステップS203)。一方、サーバ40は、キャッシュを確認する(ステップS204)。このとき、サーバ40は、当該動画ファイルの分割動画ファイルがキャッシュにない場合には、エッジ装置20に対して、キャッシュにない分割動画ファイルのダウンロードをリクエストする(ステップS205)。エッジ装置20は、サーバ40のリクエストに応じて、サーバ40に対して、分割動画ファイルを送信する(ステップS206)。このとき、サーバ40は、受信した分割動画ファイルをキャッシュする。
(3-2. Data file generation process 1)
The user terminal 10A downloads a video file for an arbitrary period (e.g., one hour) (step S202). At this time, the user terminal 10A requests the server 40 to download the video file (step S203). Meanwhile, the server 40 checks its cache (step S204). At this time, if the divided video files of the video file are not in the cache, the server 40 requests the edge device 20 to download the divided video files that are not in the cache (step S205). In response to the request from the server 40, the edge device 20 transmits the divided video files to the server 40 (step S206). At this time, the server 40 caches the received divided video files.

そして、サーバ40は、利用者端末10Aに対して、リクエストされた分割動画ファイルを送信する(ステップS207)。最後に、利用者端末10Aは、リクエストした期間の分割動画ファイルの受信が完了した場合には、受信した分割動画ファイルを結合し、大容量動画ファイルを生成する(ステップS208)。 Then, the server 40 transmits the requested split video files to the user terminal 10A (step S207). Finally, when the user terminal 10A has completed receiving the split video files for the requested period, it combines the received split video files to generate a large-capacity video file (step S208).

(3-3.データファイル生成処理2)
利用者端末10Bは、任意の期間の動画ファイルのダウンロードを実行する(ステップS209)。このとき、利用者端末10Bは、サーバ40に対して、利用者端末10Aと同一の動画ファイルのダウンロードをリクエストする(ステップS210)ことを考える。一方、サーバ40は、キャッシュを確認する(ステップS211)。このとき、サーバ40は、当該動画ファイルの分割動画ファイルがキャッシュに保存済みであるので、利用者端末10Bに対して、リクエストされた分割動画ファイルを送信する(ステップS212)。最後に、利用者端末10Bは、リクエストした期間の分割動画ファイルの受信が完了した場合には、受信した分割動画ファイルを結合し、大容量動画ファイルを生成する(ステップS213)。
(3-3. Data file generation process 2)
User terminal 10B downloads video files for a given period (step S209). At this time, user terminal 10B requests server 40 to download the same video file as user terminal 10A (step S210). Meanwhile, server 40 checks its cache (step S211). At this time, since the split video files of the video file in question have already been saved in the cache, server 40 transmits the requested split video files to user terminal 10B (step S212). Finally, when user terminal 10B has completed receiving the split video files for the requested period, it combines the received split video files to generate a large-capacity video file (step S213).

〔4.実施形態2の効果〕
最後に、実施形態2の効果について説明する。以下では、実施形態2に係る処理に対応する効果1~3について説明する。
4. Effects of the Second Embodiment
Finally, the effects of the second embodiment will be described below. Effects 1 to 3 corresponding to the processing according to the second embodiment will be described below.

(4-1.効果1)
第1に、上述した実施形態2に係る処理では、カメラ30またはエッジ装置20から各データファイルを受信し、各データファイルを所定間隔で分割した複数の分割データファイルを生成し、利用者端末10から所定のデータファイルの送信要求を受信した場合には、所定のデータファイルが受信済みか否かを判定し、所定のデータファイルが受信済みである場合には、所定のデータファイルを分割した複数の分割データファイルを、利用者端末10に順次送信し、所定のデータファイルが受信済みではない場合には、所定のデータファイルをカメラ30またはエッジ装置20から受信し、受信した所定のデータファイルから複数の分割データファイルを生成し、利用者端末10に順次送信する。このため、本処理では、サーバ40を使用することによって、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-1. Effect 1)
First, in the process according to the second embodiment described above, each data file is received from the camera 30 or the edge device 20, and each data file is divided at predetermined intervals to generate a plurality of split data files. When a request to send a predetermined data file is received from the user terminal 10, it is determined whether the predetermined data file has been received, and if the predetermined data file has been received, the plurality of split data files obtained by dividing the predetermined data file are sequentially transmitted to the user terminal 10. If the predetermined data file has not been received, the predetermined data file is received from the camera 30 or the edge device 20, and a plurality of split data files are generated from the received predetermined data file and sequentially transmitted to the user terminal 10. Therefore, in this process, by using the server 40, efficient downloading of large video files can be achieved.

(4-2.効果2)
第2に、上述した実施形態2に係る処理では、それぞれに提供条件が設定された各データファイルから複数の分割データファイルを生成し、利用者端末10から所定のデータファイルの送信要求を受信した場合には、利用者端末10が提供条件を満たすか否かを判定し、提供条件を満たさない場合には、利用者端末10への所定のデータファイルの提供を抑制し、提供条件を満たす場合には、所定のデータファイルが受信済みか否かを判定する。このため、本処理では、サーバ40を使用することによって公開範囲を限定し、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-2. Effect 2)
Second, in the process according to the second embodiment, multiple split data files are generated from each data file, each of which has a provision condition set for it, and when a request to send a predetermined data file is received from the user terminal 10, it is determined whether the user terminal 10 satisfies the provision condition, and if the provision condition is not satisfied, the provision of the predetermined data file to the user terminal 10 is suppressed, and if the provision condition is satisfied, it is determined whether the predetermined data file has already been received. Therefore, in this process, the scope of disclosure is limited by using the server 40, and efficient downloading of large video files can be achieved.

(4-3.効果3)
第3に、上述した実施形態2に係る処理では、サーバ40(40A、40B)と利用者端末10との間の通信を制御するサーバ40Cとを有し、サーバ40Cは、利用者端末10から受信した、いずれかのサーバ40(40A、40B)に対するデータファイルの送信要求を送信し、サーバ40(40A、40B)のうち、データファイルを保持する対象装置を特定し、特定した対象装置から、データファイルの複数の分割データファイルを受信し、利用者端末10に送信する。このため、本処理では、サーバ40を多段階に使用することによって、大容量の動画ファイルの効率的なダウンロードを実現できる。
(4-3. Effect 3)
Thirdly, the process according to the second embodiment described above includes a server 40C that controls communication between the servers 40 (40A, 40B) and the user terminal 10, and the server 40C transmits a data file transmission request received from the user terminal 10 to one of the servers 40 (40A, 40B), identifies a target device among the servers 40 (40A, 40B) that holds the data file, receives multiple split data files of the data file from the identified target device, and transmits them to the user terminal 10. Therefore, in this process, the servers 40 are used in multiple stages, thereby enabling efficient downloading of large video files.

〔システム〕
上記文書中や図面中で示した処理手順、制御手順、具体的名称、各種のデータやパラメータを含む情報については、特記する場合を除いて任意に変更することができる。
〔system〕
The information including the processing procedures, control procedures, specific names, various data and parameters shown in the above documents and drawings can be changed arbitrarily unless otherwise specified.

また、図示した各装置の各構成要素は機能概念的なものであり、必ずしも物理的に図示の如く構成されていることを要しない。すなわち、各装置の分散や統合の具体的形態は図示のものに限られない。つまり、その全部または一部を、各種の負荷や使用状況などに応じて、任意の単位で機能的または物理的に分散・統合して構成することができる。 Furthermore, the components of each device shown in the figure are functional concepts and do not necessarily have to be physically configured as shown. In other words, the specific form of distribution and integration of each device is not limited to that shown. In other words, all or part of the devices can be functionally or physically distributed and integrated in any unit depending on various loads, usage conditions, etc.

さらに、各装置にて行なわれる各処理機能は、その全部または任意の一部が、CPUおよび当該CPUにて解析実行されるプログラムにて実現され、あるいは、ワイヤードロジックによるハードウェアとして実現され得る。 Furthermore, each processing function performed by each device may be realized, in whole or in part, by a CPU and a program analyzed and executed by the CPU, or may be realized as hardware using wired logic.

〔ハードウェア〕
次に、情報処理装置である利用者端末10のハードウェア構成例を説明する。なお、エッジ装置20、サーバ40等の他の装置も同様のハードウェア構成とすることができる。図10は、ハードウェア構成例を説明する図である。図10に示すように、利用者端末10は、通信装置10a、HDD(Hard Disk Drive)10b、メモリ10c、プロセッサ10dを有する。また、図10に示した各部は、バス等で相互に接続される。
[Hardware]
Next, an example of the hardware configuration of a user terminal 10, which is an information processing device, will be described. Note that other devices, such as the edge device 20 and the server 40, may also have a similar hardware configuration. FIG. 10 is a diagram illustrating an example of the hardware configuration. As shown in FIG. 10, the user terminal 10 includes a communication device 10a, a hard disk drive (HDD) 10b, a memory 10c, and a processor 10d. The components shown in FIG. 10 are interconnected via a bus or the like.

通信装置10aは、ネットワークインタフェースカードなどであり、他のサーバとの通信を行う。HDD10bは、図3に示した機能を動作させるプログラムやDBを記憶する。 The communication device 10a is a network interface card or the like, and communicates with other servers. The HDD 10b stores the programs and databases that operate the functions shown in Figure 3.

プロセッサ10dは、図3に示した各処理部と同様の処理を実行するプログラムをHDD10b等から読み出してメモリ10cに展開することで、図3等で説明した各機能を実行するプロセスを動作させる。例えば、このプロセスは、利用者端末10が有する各処理部と同様の機能を実行する。具体的には、プロセッサ10dは、送信部14a、受信部14b、格納部14c、生成部14d、特定部14e、削除部14f等と同様の機能を有するプログラムをHDD10b等から読み出す。そして、プロセッサ10dは、送信部14a、受信部14b、格納部14c、生成部14d、特定部14e、削除部14f等と同様の処理を実行するプロセスを実行する。 Processor 10d reads from HDD 10b, etc., programs that perform the same processing as each processing unit shown in FIG. 3 and expands them into memory 10c, thereby operating processes that perform each function described in FIG. 3, etc. For example, this process performs the same functions as each processing unit possessed by user terminal 10. Specifically, processor 10d reads from HDD 10b, etc., programs that have the same functions as transmitter 14a, receiver 14b, storage unit 14c, generator 14d, identification unit 14e, deletion unit 14f, etc. Then, processor 10d executes processes that perform the same processing as transmitter 14a, receiver 14b, storage unit 14c, generator 14d, identification unit 14e, deletion unit 14f, etc.

このように、利用者端末10は、プログラムを読み出して実行することで各種処理方法を実行する装置として動作する。また、利用者端末10は、媒体読取装置によって記録媒体から上記プログラムを読み出し、読み出された上記プログラムを実行することで上記した実施形態と同様の機能を実現することもできる。なお、この他の実施形態でいうプログラムは、利用者端末10によって実行されることに限定されるものではない。例えば、他のコンピュータまたはサーバがプログラムを実行する場合や、これらが協働してプログラムを実行するような場合にも、本発明を同様に適用することができる。 In this way, the user terminal 10 operates as a device that executes various processing methods by reading and executing programs. The user terminal 10 can also realize functions similar to those of the above-described embodiments by reading the programs from a recording medium using a media reading device and executing the read programs. Note that the programs referred to in these other embodiments are not limited to those executed by the user terminal 10. For example, the present invention can also be applied in the same way when another computer or server executes a program, or when these execute a program in cooperation with each other.

このプログラムは、インターネットなどのネットワークを介して配布することができる。また、このプログラムは、ハードディスク、フレキシブルディスク(FD)、CD-ROM、MO(Magneto-Optical disk)、DVD(Digital Versatile Disc)などのコンピュータで読み取り可能な記録媒体に記録され、コンピュータによって記録媒体から読み出されることによって実行することができる。 This program can be distributed via a network such as the Internet. It can also be recorded on a computer-readable recording medium such as a hard disk, flexible disk (FD), CD-ROM, MO (Magneto-Optical disk), or DVD (Digital Versatile Disc), and can be executed by being read from the recording medium by a computer.

10 利用者端末
11 通信部
12 キャッシュ領域
13 記憶部
13a データファイル記憶部
14 制御部
14a 送信部
14b 受信部
14c 格納部
14d 生成部
14e 特定部
14f 削除部
20 エッジ装置
21 通信部
22 記憶部
22a 分割データファイル記憶部
23 制御部
23a 受信部
23b 生成部
23c 判定部
23d 送信部
30 カメラ
31 収集部
40 サーバ
41 通信部
42 キャッシュ領域
43 制御部
43a 受信部
43b 格納部
43c 判定部
43d 送信部
43e 削除部
100-1、100-2 情報処理システム
10 User terminal 11 Communication unit 12 Cache area 13 Memory unit 13a Data file memory unit 14 Control unit 14a Transmission unit 14b Reception unit 14c Storage unit 14d Generation unit 14e Identification unit 14f Deletion unit 20 Edge device 21 Communication unit 22 Memory unit 22a Divided data file memory unit 23 Control unit 23a Reception unit 23b Generation unit 23c Determination unit 23d Transmission unit 30 Camera 31 Collection unit 40 Server 41 Communication unit 42 Cache area 43 Control unit 43a Reception unit 43b Storage unit 43c Determination unit 43d Transmission unit 43e Deletion unit 100-1, 100-2 Information processing system

Claims (8)

コンピュータに、
収集されたデータファイルを保持する情報処理装置に、前記データファイルの送信要求を送信し、
前記データファイルが所定間隔で分割された複数の分割データファイルを、前記情報処理装置から順次受信して、前記コンピュータの所定領域に格納し、
前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、
処理を実行させ
前記送信する処理は、
前記複数の分割データファイルの受信中に通信エラーが発生した場合に、前記所定領域に格納された分割データファイルのうち最新の分割データファイルを特定し、
特定された前記最新の分割データファイルの次の分割データファイルからの再送要求を前記情報処理装置に送信する、
情報処理プログラム。
On the computer,
Sending a request to transmit the collected data file to an information processing device that holds the data file;
a plurality of divided data files obtained by dividing the data file at predetermined intervals are sequentially received from the information processing device and stored in a predetermined area of the computer;
When reception of the plurality of divided data files has been completed, the data file is generated by combining the plurality of divided data files that have been received and stored in the predetermined area.
Execute the process ,
The transmitting process includes:
If a communication error occurs during reception of the plurality of divided data files, the latest divided data file is identified from among the divided data files stored in the predetermined area;
transmitting a retransmission request from the divided data file next to the latest divided data file identified to the information processing device;
Information processing program.
前記格納する処理は、
前記複数の分割データファイルそれぞれをキャッシュデータとして前記コンピュータのキャッシュ領域に格納し、
前記生成する処理は、
前記複数の分割データファイルの受信が完了した場合には、前記キャッシュ領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、
請求項1に記載の情報処理プログラム。
The storing process includes:
storing each of the plurality of divided data files as cache data in a cache area of the computer;
The generating process includes:
When reception of the plurality of divided data files has been completed, the data file is generated by combining the plurality of divided data files that have been received and stored in the cache area.
The information processing program according to claim 1 .
前記格納する処理は、
前記キャッシュ領域に格納される前記キャッシュデータのデータサイズの総和が閾値を超過した場合には、前記キャッシュデータのうち参照回数が最も少ないキャッシュデータまたは作成日時が最も古いキャッシュデータを削除する、
請求項に記載の情報処理プログラム。
The storing process includes:
When the total data size of the cache data stored in the cache area exceeds a threshold, the cache data with the least number of references or the cache data with the oldest creation date and time is deleted.
The information processing program according to claim 2 .
コンピュータに、
収集機器から各データファイルを受信し、
前記各データファイルを所定間隔で分割した複数の分割データファイルを生成し、
クライアント装置から所定のデータファイルの送信要求を受信した場合には、前記所定のデータファイルが受信済みか否かを判定し、
前記所定のデータファイルが受信済みである場合には、前記所定のデータファイルを分割した複数の分割データファイルを、前記クライアント装置に順次送信し、
前記所定のデータファイルが受信済みではない場合には、前記所定のデータファイルを前記収集機器から受信し、受信した前記所定のデータファイルから前記複数の分割データファイルを生成し、前記クライアント装置に順次送信する、
処理を実行させ
前記生成する処理は、
それぞれに提供条件が設定された前記各データファイルから前記複数の分割データファイルを生成し、
前記判定する処理は、
前記クライアント装置から前記所定のデータファイルの送信要求を受信した場合には、前記クライアント装置が提供条件を満たすか否かを判定し、
前記提供条件を満たさない場合には、前記クライアント装置への前記所定のデータファイルの提供を抑制し、前記提供条件を満たす場合には、前記所定のデータファイルが受信済みか否かを判定する、
情報提供プログラム。
On the computer,
Receive each data file from the acquisition device;
generating a plurality of divided data files by dividing each of the data files at predetermined intervals;
When a request to transmit a predetermined data file is received from a client device, the server determines whether the predetermined data file has already been received;
If the predetermined data file has already been received, a plurality of divided data files obtained by dividing the predetermined data file are sequentially transmitted to the client device;
If the predetermined data file has not been received, the predetermined data file is received from the collection device, and the plurality of divided data files are generated from the received predetermined data file and sequentially transmitted to the client device.
Execute the process ,
The generating process includes:
generating the plurality of divided data files from the data files each having a provision condition set therefor;
The determining process includes:
When a transmission request for the predetermined data file is received from the client device, it is determined whether the client device satisfies a provision condition;
If the provision condition is not satisfied, provision of the predetermined data file to the client device is suppressed, and if the provision condition is satisfied, it is determined whether the predetermined data file has already been received.
Informational program.
第1の情報処理装置と第2の情報処理装置とを有する情報処理システムにおいて、
前記第1の情報処理装置は、
収集機器からデータファイルを受信し、
受信された前記データファイルを所定間隔で分割した分割データファイルを生成する、制御部を有し、
前記第2の情報処理装置は、
前記第1の情報処理装置に、前記データファイルの送信要求を送信し、
前記データファイルが所定間隔で分割された複数の分割データファイルを、前記第1の情報処理装置から順次受信して、所定領域に格納し、
前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、
制御部を有し、
前記第2の情報処理装置の前記制御部は、
前記複数の分割データファイルの受信中に通信エラーが発生した場合に、前記所定領域に格納された分割データファイルのうち最新の分割データファイルを特定し、
特定された前記最新の分割データファイルの次の分割データファイルからの再送要求を前記第1の情報処理装置に送信する、
情報処理システム。
In an information processing system having a first information processing device and a second information processing device,
The first information processing device
Receives data files from acquisition devices;
a control unit that divides the received data file at predetermined intervals to generate divided data files;
The second information processing device
transmitting a request to transmit the data file to the first information processing device;
receiving a plurality of divided data files obtained by dividing the data file at predetermined intervals from the first information processing device in sequence and storing the divided data files in a predetermined area;
When reception of the plurality of divided data files has been completed, the data file is generated by combining the plurality of divided data files that have been received and stored in the predetermined area.
A control unit is provided.
The control unit of the second information processing device
If a communication error occurs during reception of the plurality of divided data files, the latest divided data file is identified from among the divided data files stored in the predetermined area;
transmitting a retransmission request from the divided data file next to the latest divided data file identified to the first information processing device;
Information processing system.
前記情報処理システムは、
複数の前記第1の情報処理装置と、
前記複数の第1の情報処理装置と前記第2の情報処理装置との間の通信を制御する第3の情報処理装置と、を有し、
前記第3の情報処理装置は、
前記第2の情報処理装置からいずれかの第1の情報処理装置に対する前記データファイルの送信要求を受信し、
前記複数の第1の情報処理装置のうち、前記データファイルを保持する対象装置を特定し、
特定された前記対象装置から、前記データファイルの前記複数の分割データファイルを受信し、前記第2の情報処理装置に送信する、
請求項に記載の情報処理システム。
The information processing system includes:
A plurality of the first information processing devices;
a third information processing device that controls communication between the plurality of first information processing devices and the second information processing device;
The third information processing device
receiving a request from the second information processing device to transmit the data file to any one of the first information processing devices;
Identifying a target device that holds the data file from among the plurality of first information processing devices;
receiving the plurality of divided data files of the data file from the identified target device and transmitting the divided data files to the second information processing device;
The information processing system according to claim 5 .
コンピュータが、
データファイルを収集して保持する情報処理装置に、前記データファイルの送信要求を送信し、
前記データファイルが所定間隔で分割された複数の分割データファイルを、前記情報処理装置から順次受信して、前記コンピュータの所定領域に格納し、
前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、
処理を実行し、
前記送信する処理は、
前記複数の分割データファイルの受信中に通信エラーが発生した場合に、前記所定領域に格納された分割データファイルのうち最新の分割データファイルを特定し、
特定された前記最新の分割データファイルの次の分割データファイルからの再送要求を前記情報処理装置に送信する、
情報処理方法。
The computer
Sending a request to transmit the data file to an information processing device that collects and stores the data file;
a plurality of divided data files obtained by dividing the data file at predetermined intervals are sequentially received from the information processing device and stored in a predetermined area of the computer;
When reception of the plurality of divided data files has been completed, the data file is generated by combining the plurality of divided data files that have been received and stored in the predetermined area.
Execute the process ,
The transmitting process includes:
If a communication error occurs during reception of the plurality of divided data files, the latest divided data file is identified from among the divided data files stored in the predetermined area;
transmitting a retransmission request from the divided data file next to the latest divided data file identified to the information processing device;
Information processing methods.
データファイルを収集して保持する情報処理装置に、前記データファイルの送信要求を送信し、
前記データファイルが所定間隔で分割された複数の分割データファイルを、前記情報処理装置から順次受信して、自装置の所定領域に格納し、
前記複数の分割データファイルの受信が完了した場合には、前記所定領域に格納される受信済みの前記複数の分割データファイルを結合した前記データファイルを生成する、
制御部を有し、
前記制御部は、
前記複数の分割データファイルの受信中に通信エラーが発生した場合に、前記所定領域に格納された分割データファイルのうち最新の分割データファイルを特定し、
特定された前記最新の分割データファイルの次の分割データファイルからの再送要求を前記情報処理装置に送信する、
情報処理装置。
Sending a request to transmit the data file to an information processing device that collects and stores the data file;
receiving a plurality of divided data files obtained by dividing the data file at predetermined intervals from the information processing device in sequence and storing the divided data files in a predetermined area of the information processing device;
When reception of the plurality of divided data files has been completed, the data file is generated by combining the plurality of divided data files that have been received and stored in the predetermined area.
A control unit is provided.
The control unit
If a communication error occurs during reception of the plurality of divided data files, the latest divided data file is identified from among the divided data files stored in the predetermined area;
transmitting a retransmission request from the divided data file next to the latest divided data file identified to the information processing device;
Information processing device.
JP2022026860A 2022-02-24 2022-02-24 Information processing program, information providing program, information processing system, information processing method, and information processing device Active JP7794017B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2022026860A JP7794017B2 (en) 2022-02-24 2022-02-24 Information processing program, information providing program, information processing system, information processing method, and information processing device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2022026860A JP7794017B2 (en) 2022-02-24 2022-02-24 Information processing program, information providing program, information processing system, information processing method, and information processing device

Publications (2)

Publication Number Publication Date
JP2023123032A JP2023123032A (en) 2023-09-05
JP7794017B2 true JP7794017B2 (en) 2026-01-06

Family

ID=87885648

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2022026860A Active JP7794017B2 (en) 2022-02-24 2022-02-24 Information processing program, information providing program, information processing system, information processing method, and information processing device

Country Status (1)

Country Link
JP (1) JP7794017B2 (en)

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2003337803A (en) 2002-05-21 2003-11-28 Ntt Me Corp Content illegal acquisition prevention method, content illegal acquisition prevention system and content illegal acquisition prevention program
WO2012011449A1 (en) 2010-07-20 2012-01-26 シャープ株式会社 Proxy server, relay method, communication system, relay control program, and recording medium
JP2013229860A (en) 2012-03-28 2013-11-07 Panasonic Corp Recording device and recording system
JP2017055379A (en) 2015-09-08 2017-03-16 船井電機株式会社 Information apparatus and distribution device
JP2021175026A (en) 2020-04-21 2021-11-01 株式会社東芝 Server device, communication system, and program

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2003337803A (en) 2002-05-21 2003-11-28 Ntt Me Corp Content illegal acquisition prevention method, content illegal acquisition prevention system and content illegal acquisition prevention program
WO2012011449A1 (en) 2010-07-20 2012-01-26 シャープ株式会社 Proxy server, relay method, communication system, relay control program, and recording medium
JP2013229860A (en) 2012-03-28 2013-11-07 Panasonic Corp Recording device and recording system
JP2017055379A (en) 2015-09-08 2017-03-16 船井電機株式会社 Information apparatus and distribution device
JP2021175026A (en) 2020-04-21 2021-11-01 株式会社東芝 Server device, communication system, and program

Also Published As

Publication number Publication date
JP2023123032A (en) 2023-09-05

Similar Documents

Publication Publication Date Title
US20150237113A1 (en) Method and system for file transmission
EP3633957B1 (en) Data storage method, storage server, storage medium and system
US20080072264A1 (en) Distribution of content on a network
CN101652999A (en) Systems and methods for managing live video data
US10609123B2 (en) Hybrid quorum policies for durable consensus in distributed systems
US10447623B2 (en) Data storage systems and methods using a real-time messaging system
CN102833293A (en) Method for downloading resources in peer to server and peer (P2SP) network, and client
CN112910967A (en) Network transmission of large files in unstable network environments
US11895192B1 (en) Managing subscriptions to resource updates made via a target interface
US20170262543A1 (en) Method and system for improving sessions and open files enumerations by data structures changes
US20180343217A1 (en) Providing video to subscribers of a messaging system
CN112417050A (en) Data synchronization method and device, system, storage medium and electronic device
US8775456B2 (en) System and method for scheduled and collaborative distribution of software and data to many thousands of clients over a network using dynamic virtual proxies
CN114610679A (en) Storage device, data storage method thereof and cloud storage system
US10545667B1 (en) Dynamic data partitioning for stateless request routing
CN112866406A (en) Data storage method, system, device, equipment and storage medium
JP7794017B2 (en) Information processing program, information providing program, information processing system, information processing method, and information processing device
CN109996031B (en) Monitoring system and monitoring method
KR100565168B1 (en) An optimal node retrieval apparatus and method for P2P data communication, and a computer-readable recording medium recording a program for executing the method.
WO2024129083A1 (en) Security scan with backup
Lin et al. A fault-tolerant ONVIF protocol extension for seamless surveillance video stream recording
US20040080505A1 (en) Moving picture file distributing device
CN114461446A (en) Double-activity disaster recovery method and device and electronic equipment
CN100525314C (en) Video-recording file transmitting method in multistage video frequency monitoring system
JPH11345179A (en) Data management method, data management system and configuration device, recording medium

Legal Events

Date Code Title Description
A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20240403

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20250127

A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20250304

A521 Request for written amendment filed

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20250425

A131 Notification of reasons for refusal

Free format text: JAPANESE INTERMEDIATE CODE: A131

Effective date: 20250805

A521 Request for written amendment filed

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20251003

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: 20251118

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20251201

R150 Certificate of patent or registration of utility model

Ref document number: 7794017

Country of ref document: JP

Free format text: JAPANESE INTERMEDIATE CODE: R150