JP2017504850A - 接続された装置のデータ管理 - Google Patents

接続された装置のデータ管理 Download PDF

Info

Publication number
JP2017504850A
JP2017504850A JP2016526836A JP2016526836A JP2017504850A JP 2017504850 A JP2017504850 A JP 2017504850A JP 2016526836 A JP2016526836 A JP 2016526836A JP 2016526836 A JP2016526836 A JP 2016526836A JP 2017504850 A JP2017504850 A JP 2017504850A
Authority
JP
Japan
Prior art keywords
data
records
stream
index
chunk
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.)
Granted
Application number
JP2016526836A
Other languages
English (en)
Other versions
JP6426174B2 (ja
JP2017504850A5 (ja
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.)
Microsoft Corp
Microsoft Technology Licensing LLC
Original Assignee
Microsoft Corp
Microsoft Technology Licensing LLC
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 Microsoft Corp, Microsoft Technology Licensing LLC filed Critical Microsoft Corp
Publication of JP2017504850A publication Critical patent/JP2017504850A/ja
Publication of JP2017504850A5 publication Critical patent/JP2017504850A5/ja
Application granted granted Critical
Publication of JP6426174B2 publication Critical patent/JP6426174B2/ja
Expired - Fee Related legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • GPHYSICS
    • G11INFORMATION STORAGE
    • G11BINFORMATION STORAGE BASED ON RELATIVE MOVEMENT BETWEEN RECORD CARRIER AND TRANSDUCER
    • G11B27/00Editing; Indexing; Addressing; Timing or synchronising; Monitoring; Measuring tape travel
    • G11B27/02Editing, e.g. varying the order of information signals recorded on, or reproduced from, record carriers
    • G11B27/031Electronic editing of digitised analogue information signals, e.g. audio or video signals
    • G11B27/034Electronic editing of digitised analogue information signals, e.g. audio or video signals on discs
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/22Indexing; Data structures therefor; Storage structures
    • G06F16/2228Indexing structures
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24Querying
    • G06F16/245Query processing
    • G06F16/2455Query execution
    • G06F16/24553Query execution of query operations
    • G06F16/24562Pointer or reference processing operations
    • GPHYSICS
    • G11INFORMATION STORAGE
    • G11BINFORMATION STORAGE BASED ON RELATIVE MOVEMENT BETWEEN RECORD CARRIER AND TRANSDUCER
    • G11B27/00Editing; Indexing; Addressing; Timing or synchronising; Monitoring; Measuring tape travel
    • G11B27/10Indexing; Addressing; Timing or synchronising; Measuring tape travel
    • G11B27/11Indexing; Addressing; Timing or synchronising; Measuring tape travel by using information not detectable on the record carrier

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Data Mining & Analysis (AREA)
  • Databases & Information Systems (AREA)
  • Physics & Mathematics (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Multimedia (AREA)
  • Software Systems (AREA)
  • Computational Linguistics (AREA)
  • Radar Systems Or Details Thereof (AREA)
  • Closed-Circuit Television Systems (AREA)
  • Storage Device Security (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
  • Signal Processing For Digital Recording And Reproducing (AREA)
  • Indexing, Searching, Synchronizing, And The Amount Of Synchronization Travel Of Record Carriers (AREA)
  • Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
  • Alarm Systems (AREA)
  • Arrangements For Transmission Of Measured Signals (AREA)
  • Information Transfer Systems (AREA)

Abstract

データ管理を容易にする手法及び構成が、接続された装置からなどの時系列データのための改良された応答時間及び空間効率を提供することができる。上記構成は、複数のオブジェクトと該オブジェクトの各々に関連付けられた時間識別とを含む時系列データのストリームを受信することを可能にし得る。1つ以上のタグが、オブジェクトに関連付けられる。上記構成は、さらに、ストリームを複数の連続チャンクへとチャンクにし、各々が複数のオブジェクト含み、時間識別と1つ以上のタグとを関連付ける索引を作成し、チャンクを第1のリモートの記憶装置に送信し、それから、索引を記憶することができる。

Description

関連出願の相互参照
本出願は、2014年7月24日に申請された米国出願第14/340,514号の利益を主張するものであり、上記出願は、2013年10月30日に申請された米国仮出願第61/897,555号の利益を主張するものであり、双方の開示全体が、本明細書において参照により援用される。
本開示は、データ管理の技術分野に関する。
建物、例えば、住宅、倉庫、及びオフィスなどは、ますます、接続された装置で満たされつつある。例えば、監視カメラ、温度センサ、及び/又はモーションセンサが、より一般的になってきている。したがって、こうした装置からのデータを操作するアプリケーションもまた、より普及してきている。しかしながら、上記のアプリケーションにおけるデータ記憶、取り出し、及び共有のためにこれまでに実施又は提案されたシステムは、不十分であり、非効率である可能性がある。
本出願は、接続された装置システムにおいてデータを管理するための、例えば、記憶し、操作し、及び/又は取り出すための、改良されたフレームワーク及び方法を説明する。少なくとも1つの例において、本明細書に説明される手法は、ホームモニタリングシステムから受信されたデータを整形し(format)、記憶する。上記ホームモニタリングシステムには、監視カメラ、モーションセンサ、温度センサ、及び同様のものを含み得る。いくつかの例において、上記方法は、データにタグを付け、タグ/データの索引を作成することができる。索引及びデータは、リモートに、例えば、クラウドベースのストレージ上などに記憶されることができる。いくつかの実施において、索引はローカルに取得され、クエリが、データの関連部分を取得する前に、索引に対してローカルに発行される。下記の議論は、接続されたモニタリング装置システムにわたるデータ取り扱いについての上記及び他の非限定的な例を説明する。いくつかの実施は、アプリケーション設計の柔軟性、ユーザ間での情報の共有、及び/又はデータの改良された保護を可能にすることができる。
本発明の概要は、以下に詳細な説明においてさらに説明される概念のうち選択されたものを簡素化された形式で紹介するために提供される。本発明の概要は、請求される対象事項の重要な特徴又は必須の特徴を識別するものではなく、請求される対象事項の範囲を限定するために使用されるべきものでもない。
詳細な説明は、添付図面を参照して説明される。図面において、参照番号のうち最も左の(1又は複数の)桁は、その参照番号が最初に出現する図を識別する。異なる図における同じ参照番号は同様の又は同一の項目を示す。
本明細書に説明される接続された装置のデータ管理を実施する一例示的環境を表すブロック図である。 図1の環境に例示されたコンピューティング装置などの一例示的なコンピューティンす装置を表すブロック図である。 接続された装置のデータ管理を実行することができる一例示的な処理アーキテクチャを表すブロック図である。 接続された装置のデータ取り出しを実行することができる一例示的な処理アーキテクチャを表すブロック図である。 本明細書に説明される接続された装置のデータ管理を実施する一例示的なデータレイアウトを表すブロック図である。 本明細書に説明される接続された装置のデータ管理を実施する一例示的なデータレイアウトを表すブロック図である。
本明細書に説明される例は、処理ユニット及びアクセラレータを例として含むリソースを用いて、接続された装置からのデータなどのデータを管理する手法及び構成を提供する。上記リソースは、指定された機能を実施するための専用のプログラミング及び/又は特定の命令でプログラムされたハードウェアを用いて実施されることができる。例えば、リソースは、グラフィックス処理ユニット(GPU)とコンピュータ処理ユニット(CPU)との場合のように、異なる実行モデルを有することができる。
本開示の実施において、情報を記憶する方法が、複数の装置から、複数のオブジェクトと該オブジェクトの各々に関連付けられた時間識別とを含む時系列データのストリームを受信することを含む。オブジェクトは、例えば、値(例えば、温度値)、画像(例えば、監視カメラから)、及び/又は2値の指標(例えば、モーション検出器からの存在/不在)であり得る。
上記方法は、1つ以上のタグを、オブジェクトの各々に関連付けることをさらに含むことができる。いくつかの実施において、タグは、オブジェクトの属性を説明することができ、検索可能であって、例えば、タグ付けされたオブジェクトを後の日付又は時間において取り出す(retrieve)ことができる。タグは、例えば、装置/センサ上で実行されるアプリケーションによってなどで、装置/センサにおいて適用されることができる。他の実施において、ユーザがタグを手動で入力することができ、あるいは、タグが他の方法で、装置/センサ上以外で、データストリームに関連付けられてもよい。上記方法は、タグ付けされたオブジェクトのストリームを複数の連続チャンクへとチャンクにすることをさらに含むことができ、連続チャンクの各々は、複数の上記オブジェクトを含む。本開示による手法は、チャンクを圧縮し及び/又は暗号化し、チャンクを記憶することができる。いくつかの実施において、上記方法は、データストリームの索引を作成することをさらに含む。索引は、時間識別とタグとにおける関連付けを含むことができ、本開示の方法は、チャンクとは別個に索引を記憶することができる。一例において、チャンクはリモートに記憶されることができ、一方で、索引はローカルに検索される。他の例示的な実施において、ユーザが、索引のローカルクエリを作ることができ、上記方法は、クエリを満足するオブジェクトを有するチャンクを取り出すことができる。
本明細書に説明される手法は、さらに、ユーザ選好を利用してデータを記憶することができる。例えば、ユーザは、関連付けられた装置に由来するデータが他のユーザに利用可能であるかを決めることができる。すなわち、ユーザが、自身に由来する情報へのアクセスを承認することになる。ユーザは、さらに、情報の記憶タイプを選択して、例えば、データをユーザの装置及び/又は記憶制約に合わせることができる。他の態様において、本明細書に説明されるフレームワークに従って記憶されるデータは、機密性があり、改ざんが明白であり(tamper evident)、及び/又は新鮮であり得る。
データ管理フレームワークの例が、下記の説明及び添付の図面において、さらに詳細に提示される。
本明細書に説明される例は、装置/センサからのデータを維持すること及び操作することに適用可能な手法及び構成を提供する。様々な事例において、本明細書に説明される手法を実行するようにモジュール又はAPIからのプログラミングを介して構成される処理ユニットには、GPU、フィールドプログラマブルゲートアレイ(FPGA)、別のクラスのデジタルシグナルプロセッサ(DSP)、又は他のハードウェアロジックコンポーネントのうち、1つ以上を含むことができ、上記は、いくつかの事例において、CPUにより駆動され得る。限定ではなく、例えば、使用され得る例示的なタイプのハードウェアロジックコンポーネントには、特定用途向け集積回路(ASIC)、特定用途向け標準製品(ASSP)、システムオンチップ・システム(SOC)、複合プログラマブルロジックデバイス(CPLD)等が含まれる。
様々な例、シナリオ、及び態様が、図1〜図6を参照してさらに説明される。
図1は、一例示的な環境100を示しており、環境100を使用して、データ記憶及び取り出しを含む、監視システムにおけるデータ管理及び取り扱いを実施することができる。環境100は、監視されるべき場所に配設された複数のモニタリング装置102を含む。示される例では、2つの場所が監視されることになり、ゆえに、2セットのモニタリング装置102がある。モニタリング装置102は、個々に、センサ104と通信インターフェース106とを含み、センサ104により感知されたオブジェクトと該オブジェクトに関連付けられたタイムスタンプとを含む時系列データのストリームを出力する。例示的なモニタリング装置102は、これらに限られないが、カメラ、モーションセンサ、温度センサ、及び同様のものを含み得る。
環境100は複数のコンピューティング装置108をさらに含み、各々が1つ以上のモニタリング装置に関連付けられる。一実施において、各コンピューティング装置108は異なるユーザ又は異なる場所に関連付けられる。例えば、モニタリング装置102が住宅監視装置である事例において、各住宅はその独自のコンピューティング装置108を有する。他の例において、例えば、複数の住宅及び/又は監視装置に対して、単一のコンピューティング装置108のみが使用されてもよい。一例において、コンピューティング装置108は、例えばホームセキュリティ又は監視会社などの、サードパーティサービスプロバイダに存在し、あるいは他の方法で該サービスプロバイダによって制御されてもよい。
コンピューティング装置108は、様々なカテゴリ又はクラスの装置、例えば、従来のクライアントタイプ装置、デスクトップコンピュータタイプ装置、モバイルタイプ装置、専用目的タイプ装置、組み込みタイプ装置、及び/又はウェアラブルタイプ装置などに属し得る。コンピューティング装置108は、異なる様々な装置タイプを含むことができ、いかなる特定タイプの装置にも限定されない。コンピューティング装置108は、これらに限られないが、モバイルフォンなどの電気通信装置、タブレットコンピュータ、モバイルフォン/タブレットハイブリッド装置、パーソナルデジタルアシスタント(PDA)、ラップトップコンピュータ、他のモバイルコンピュータ、ウェアラブルコンピュータ、埋め込みコンピューティング装置、デスクトップコンピュータ、パーソナル(例えば、デスクトップ)コンピュータ、自動車用コンピュータ、ネットワーク対応テレビジョン、シンクライアント、端末、ゲームコンソール、ゲーム用装置、ワークステーション、メディアプレーヤ、パーソナルビデオレコーダ(PVR)、セットトップボックス、カメラ、コンピューティング装置に含めるための統合コンポーネント、電化製品、又は任意の他の種類のコンピューティング装置を含み得る。
コンピューティング装置108の各々は、少なくとも1つのプロセッサ110とメモリ112とを有する。1つのプロセッサ110と1つのメモリ112とだけが例示されているが、複数のプロセッサ110、複数のメモリ装置112、又は双方があってもよい。プロセッサ110は単一の処理ユニット又は複数のユニットであってよく、上記ユニットの各々が複数の異なる処理ユニットを含み得る。プロセッサ110は、マイクロプロセッサ、マイクロコンピュータ、マイクロコントローラ、デジタルシグナルプロセッサ、中央処理ユニット(CPU)、グラフィックス処理ユニット(GPU)、セキュリティプロセッサ等を含み得る。別法として、又はさらに、本明細書に説明される手法のうちいくつか又はすべてが、少なくとも部分的に、1つ以上のハードウェアロジックコンポーネントによって実行されることができる。限定ではなく、例えば、使用され得る例示的なタイプのハードウェアロジックコンポーネントには、特定用途向け集積回路(ASIC)、特定用途向け標準製品(ASSP)、ステートマシン、複合プログラマブルロジックデバイス(CPLD)、他のロジック回路、システムオンチップ(SOC)、及び/又は命令に基づいて動作を実行する任意の他の装置が含まれる。他の能力の中でも、プロセッサ110は、メモリ112に記憶されたコンピュータ可読命令を取得し及び/又は実行するように構成されることができる。
メモリは、コンピュータ可読媒体のうち1つ又は組み合わせを含み得る。本明細書において使用されるとき、「コンピュータ可読媒体」は、コンピュータ記憶媒体と通信媒体とを含む。
コンピュータ可読媒体には、コンピュータ可読命令、データ構造、プログラムモジュール又は他のデータなどの情報の記憶のために任意の方法又はテクノロジーにおいて実施される揮発性及び不揮発性の、取外し可能及び取外し不能の媒体が含まれる。コンピュータ可読媒体は、これらに限られないが、相変化メモリ(PRAM)、スタティックランダムアクセスメモリ(SRAM)、ダイナミックランダムアクセスメモリ(DRAM)、他のタイプのランダムアクセスメモリ(RAM)、読取専用メモリ(ROM)、電気的消去可能プログラマブルROM(EEPROM)、フラッシュメモリ若しくは他のメモリテクノロジー、コンパクトディスクROM(CD‐ROM)、デジタル多用途ディスク(DVD)若しくは他の光学記憶装置、磁気カセット、磁気テープ、磁気ディスクストレージ若しくは他の磁気記憶装置、又はコンピューティング装置によるアクセスのために情報を記憶することに使用することができる任意の他の媒体が含まれる。
対照的に、通信媒体は、搬送波などの変調されたデータ信号に、コンピュータ可読命令、データ構造、プログラムモジュール、又は他のデータを含む。本明細書において定義されるとき、コンピュータ記憶媒体は通信媒体を含まない。
メモリ112のコンピュータ可読媒体に記憶される実行可能命令には、例えば、オペレーティングシステム、データ管理フレームワーク114、及び/又は、処理ユニット110によりロード可能及び実行可能な他のモジュール、プログラム、若しくはアプリケーションを含み得る。別法として、又はさらに、本明細書に説明される機能性は、少なくとも部分的に、アクセラレータなどの1つ以上のハードウェアロジックコンポーネントによって実行されることができる。限定ではなく、例えば、使用され得る例示的なタイプのハードウェアロジックコンポーネントには、FPGA、ASIC、ASSP、SOC、CPLD等が含まれる。例えば、アクセラレータは、FPGAファブリックに組み込まれたCPUコースを含むZYLEX又はALTERAのうちの1つなどの、ハイブリッド装置を表し得る。
図1にさらに例示されるとおり、コンピューティング装置108はさらに、例えばネットワーク120を介して、互いに、並びにローカル記憶装置116及びリモート記憶装置118に、通信可能に結合される。
例えば、ネットワーク120は、インターネットなどのパブリックネットワーク、機関及び/又は個人のイントラネットなどのプライベートネットワーク、又は、プライベートネットワークとパブリックネットワークとの何らかの組み合わせを含むことができる。ネットワーク120は、任意タイプの有線及び/又はワイヤレスネットワークをさらに含むことができ、これらに限られないが、ローカルエリアネットワーク(LAN)、ワイドエリアネットワーク(WAN)、衛星ネットワーク、ケーブルネットワーク、Wi‐Fiネットワーク、WiMaxネットワーク、モバイル通信ネットワーク(例えば、3G、4G、及び同様のもの)、又はこれらの任意の組み合わせが含まれる。ネットワーク120は、インターネットプロトコル(IP)、トランスミッションコントロールプロトコル(TCP)、ユーザデータグラムプロトコル(UDP)、又は他のタイプのプロトコルなどの、パケットベース及び/又はデータグラムベースのプロトコルを含む通信プロトコルを利用することができる。さらに、ネットワーク120は、スイッチ、ルータ、ゲートウェイ、アクセスポイント、ファイアウォール、基地局、リピータ、バックボーン装置、及び同様のものなどの、ネットワーク通信を容易にし及び/又はネットワークのハードウェア基盤を形成する複数の装置をさらに含むことができる。
いくつかの例において、ネットワーク120は、ワイヤレスアクセスポイント(WAP)などのワイヤレスネットワークに対する接続を可能にする装置をさらに含むことができる。ネットワークは、電気電子技術者協会(IEEE)802.11標準(例えば、802.11g、802.11n、及び同様のもの)及び他の標準をサポートするWAPを含む、様々な電磁気的周波数(例えば、無線周波数)を通じてデータを送信及び受信するWAPによる接続性をサポートし得る。
ローカル記憶装置116は、概して、コンピューティング装置108に関連付けられたデータベースなどのメモリ及び/又はデータストレージを参照する。一例において、ローカル記憶装置は、コンピューティング装置108のハードドライブ上に記憶されたメモリを参照し得る。いくつかの他の実施において、ローカル記憶装置116は、コンピューティング装置108のうち1つ以上とネットワークを共有するデータベース及び/又はメモリを参照し得る。ローカル記憶装置116は、ファイアウォールについて、コンピューティング装置108と同じ側にあり得る。
リモート記憶装置118は、概して、コンピューティング装置108から遠隔のメモリ及び/又はデータ記憶装置を参照し得る。リモート記憶装置118は、別個の場所における記憶装置又はクラウドベースのストレージを含み得る。
例示されるとおり、コンピューティング装置108‐1、108‐2の双方が、同じ記憶装置116、118にアクセスすることができる。本開示のいくつかの実施において、1つのコンピューティング装置108‐1に関連付けられたユーザが、第2のコンピューティング装置108‐2に由来する情報にアクセスすることを承認されることができる。例えば、各コンピューティング装置108が、特定の近隣の家と監視カメラを含むモニタリング装置とに関連付けられる事例において、近隣のある家が、隣人の監視カメラからの監視映像をダウンロードし、見ることが可能であり得る。当然ながら、それぞれの装置108‐1、108‐2の所有者/ユーザは、隣人によるこうしたアクセスを承認する必要があることになる。
図2は、コンピューティング装置108をより詳細に示している。例示されるとおり、プロセッサ110及びメモリ112に対して追加して、コンピューティング装置108は、通信インターフェース202をさらに含む。通信インターフェース202は、装置102、108と、並びにローカル記憶装置114及びリモート記憶装置116と通信する。インターフェース202は、有線又はワイヤレスのインターフェースなどの、複数の異なるインターフェースを含み得る。さらに、インターフェース202は、1つ以上の入出力(I/O)インターフェースを含み、コンピューティング装置108が入力/出力装置、例えば、周辺入力装置(例えば、キーボード、マウス、ペン、ゲームコントローラ、音声入力装置、タッチ入力装置、ジェスチャの(gestural)入力装置、及び同様のもの)を含むユーザ入力装置、及び/又は周辺出力装置(例えば、ディスプレイ、プリンタ、オーディオスピーカ、触覚に関する(haptic)出力、及び同様のもの)を含む出力装置などと、通信することを可能にすることができる。インターフェース202は1つ以上のネットワークインターフェースをさらに含むことができ、このことは、例えば、ネットワークを通じて通信を送信し及び受信するネットワークインターフェースコントローラ(NIC)又は他のタイプの送受信器装置を表すことができる。
図2にさらに例示されるとおり、メモリ112はオペレーティングシステム204を含み、オペレーティングシステム204は、装置内の、及び該装置に結合されたハードウェア及びサービスを、他のモジュール、コンポーネント、及び装置の利益のために管理するように構成される。
メモリ112はデータ管理フレームワーク114をさらに含む。フレームワーク114は、プロセッサ110上で実行可能な1つ以上のソフトウェア及び/又はファームウェアのモジュール及び/又はAPIを含み、本明細書に説明されるデータ管理機能及び手法を含む様々な機能を実施することができる。モジュール及び/又はAPIはブロック206、208、210、212、及び214として例示されているが、これは単に一例であり、ブロックの数はより多く又はより少なく変化してもよい。ブロック206、208、210、212、及び214に関連付けられて説明される機能性は、組み合わせられて、より少ない数のモジュール及び/又はAPIによって実行されてもよく、あるいは、分割され、より多い数のモジュール及び/又はAPIによって実行されてもよい。モジュール/APIは、プロセッサ上で実行可能なソフトウェア及び/又はファームウェアであるとして説明されているが、他の例において、モジュールのうち任意のもの又はすべてが、全体として又は部分的に、ハードウェアによって(例えば、ASIC、専用処理ユニット等として)実施されて説明される機能を実行してもよい。
図2の例において、ブロック206はタグ付けモジュールを概して表し、該モジュールは、モニタリング装置102などのセンサ又は感知装置から受信されたデータストリームにタグを付けるようにプロセッサ110をプログラムするロジックを有する。例えば、タグは、データストリーム内の情報のテキスト説明を含むことができる。タグは、アプリケーション固有であってもよい。例えば、データストリームが監視カメラなどのカメラからの画像を含むとき、タグ付けモジュールは、画像内のオブジェクトに対応する1つ以上のタグを適用することができる。例えば、「自動車」、「動物」、及び/又は「人間」などのタグが、こうした特徴を含むデータストリーム内の上記画像に適用されてもよい。いくつかの実施において、タグ付けモジュールはモニタリング装置102又はセンサ014において動作し得る。こうした実施において、装置108は、既にタグ付けされたデータストリームを受信することができる。
ブロック208は索引付けモジュールを概して表し、該モジュールは、タグ付けされたデータストリームの索引を作成するように処理ユニット110をプログラムするロジックを有する。索引は、データ上のタイムスタンプとデータ内のオブジェクトに関連付けられたタグとの関連付けを含むことができる。索引は検索可能であり、データストリームから別個に維持されることができる。一実施において、索引はローカルに存在すると同時に、データストリームは、クラウドベースのストレージ内などに、リモートに記憶されることができる。
ブロック210はチャンク化モジュール(chunking module)を表し、該モジュールは、データストリームを複数の連続チャンクへと分割するようにプロセッサ110をプログラムするロジックを有する。チャンクは、各々、連続した時間についてのオブジェクト/タグペアを包含する。チャンクのサイズは、例えばアプリケーション開発者によって、構成可能であり得る。サイズは様々な要因に基づいてよく、該要因は、これに限られないが、データオブジェクトのサイズを含む。チャンクは、記憶の前に、他の方法で処理されてもよい。例えば、チャンクは、より効率的な記憶のために圧縮されてもよい。チャンクは、具体的に図4を参照して、以下により詳細に説明される。
ブロック212は暗号化モジュールを表し、該モジュールは、チャンクを暗号化するように処理ユニット110をプログラムするロジックを有する。いくつかの例において、チャンクはリモートに記憶されることが意図され、暗号化モジュールは記憶の前にチャンクを暗号化することができる。例示されていないが、暗号化モジュールは、信頼された鍵サーバ(図示されていない)又は同様のものと通信して、チャンクを暗号化/解読するスキームを確立してもよい。例示的なスキームが、以下により詳細に論じられる。
ブロック214はユーザインターフェースモジュールを表し、該モジュールは、ユーザが本明細書に説明されるシステムと相互作用するために1つ以上のインターフェースのディスプレイに命令するように処理ユニット110をプログラムするロジックを有する。例えば、上記モジュールは、ディスプレイ又は他のユーザインターフェースと関連して、ユーザがデータストリームに対して規則を設定することを可能にするインターフェースを提供することができる。例えば、インターフェースを通して、ユーザは、チャンクサイズを定義し、チャンクのために使用される記憶装置のタイプを規定し、あるいはデータストリームに対する他の属性又はポリシーを入力することができる。
他の実施において、ユーザインターフェースモジュールは、さらに、上記で説明された索引付けモジュールによって作成された索引などの索引をユーザが問い合わせることができるインターフェースを容易にすることができる。いくつかの実施において、索引は、ユーザの装置からのデータストリームに関連付けられることができ、一方、別の実施において、索引は、他の、すなわち、ユーザにより所有/稼働されていないモニタリング装置からの、データストリームに関連付けられることができる。例えば、ある住宅所有者が、近隣における他の住宅からの監視映像の索引を問い合わせることができ得る。当然ながら、ユーザ及び隣人は、自身の映像をアクセス可能にするか又はプライベートを保たせることを可能にするオプションを有することになる。こうしたオプションは、ユーザインターフェースモジュールによって容易にされた制御を通して行使されることができる。さらに、チャンクは暗号化されてもよく、ユーザは、例えば鍵の受信を通して、データにアクセスすることを承認される。
複数のモジュールがコンピューティング装置108のメモリ112に存在するものとして例示されたが、このことは必要とはされない。上記モジュールのうちいくつか又はすべてが、コンピューティング装置108以外に存在してもよい。例えば、タグ付けモジュール、又は同様のタグ付けスキームを実行するモジュールが、モニタリング装置102において実施されてもよく、したがって、モニタリング装置102から出力されるストリームは、タグを既に含む。同様に、タグ付けは、モニタリング装置102とコンピューティング装置108との間のアプリケーション動作によって行われてもよい。同様の変更が、本開示の利益と共に、当業者に明らかになるであろう。
例示されているコンピューティング装置108はバス216をさらに含み、いくつかの事例において、バス216は、システムバス、データバス、アドレスバス、PCIバス、ミニPCIバス、並びに任意の様々なローカルの、ペリフェラルの、及び/又は独立のバスうち、1つ以上を含み得る。バス216は、コンピュータ可読媒体112を処理ユニット110に動作可能に接続することができる。
図3は、データ管理を容易にするようにデータ管理フレームワークが実行することができる処理の、一例示的なアーキテクチャ300を表すブロック図である。いくつかの例において、データ管理フレームワーク114は、すべての処理を実行することになる。他の実施において、アーキテクチャ300のうちいくつか又はすべてが、装置102において、又は他の場所で実行されてもよい。
アーキテクチャ300は、概して、上記で説明された感知装置102から受信されたデータなどの、センサデータ302を含む。例示的な実施において、センサデータ302は、各レコードがタイムスタンプと1つ以上のタグ値とのペアを有する、データストリームである。例えば、データストリームは、<タイムスタンプ,<値1>,[<値2>,...]>の形式を取ることができる。このタイプのデータは、単一のライタ、例えばモニタリング装置102によって書かれてもよい。単一のライタは、新しいデータを生成するだけでもよく、例えば、ライタは、ランダムアクセス更新又は削除を実行しなくてもよい。
アーキテクチャ300は、304において、センサデータ302にタグを付けることを含む。タグは、概して、データストリーム内のデータのオブジェクトタイプに関する情報を含むことができる。例えば、監視カメラからのデータストリームについて、タグは、「動物」、「人間」、「自動車」、及び同様のものを含み得る。エネルギーデータ解析システムにおいて、タグは、「加熱消費」、「水消費」、及び同様のものを含み得る。こうして、タグは、アプリケーション固有であり得る。センサデータにタグを付けるアプリケーションは、モニタリング装置102上で、コンピューティング装置108上で、又は他のいずれかの場所で実行されることができる。
308において、アーキテクチャ300は、タグ付けされたセンサデータを受信する。本開示の例示的な実施において、タグを有するデータストリームは、<タイムスタンプ,<タグ1,値1>,[<タグ2,値2>,...]>の形式を有する。別個のストリームが、複数の異なる基準によって識別可能であり得る。例えば、ストリームは、3つのタプル(three-tuple)、すなわち、<HomeID,AppID,StreamID>によって一意に識別されることができる。上記で述べられたとおり、アーキテクチャ300は、装置108においてセンサデータ304にタグを付けることを含み得る。
アーキテクチャ300は、306において、データ管理情報を受信することをさらに含む。データ管理情報は、概して、感知装置102から受信されたデータストリームが取り扱われるやり方を制御することになる任意の情報を含む。データ管理情報は、プログラマによって、ユーザによって、及び/又はいずれかの他の人若しくは手段によって決定されてよい。
いくつかの例において、データ管理情報は、データストリームのタイプを識別することができる。いくつかの実施において、データストリームのタイプは、データストリームに包含されるデータ値のサイズに基づいて区別することができる。例えば、温度値及び存在/不在指標は、一般に、画像及びビデオストリームよりかなり小さい。したがって、いくつかの実施は、小さいデータ値と大きいデータ値との間で区別することになる。
データ管理情報は、別法として、又はさらに、データストリームが記憶されるべき場所を指定することができる。例えば、データストリーム、データストリームの一部、又はデータストリームに関連付けられた情報(例えば、索引、タグ、及び同様のものなど)が、ローカルに及び/又はリモートに記憶されることができる。さらに、データのうちいくらか又はすべてが、複製されてもよい。
データ管理情報は、別法として、又はさらに、データストリーム又は同様のものなどのデータが保護されるべきかを指定することができる。例えば、データは暗号化されてもよく、あるいは、保護されていなくてもよい。さらに、多数の暗号化スキームのうちの1つ以上が、データ管理情報によって指定されてもよい。
データ管理情報は、さらに、又は別法として、データへのアクセスに関する情報を含むことができる。一例において、ユーザが、他のアプリケーション又はユーザに対して、データストリーム又は関連付けられた情報に対する読み出しアクセスを承諾し、あるいは取り消すことができる。例えば、上記情報は、あるユーザに関連付けられた装置102からのデータが他のユーザと共有されるべきかを命令することができる。ここで説明されたデータ管理情報は、単に例を提供することが意図される。データについての他の属性がデータ管理情報の中に記憶されてもよい。
310において、アーキテクチャ300は、タグ付けされたセンサデータをチャンクにする(chunks)。上記で述べられたとおり、データは、連続したタイムスタンプのオブジェクトエントリから成るデータストリームを含む。データレコードが、ストリームごとにログに記録されることができ、このことは、効率的なアペンド専用書き込み(append-only writes)を可能にすることができる。本明細書において使用されるとき、チャンクは、いくらかの長さ又はレコードの連続シーケンスで形成される。本開示の態様に従い、チャンクは、記憶及び取り出しのためのデータの伝送の基本単位である。例えば、データライタが、個々のレコードに代わってチャンクをアップロードし、リーダが、チャンクを取得する(fetch)。いくつかの事例において、例えば、単一の既知のレコードにのみ関心があるため、チャンクを取り出すことが非効率である可能性がある。しかしながら、より頻繁に、時間ウィンドウからのすべてのレコードに関心があり、チャンクは、時間的局所性を有する共通のクエリをより効率的にすることを、経験が示している。
312において、チャンクは、圧縮され、かつ/あるいは暗号化されることができる。圧縮すること及び/又は暗号化することに対する命令が、306において受信されるデータ管理情報に包含されてもよい。一般に、チャンクを圧縮することは、伝送及び記憶効率を向上させる。一例示的な暗号化スキームにおいて、所有者(すなわち、装置102又は装置108の所有者)により生成される暗号鍵を使用して、チャンクが暗号化される。さらに、上記暗号鍵を使用して、索引が暗号化されてもよい。上記の例は、ゆったりした取り消し(レイジーリボケーション)(lazy revocation)を使用して暗号法動作の計算オーバーヘッドを低減させる。レイジーリボケーションは、追い払われたリーダが将来のコンテンツにアクセスすることのみ防止する。リボケーションの前のコンテンツは、上記リーダによってすでにアクセスされ、キャッシュされている可能性があるからである。さらに、上記の例において、ハッシュベースの鍵の回帰(キーリグレッション)(key regression)が、鍵管理スキームとして使用される。このスキームは、どのリーダがすべての事前の鍵を導出してコンテンツを解読することができるかに基づいて、所有者が、承認されたリーダと、最も直近の鍵のみ共有することを可能にする。上記の例において、信頼された鍵サーバを使用して、鍵が配布されてもよい。こうして、いったんストリームがオープンされると、すべての後続の読み出し及び書き込みが、記憶サーバとアプリケーションとの間で直接発生する。さらに、上記の例において、所有者はストリームコンテンツのハッシュを生成することができ、上記ハッシュはリーダによって検証されることができる。ストリームメタデータの一部として鮮度時間ウィンドウを含むことによって、鮮度がチェックされることができる。このウィンドウは、データが新鮮であると見なされ得るときまでの時間を表すことができ、こうした時間は、所有者が新しいデータの生成を予期する周期性に基づくことができる。時間ウィンドウは、306において受信されるデータ管理情報の一部であってもよい。所有者は、周期的に時間ウィンドウを更新し、署名することができ、このことを、ストリームがいつオープンされるかに対して、リーダがチェックすることができる。
314において、アーキテクチャ300は、ストリーム内のチャンクの索引を作成する。索引は、例えば時間及び/又はタグによって、検索可能である。
316及び318において、チャンク及び索引はそれぞれ記憶される。本開示の実施において、チャンクは、例えばリモート記憶装置118上に、リモートに記憶され、索引は、例えばローカル記憶装置116上に、ローカルに記憶され、あるいは他の方法で利用可能である。いくつかの実施において、索引はリモート記憶装置から取得され、コピーがリーダ及びライタにおいてローカルに記憶される。データは、依然としてリモートに存在してもよい。索引をローカルに記憶することによって、エンドポイントにおけるクエリが、ローカル索引に対して作られることができる。チャンクの識別がローカルでされることができるため、リモート記憶装置において計算(クエリエンジン)は必要とされない。こうした実施において、記憶サーバは、データ読み出し/書き込みAPIを提供するだけでもよい。このことは、記憶システムのコストを低減させることができる。
さらに、索引とチャンクとを別個に記憶することは、データ管理フレームワーク114が記憶サーバについてのその信頼の仮定を緩めることを可能にすることができる。例えば、チャンクを暗号化することによって、いくつかの実施は、データ機密性を損なうことなしに、信頼されていないリモートの、例えばクラウドの、プロバイダをサポートすることができる。チャンクは、アップロードにおいて暗号化され、ダウンロードの後に解読されてもよい。リモート記憶装置においてルックアップが行われてもよいが、こうした配置は、記憶装置プロバイダがより多くの情報を有し、潜在的にチャンクのセキュリティを減少させることを恐らく要することになる。
いくつかの実施において、書き込まれるデータのみが、既存のストリームにアペンドされる新しいデータであるため、ストリームは、かなり大きく成長する可能性がある。上記で説明されたチャンク化及び記憶手法は、効率的な問い合わせを依然として可能にすると同時に、ストリームの連続部分をセグメントへとアーカイブすることをサポートする。各チャンクの記憶場所は構成されることができ、同じストリーム内のデータが異なる記憶装置プロバイダにわたって記憶されることが可能になる。ゆえに、本開示の様々な実施において、ストリームは、ローカルに又は信頼されていないサーバ上にリモートに記憶され、信頼性のために複製され、かつ/あるいはコスト効率性のために複数の記憶装置プロバイダにわたってストライプにされる(striped)ことができる。上記フレームワークを使用するアプリケーションは、スペース、パフォーマンス、コスト、及び信頼性の記憶要件に優先順位をつけることができ得る。
図4は、データ管理フレームワークにおけるデータの取り出しを容易にするようにデータ管理フレームワークが実行することができる処理の一例示的なアーキテクチャ400を表すブロック図である。いくつかの例において、データ管理フレームワーク114は、すべての処理を実行することになる。他の実施において、アーキテクチャ400のうちいくつか又はすべてが、装置102において、又は他の場所で実行されてもよい。
402において、アーキテクチャ400は、索引のクエリを受信する。いくつかの例において、クエリは、314において作成される索引などのローカル索引に対して作られる。別法として、又はさらに、クエリは複数の索引に対して行われてもよい。索引は、任意数のモニタリング装置102からのストリームから成ってもよく、該ストリームは、適切な認証を仮定して、問い合わせているユーザ以外のユーザに関連付けられた装置に関連付けられたストリームを含み得る。例示されていない、402に対する事前のカーソルが、索引をローカルに受信することであり得る。例えば、索引、又は、索引のより新しいバージョンが、リモートに記憶される場合である。他の実施において、1つの索引が、すべてのセンサからのすべてのデータストリームに関する情報を含んでもよく、検索は、該索引に対して行われる。
索引は、少なくとも、索引付けされたデータに関する時間及びタグ情報を含み得る。したがって、クエリは、特定の時間期間からのエントリ、若しくは特定のタグでタグ付けされたエントリ、又は双方を要求することができる。索引は、クエリを介して検索可能であり得る追加情報をさらに記憶してもよい。
404において、アーキテクチャ400は、クエリを満足する情報を包含する1つ又は複数のチャンクを決定する。いくつかの例において、クエリへの応答において、個々のレコードは検索されない。代わって、複数のレコードを包含するチャンクが返される。チャンクの性質のため、決定されたチャンクは、クエリを満足するレコードに対して追加で、検索クエリにマッチしない1つ以上のレコードを包含し得る。
406において、アーキテクチャ400は、402において作られたクエリを満足するレコードを含むよう、404において決定された1つ以上のチャンクを要求する。いくつかの例において、チャンクは、クラウドベースのストレージシステムなどにリモートに記憶され、ゆえにチャンクは、リモートの記憶システムから要求される。他の実施において、チャンクは、その他の方法で記憶装置から取り出されてもよい。
408において、要求されたチャンクはアーキテクチャ400によって受信され、必要とされる場合、410において、チャンクは解読される。上記で論じられたとおり、チャンクを暗号化することは、特にローカルに索引が記憶され、すべてのクエリが行われるとき、リモート記憶装置におけるより緩くされたセキュリティ標準を容易にし得る。
アーキテクチャ300、400の例示的な実施は、複数のストリームAPIを用いて実行されることができる。一実施に従うこうしたストリームAPIには、下記が含まれる。
上記の例示的な実施において、アプリケーションは、<HomeID,AppID>ペアによって識別され、読み出し又は書き込みを行うプリンシパルである。アプリケーションは、例えば、装置108上に記憶され、かつ/あるいは装置108上で実行されることができる。上記の例では、create及びopenにおいて、アプリケーションはポリシーを指定する。上記ポリシーは、ストリームのタイプ、記憶場所、並びに保護及び共有要件を含み得る。他の例において、追加の又は他のポリシーがアプリケーションによってさらに指定されてもよい。さらに、複数の例が、アプリケーションがポリシーを指定することを説明しているが、ユーザ、例えば所有者などが、ポリシーを指定してもよい。上記の例において、2つのタイプのストリーム、すなわち、ValueStream又はFileStreamが指定され得る。この実施において、ValueStreamは、温度読み出しなどの小さいデータ値に有用であり、FileStreamは、画像又はビデオなどのより大きい値に有用である。2つのストリームは別様に記憶されてもよい。
上記の例示的な実施において、各ストリームは、1つのライタ(例えば、所有者)と1つ以上のリーダとを有する。ライタは、appendを用いてストリームに時間・タグ・値レコードを追加する。レコードは、複数のタグ・値ペアと1つの値のための複数のタグとを有することができる。タグ及び値は、一例示的な実施においてIKey及びIValueインターフェースを実施する、アプリケーションにより定義されたタイプであり、ハッシュすること、比較すること、及び/又はシリアライズすることを可能にする。さらに、上記の実施において、ライタは、他のアプリケーションに対して/他のアプリケーションからの、読み出しアクセスを承諾し(grant)、取り消す(revoke)ことができる。リーダは、タグ及び時間を用いて、データをフィルタし、問い合わせることができる(get*)。上記で列挙され説明されたAPIは、最新の(latest)レコード、あるタグについての最新のレコード、時間範囲及びサンプリングクエリ、並びに複数タグにおける範囲クエリについて、問い合わせることをサポートする。このフレームワークにおいて、範囲クエリはイテレータを返し、該イテレータは、アクセスされたときにオンデマンドでデータを取得する。
上記の例示的な実施において、所有者は、新しいデータストリームを最初作成し、それに対してデータレコードをアペンドする。図5は、ストリームのデータレイアウト500を例示している。このストリームは、住宅又は他の建物の外部に設置され得るセキュリティカメラなどの監視カメラからの情報についてのValueStreamに関する画像データを含む。図示されるとおり、500は、データレコードのログ502と索引504とを含み、索引504は、タグ506をデータ項目識別子508のリストにマップする。この例において、項目識別子508は固定サイズのエントリであり、索引の中の項目識別子のリストは時間(例えば、タイムスタンプts)でソートされる。この配置は、範囲及びサンプリングクエリについて、効率的な2値検索を可能にすることができる。この例示的な配置において、索引はメモリ常駐であり、ファイルによって裏付けられ(backed)てもよい。ログ502の中のレコードは、ディスク上に、例えばリモートに記憶され、アプリケーションによって参照されるときに取り出されることができる。ログ502は、連続したデータレコード512のチャンク510へと分割される。チャンク510は、サイズにおいて固定されてもよい。
時間と共に大きく成長する可能性がある索引のメモリフットプリントを低減するために、ストリームはアーカイブされてもよい。いくつかの例において、ストリームはセグメント化され、各セグメントはその独自のログと対応する索引とを有する。ゆえに、ストリームは、セグメントについての時間で順序付けされたリストとして見ることができる。この例において、メモリにおける索引のサイズが、構成可能な閾値(indextresh)を超える場合、最新のセグメントは封印され(sealed)、その索引はディスクにフラッシュされ、メモリ常駐の索引を有する新しいセグメントが作成される。このフレームワークにおいて、ストリームに対する書き込みは最新のセグメントに進み、ストリームのすべての他のセグメントは読取専用エントリである。ストリームの最新セグメントの索引は、メモリ常駐とすることができ、例えばリモートに記憶され、ファイルによって裏付けられてもよい。
図6には、封印されたセグメントのレイアウトが示されている。図6は、コンパクトな索引602がローカルの記憶のために作成されていることを除き、図5と同様である。コンパクト索引602は、タグ506と、各タグについての、対応する項目識別子リスト内の最初及び最後の識別子のタイムスタンプ(ts)と、索引内での該リストの場所とを含む。この例において、コンパクト索引がローカルに記憶され、索引504がさらにディスクに記憶されてもよい。いくつかの実施において、索引はリモートに記憶されてもよいが、ローカルクエリのためにローカルに取得されることができる。
次に、一例に従うストリームデータのアップロードが説明される。説明される例において、各々のプリンシパル(principal)(例えば、<HomeID,AppID>ペア)は、秘密・公開(private-public)鍵ペアに関連付けられることができ、各ストリームは、秘密鍵Kconで暗号化されることができる。秘密鍵は、所有者によって生成されることができる。ストリームが同期され、あるいはクローズされるとき、フレームワークは、ディスクに対して索引をフラッシュし、セグメントログをチャンクにし、チャンクを圧縮し及び暗号化し、チャンクのリスト、本明細書においてChunkListを生成することができる。ChunkListは、各セグメントについての、セグメント内のすべてのチャンクについての順序付けされたリストと、該チャンクの対応するハッシュ(図6においてハッシュ(チャンク#1)、ハッシュ(チャンク#2)等として示されている)である。上記の機能は、好ましくは、データアペンドに起因して変更されている可能性があるすべての新しいセグメントに対して実行される。
上記の例において、フレームワークは、ストリームの完全性メタデータ(MDint)を生成して、ストリームデータと共にアップロードする。nが、ストリーム内のセグメントの数であるとき、MDintは、下記のとおり、式(1)に従って計算される。
TTLは、データ鮮度に対する保証を提供し、ゆえに、記憶サーバから取得されたデータが、構成可能なライタ指定の一貫性期間より古くなく、いかなる事前に取り出されたデータよりも古くないことを確保することができる。MDintは、所有者がデータ鮮度(TTL)を保証する継続時間と、セグメントごとの索引及びChunkListのハッシュとの、署名されたハッシュである。チャンク、更新されたChunkList、及び変更された索引は、記憶サーバに対してアップロードされることができる。その後、MDintがアップロードされてもよい。それから、ストリームメタデータはメタデータサーバにアップロードされてもよい。メタデータサーバは、承認されていない更新を防止する、信頼された鍵サーバであり得る。メタデータ/鍵サーバは、鍵と、ストリームのメタデータとを配布することができる。他の実施において、メタデータサーバ上に記憶される情報は、2f+1のサーバ上に複製されて、最大fの悪意のあるサーバに耐えることができる。別法として、ビザンチンクォーラムシステム(Byzantine quorum system)が採用されてもよい。
メタデータ/鍵サーバは、使用されるとき、プリンシパル対公開鍵のマッピングと、データを暗号化し及び解読するための対称コンテンツ鍵(Kcon)と、データに対するアクセスを有するプリンシパル(所有者を含む)と、MDintの場所と、セグメントごとの場所及び鍵バージョンとを維持し得る。Kconは、記憶のために暗号化されてもよく、公開鍵を用いてストリームに対するアクセスを有する各プリンシパルについて1つのエントリがあり得る。
アプリケーション読み出しアクセスを承諾するために、一実施において、所有者は、リーダの公開鍵を用いて暗号化されたKconを用いてストリームメタデータを更新する。読み出しアクセスを取り消すことは、上記で説明されたAPIを用いてストリームメタデータを更新することをさらに含む。一実施において、所有者は、アクセス者のリストから適切なプリンシパルを除去し、暗号化されたコンテンツ鍵を除去し、すべての有効なプリンシパルのためのコンテンツ鍵及び鍵バージョンをロールフォワードする。この例において、セグメント内のすべてのチャンクが、同じバージョンのコンテンツ鍵を用いて暗号化される。
チャンクからストリームデータを読み出すために、フレームワークは、ストリームをオープンし、ストリームメタデータを取得し得る。それから、この情報を用いて、ストリームの完全性メタデータMDintは、例えば、信頼されていない記憶装置から取得され得る。完全性メタデータは、所有者の公開鍵を用いて検証されることができ、鮮度は、MDint内のTTLを用いて検証されることができる。それから、リーダは、ストリームのセグメントごとの索引及びChunkListを取得し、その完全性をMDintを用いて検証する。
所有者は、索引データの完全性を検証するにおいて、ストリーム内に新しいデータレコードを記憶することができる。リーダにおいて、すべてのセグメントの索引及びChunkList完全性検証が完了すると、索引を使用して、取得されるべきチャンクが識別される。上記で説明されたとおり、この例において、チャンクレベル完全性は、例えば、チャンクをダウンロードすることとその完全性をセグメントのChunkListを用いて検証することとによって、ゆったりと(lazily)チェックされる。この例において、検証されたチャンクは解読され、かつ/あるいは解凍されてもよく、チャンクは、後続の読み出しのためにローカルに、例えばキャッシュに記憶されてもよい。上記で述べられたとおり、取り出されたチャンクは、クエリにより実際に要求された情報に対して追加的な情報を有し得る。より具体的に、各チャンクは複数のレコードを有することがあり、該レコードのうちいくつかがクエリを満足し、該レコードのうちいくつかは満足しない可能性がある。ゆえに、チャンクがキャッシュに記憶されるとき、後続の異なるクエリもまた、キャッシュされたチャンクによって満足され、要求された情報のより効率的な取り出しをもたらす可能性がある。
上記で説明されたシステムなどの例示的なシステムは、.NETフレームワークv4.5上でC#を用いて実施されてもよい。上記の例示的な実施は、HomeOSプラットフォームに統合されてもよいが、さらに、独立のライブラリとして使用されてもよい。クライアントライブラリは、データのシリアライゼーションに対してProtocol Bufferを使用してもよく、リモート記憶装置に対してWindows Azure及びAmazon S3を使用することが可能であり得る。実施は、リモートにデータを読み出し及び書き込むためのそれぞれのライブラリを使用してもよい。いくつかのタイプのリモート記憶装置において、各セグメントはコンテナにマップされることができ、データの索引及びログがブロブ(blob)にマップされ、個々のチャンクはデータのログを包含するブロブの一部にマップされる。別のタイプのリモート記憶装置において、各セグメントはバケットにマップされ、索引はオブジェクトにマップされ、ログのチャンクは個々のオブジェクトにマップされる。
例示的な節
A:複数の装置から、複数のレコードと該レコードの各々に関連付けられた時間識別とを含む時系列データのストリームを受信するステップと、1つ以上のタグを、上記レコードのうちの個々のレコードに関連付けるステップと、上記ストリームを、複数の連続チャンクへとチャンクにするステップであって、上記連続チャンクの各々は複数のレコードを含む、ステップと、上記時間識別と上記1つ以上のタグとを関連付ける索引を作成するステップと、上記チャンクの各々を、第1のリモートの記憶場所に送信するステップと、上記索引を第2のローカルの記憶場所に記憶するステップと、を含む方法。
B:上記複数の装置は、第1のユーザに関連付けられた第1の物理的場所に関連付けられ、上記索引のクエリを受信するステップと、上記クエリを満足する1つ以上のレコードを決定するステップと、上記第1のリモートの記憶場所から、上記クエリを満足する上記1つ以上のレコードを含む1つ以上のチャンクを取り出すステップと、をさらに含む段落Aに記載の方法。
C:上記クエリは、時間的要件又はタグ識別のうち少なくとも1つを含む、段落A又はBのいずれかに記載の方法。
D:取り出された上記チャンクは、上記クエリを満足する上記1つ以上のレコードに対して追加的なレコードを含む、段落A乃至Cのうちいずれか1つに記載の方法。
E:ユーザが上記索引を問い合わせることができるためのユーザインターフェースの提示を命令するステップ、をさらに含み、上記索引のクエリを受信するステップは、上記ユーザインターフェースとのユーザインタラクションに基づく、段落A乃至Dのうちいずれか1つに記載の方法。
F:上記第1の物理的場所は第1の家であり、上記複数の装置は上記第1の家における監視装置であり、上記第2の物理的場所は第2の家である、段落B乃至Eのうちいずれか1つに記載の方法。
G:上記索引は上記レコードがない(free of)、段落A乃至Fのうちいずれか1つに記載の方法。
H:コンピュータ実行可能命令を有するコンピュータ可読媒体であって、上記コンピュータ実行可能命令は、段落A乃至Gのうちいずれか1つに記載の方法を実行するようにコンピュータを構成する、媒体。
I:段落A乃至Gのうちいずれか1つに記載の方法を実行するようにコンピュータを構成するコンピュータ実行可能命令を有するコンピュータ可読媒体と、段落A乃至Gのうちいずれか1つに記載の方法を実行する命令を実行するように適合された処理ユニットと、を含む装置。
J:1つ以上のモニタリング装置に通信可能に結合された1つ以上のコンピューティング装置であって、上記モニタリング装置の各々は1つ以上のセンサを有し、上記1つ以上のコンピューティング装置は、上記センサからデータレコードのストリームを受信する通信インターフェースと、1つ以上のタグを上記データレコード内のオブジェクトに関連付けて、タグ付けされたデータレコードを作成するタグ付けモジュールと、上記タグと上記タグ付けされたデータレコード内のタイムスタンプとにおける関連付けを含む検索可能な索引を作成する索引付けモジュールと、上記タグ付けされたデータレコードを複数の連続チャンクに分けるチャンク化モジュールであって、各チャンクは複数の上記タグ付けされたデータレコードを含む、モジュールと、を含む、システム。
K:上記1つ以上のコンピューティング装置に通信可能に結合された、上記検索可能な索引が問い合わせられるためのクエリインターフェース、をさらに含む段落Jに記載のシステム。
L:上記1つ以上のコンピューティング装置に通信可能に結合されて上記複数のチャンクを記憶する第1の記憶装置と、上記1つ以上のコンピューティング装置に通信可能に結合されて上記検索可能な索引を記憶する第2の記憶装置と、をさらに含む段落J又は段落Kに記載のシステム。
M:上記1つ以上のコンピューティング装置は、上記チャンクを暗号化する暗号化モジュールをさらに含む、段落J乃至Lのうちいずれか1つに記載の装置。
N:コンピュータ実行可能命令を有する1つ以上のコンピュータ可読媒体であって、上記コンピュータ実行可能命令は、実行されると、第1のユーザに関連付けられた第1の場所を監視する監視装置から時系列データのストリームを受信することであって、上記時系列データは、上記監視装置により感知された1つ以上のレコードと、該1つ以上のレコードの個々についての1つ以上のタイムスタンプとを含む、ことと、上記第1の場所に対してローカルの記憶装置に、上記1つ以上のタイムスタンプのうちの個々のタイムスタンプを1つ以上のタグに関連付ける索引を記憶することであって、上記タグの各々は上記1つ以上のオブジェクトの1つ以上の特徴を識別する、ことと、上記時系列データのストリームの少なくとも部分をリモートの記憶装置に記憶させることと、上記索引のクエリを、上記第1の場所とは異なる第2の場所に関連付けられた第2のユーザから受信することと、上記クエリに応答して、上記クエリを満足する上記時系列データの1つ以上のセグメントを識別することと、上記リモートの記憶装置から、上記クエリを満足する上記時系列データの上記1つ以上のセグメントを取り出すことと、を含む動作を実行するようにコンピュータを構成する、媒体。
O:上記監視装置はカメラを含み、上記レコードは、上記カメラにより捕捉された画像を含む、段落Nに記載の媒体。
P:上記タグは、上記カメラにより捕捉された上記画像内のオブジェクトのテキスト識別子である、段落N又はOに記載の媒体。
Q:上記監視装置は、温度計、近接検出器、又は需給計器のうち、少なくとも1つを含む、段落Nに記載の媒体。
R:上記タグは、上記時系列データのストリームと共に受信される、段落N乃至Qのうちいずれか1つに記載の媒体。
S:上記ストリームの少なくとも部分を記憶させることは、上記ストリームをチャンクにすることと、上記チャンクを記憶装置に送信することとを含む、段落N乃至Rのうちいずれか1つに記載の媒体。
T:上記チャンクを圧縮すること、をさらに含む段落Sに記載の媒体。
U:上記チャンクを暗号化すること、をさらに含む段落S又は段落Tに記載の媒体。
V:上記索引は上記チャンクの索引を含む、段落S乃至Uのうちいずれか1つに記載の媒体。
結び
上記手法は、構造的特徴及び/又は方法論動作に固有の言語において説明されたが、別記の請求項は必ずしも説明された具体的な特徴又は動作に限定されないことが理解されるべきである。むしろ、特徴及び動作は、上記手法の実施例として説明されている。
例示的な処理の動作が個々のブロックにおいて例示され、該ブロックを参照して要約されている。処理は、ブロックの論理フローとして例示されており、そのうちの各ブロックは、ハードウェア、ソフトウェア、又はこれらの組み合わせにおいて実施することができる1つ以上の動作を表現し得る。ソフトウェアの文脈において、動作は、1つ以上のコンピュータ可読媒体に記憶されたコンピュータ実行可能命令を表現し、該命令は、1つ以上のプロセッサによって実行されるときに、1つ以上のプロセッサが列挙された動作を実行することを可能にする。概して、コンピュータ実行可能命令には、特定の機能を実行し又は特定の抽象データタイプを実施するルーチン、プログラム、オブジェクト、モジュール、コンポーネント、データ構造、及び同様のものが含まれる。動作が説明されている順序は、限定として見なされることは意図されず、説明された動作のうち任意数のものが、説明された処理を実施するように、任意の順序において実行され、任意の順序において組み合わせられ、複数のサブ動作へと細分され、かつ/あるいは並列に実行されることができる。説明された処理は、1つ以上の装置102及び/又は108に関連付けられたリソース、例えば、1つ以上の内部若しくは外部のCPU若しくはGPU、及び/又は、FPGA、DSP、若しくは他のタイプのアクセラレータなどのハードウェアロジックの1つ以上のピースなどによって、実行されることができる。
上記で説明された方法及び処理のすべては、1つ以上の汎用目的コンピュータ又はプロセッサによって実行されるソフトウェアコードモジュールにおいて具現化され、該コードモジュールを介して十分に自動化され得る。コードモジュールは、任意タイプのコンピュータ可読記憶媒体又は他のコンピュータ記憶装置に記憶されてよい。方法のうちいくつか又はすべてが、別法として、専用のコンピュータハードウェアにおいて具現化されてもよい。
仮定的言語、中でも、「できる」、「可能性がある」、「恐れがある」、又は「し得る」などは、特に明記されない限り、その文脈内で理解され、特定の例が特定の特徴、要素、及び/又はステップを含み、一方で他の例が含まないことを提示する。ゆえに、概して、こうした仮定的言語では、特定の特徴、要素、及び/又はステップがいずれかの方法において1つ以上の例に必要とされること、又は、ユーザ入力又はプロンプトの有無にかかわらず、特定の特徴、要素、及び/又はステップがいずれかの特定の例において含まれ、あるいは実行されるべきであるかを決めるロジックを1つ以上の例が必ず含むことを伴うことは、意図されない。接続言語、例えば、フレーズ「X、Y、又はZのうち少なくとも1つ」などは、特に明記されない限り、項目、用語等がX、Y、又はZのうち任意のもの、又はこれらの組み合わせ若しくはサブ組み合わせであり得ること提示するように理解されるべきである。
本明細書において説明され及び/又は添付の図面に表されたフロー図における、いずれのルーチン説明、要素、又はブロックも、ルーチン内で特定の論理機能又は要素を実施するための1つ以上の実行可能命令を含むモジュール、セグメント、又はコードの部分を潜在的に表現するものと理解されるべきである。代替的な実施が、本明細書に説明された例の範囲内に含まれ、これにおいて、要素又は機能は、当業者により理解されるであろう、含まれる機能性に依存して、削除されてもよく、図示され又は論じられた順序以外の順序で、実質的に同期的に含まれて又は逆の順序において実行されてもよい。上記で説明された例に対して、多くのバリエーション及び変更がなされ得ることが強調されるべきであり、そのための要素は、他の許容可能な例の中にあるものと理解されるべきである。すべてのこうした変更及びバリエーションは、本明細書において本開示の範囲内に含まれ、別記の請求項によって保護されることが意図される。

Claims (15)

  1. 複数の装置から、複数のレコードと該レコードの各々に関連付けられた時間識別とを含む時系列データのストリームを受信するステップと、
    1つ以上のタグを、前記レコードのうちの個々のレコードに関連付けるステップと、
    前記ストリームを、複数の連続チャンクへとチャンクにするステップであって、前記連続チャンクの各々は複数のレコードを含む、ステップと、
    前記時間識別と前記1つ以上のタグとを関連付ける索引を作成するステップと、
    前記チャンクの各々を、第1のリモートの記憶場所に送信するステップと、
    前記索引を第2の記憶場所に記憶するステップと、
    を含む方法。
  2. 前記複数の装置は、第1のユーザに関連付けられた第1の物理的場所に関連付けられ、
    前記索引のクエリを、第2の物理的場所に関連付けられた第2のユーザから受信するステップと、
    前記クエリを満足する1つ以上のレコードを含む1つ以上のチャンクを決定するステップと、
    前記第1のリモートの記憶場所から、前記クエリを満足する前記1つ以上のレコードを含む前記1つ以上のチャンクを取り出すステップと、
    をさらに含む請求項1に記載の方法。
  3. 取り出された前記1つ以上のチャンクは、前記クエリを満足する前記1つ以上のレコードに対して追加的なレコードを含む、請求項2に記載の方法。
  4. 前記第1の物理的場所は第1の家であり、前記複数の装置は前記第1の家における監視装置であり、前記第2の物理的場所は第2の家である、請求項2又は請求項3に記載の方法。
  5. 1つ以上のモニタリング装置に通信可能に結合された1つ以上のコンピューティング装置であって、前記モニタリング装置の各々は1つ以上のセンサを有し、前記1つ以上のコンピューティング装置は、
    前記センサからデータレコードのストリームを受信する通信インターフェースと、
    1つ以上のタグを前記データレコード内のオブジェクトに関連付けて、タグ付けされたデータレコードを作成するタグ付けモジュールと、
    前記タグと前記タグ付けされたデータレコード内のタイムスタンプとにおける関連付けを含む検索可能な索引を作成する索引付けモジュールと、
    前記タグ付けされたデータレコードを複数の連続チャンクに分けるチャンク化モジュールであって、各チャンクは複数の前記タグ付けされたデータレコードを含む、モジュールと、
    を含む、
    システム。
  6. 前記1つ以上のコンピューティング装置に通信可能に結合されて前記複数のチャンクを記憶する第1の記憶装置と、
    前記1つ以上のコンピューティング装置に通信可能に結合されて前記検索可能な索引を記憶する第2の記憶装置と、
    をさらに含む請求項5に記載のシステム。
  7. 前記1つ以上のコンピューティング装置は、前記チャンクを暗号化する暗号化モジュールをさらに含む、請求項5又は請求項6に記載のシステム。
  8. コンピュータ実行可能命令を有する1つ以上のコンピュータ可読媒体であって、前記コンピュータ実行可能命令は、実行されると、
    第1のユーザに関連付けられた第1の場所を監視する監視装置から時系列データのストリームを受信することであって、前記時系列データは、前記監視装置により感知された1つ以上のレコードと、該1つ以上のレコードの個々についての1つ以上のタイムスタンプとを含み、
    前記第1の場所に対してローカルの記憶装置に、前記1つ以上のタイムスタンプのうちの個々のタイムスタンプを1つ以上のタグに関連付ける索引を記憶することであって、前記タグの各々は前記1つ以上のオブジェクトの1つ以上の特徴を識別し、
    前記時系列データのストリームの少なくとも部分をリモートの記憶装置に記憶させることと、
    前記索引のクエリを、前記第1の場所とは異なる第2の場所に関連付けられた第2のユーザから受信することと、
    前記クエリに応答して、前記クエリを満足する1つ以上のレコードを含む前記時系列データの1つ以上のセグメントを識別することと、
    前記リモートの記憶装置から、前記クエリを満足する前記1つ以上のレコードを含む前記時系列データの前記1つ以上のセグメントを取り出すことと、
    を含む動作を実行するようにコンピュータを構成する、
    媒体。
  9. 前記監視装置はカメラを含み、前記レコードは、前記カメラにより捕捉された画像を含む、請求項8に記載の媒体。
  10. 前記タグは、前記カメラにより捕捉された前記画像内のオブジェクトのテキスト識別子である、請求項8又は請求項9に記載の媒体。
  11. 前記監視装置は、温度計、近接検出器、又は需給計器のうち、少なくとも1つを含む、請求項8乃至10のうちいずれか1項に記載の媒体。
  12. 前記タグは、前記時系列データのストリームと共に受信される、請求項8乃至11のうちいずれか1項に記載の媒体。
  13. 前記ストリームの少なくとも部分を記憶させることは、前記ストリームをチャンクにすることと、前記チャンクを記憶装置に送信することとを含む、請求項8乃至12のうちいずれか1項に記載の媒体。
  14. 前記チャンクを圧縮することと前記チャンクを暗号化することとのうち、少なくとも1つをさらに含む請求項13に記載の媒体。
  15. 前記索引は前記チャンクの索引を含む、請求項13又は請求項14に記載の媒体。
JP2016526836A 2013-10-30 2014-10-29 接続された装置のデータ管理 Expired - Fee Related JP6426174B2 (ja)

Applications Claiming Priority (5)

Application Number Priority Date Filing Date Title
US201361897755P 2013-10-30 2013-10-30
US61/897,755 2013-10-30
US14/340,514 2014-07-24
US14/340,514 US10061791B2 (en) 2013-10-30 2014-07-24 Data management for connected devices
PCT/US2014/062760 WO2015066101A1 (en) 2013-10-30 2014-10-29 Data management for connected devices

Publications (3)

Publication Number Publication Date
JP2017504850A true JP2017504850A (ja) 2017-02-09
JP2017504850A5 JP2017504850A5 (ja) 2017-11-24
JP6426174B2 JP6426174B2 (ja) 2018-11-21

Family

ID=52996657

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2016526836A Expired - Fee Related JP6426174B2 (ja) 2013-10-30 2014-10-29 接続された装置のデータ管理

Country Status (16)

Country Link
US (1) US10061791B2 (ja)
EP (1) EP3063764B1 (ja)
JP (1) JP6426174B2 (ja)
KR (1) KR102231976B1 (ja)
CN (1) CN105765659B (ja)
AU (1) AU2014342430B2 (ja)
BR (1) BR112016007138A2 (ja)
CA (1) CA2924997C (ja)
CL (1) CL2016001022A1 (ja)
IL (1) IL244460B (ja)
MX (1) MX361303B (ja)
MY (1) MY182085A (ja)
PH (1) PH12016500957A1 (ja)
RU (1) RU2670573C2 (ja)
SG (2) SG10201803174XA (ja)
WO (1) WO2015066101A1 (ja)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2021502018A (ja) * 2017-11-02 2021-01-21 エヌチェーン ホールディングス リミテッドNchain Holdings Limited ブロックチェーンをデジタルツインにリンクするための、コンピュータにより実施されるシステム及び方法

Families Citing this family (54)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US10324942B2 (en) * 2013-07-26 2019-06-18 Snap Inc. Segment data visibility and management in a distributed database of time stamped records
US10417258B2 (en) 2013-12-19 2019-09-17 Exposit Labs, Inc. Interactive multi-dimensional nested table supporting scalable real-time querying of large data volumes
US10019591B1 (en) * 2014-12-23 2018-07-10 Amazon Technologies, Inc. Low-latency media sharing
US10430441B1 (en) * 2015-08-19 2019-10-01 Amazon Technologies, Inc. Tagging resources of a remote computing service based on locality
WO2017042524A1 (en) * 2015-09-11 2017-03-16 Toshiba Research Europe Limited Methods and systems for communicating information to a user
WO2017053707A1 (en) 2015-09-23 2017-03-30 Sensoriant, Inc. Method and system for using device states and user preferences to create user-friendly environments
US12174791B2 (en) * 2016-08-16 2024-12-24 Netscout Systems Texas, Llc Methods and procedures for timestamp-based indexing of items in real-time storage
US11137980B1 (en) * 2016-09-27 2021-10-05 Amazon Technologies, Inc. Monotonic time-based data storage
CN107919970A (zh) * 2016-10-08 2018-04-17 南京联成科技发展股份有限公司 一种安全运维服务云平台的日志管理实现方法及系统
US10268417B1 (en) * 2017-10-24 2019-04-23 EMC IP Holding Company LLC Batch mode object creation in an elastic cloud data storage environment
SG11202007063PA (en) * 2018-01-26 2020-08-28 Ge Inspection Technologies Lp Real time multi variate time series search
CN108280015B (zh) * 2018-02-07 2022-10-14 福建星瑞格软件有限公司 基于大数据的集群服务器日志实时处理方法及计算机设备
US11314779B1 (en) * 2018-05-31 2022-04-26 Amazon Technologies, Inc. Managing timestamps in a sequential update stream recording changes to a database partition
KR102177489B1 (ko) * 2018-08-17 2020-11-11 주식회사 마크베이스 센서 태그 데이터를 위한 색인 검색 방법 및 장치
RU2731321C2 (ru) 2018-09-14 2020-09-01 Общество С Ограниченной Ответственностью "Яндекс" Способ определения потенциальной неисправности запоминающего устройства
RU2714219C1 (ru) 2018-09-14 2020-02-13 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для планирования передачи операций ввода/вывода
RU2718215C2 (ru) 2018-09-14 2020-03-31 Общество С Ограниченной Ответственностью "Яндекс" Система обработки данных и способ обнаружения затора в системе обработки данных
RU2714602C1 (ru) * 2018-10-09 2020-02-18 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для обработки данных
RU2721235C2 (ru) 2018-10-09 2020-05-18 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для маршрутизации и выполнения транзакций
RU2711348C1 (ru) 2018-10-15 2020-01-16 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для обработки запросов в распределенной базе данных
CN111143113B (zh) 2018-11-02 2023-07-07 伊姆西Ip控股有限责任公司 复制元数据的方法、电子设备和计算机程序产品
RU2695499C1 (ru) * 2018-12-03 2019-07-23 Общество с ограниченной ответственностью "СМАРТЛАЙН" Способ и устройство для удаленного наблюдения за соблюдением правил техники безопасности сотрудниками
RU2714373C1 (ru) 2018-12-13 2020-02-14 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для планирования выполнения операций ввода/вывода
RU2749649C2 (ru) 2018-12-21 2021-06-16 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для планирования обработки операций ввода/вывода
RU2720951C1 (ru) 2018-12-29 2020-05-15 Общество С Ограниченной Ответственностью "Яндекс" Способ и распределенная компьютерная система для обработки данных
WO2020159397A1 (en) * 2019-01-30 2020-08-06 Siemens Aktiengesellschaft Method and computerized device for processing numeric time series data
RU2746042C1 (ru) 2019-02-06 2021-04-06 Общество С Ограниченной Ответственностью "Яндекс" Способ и система для передачи сообщения
CN112015729B (zh) * 2019-05-29 2024-04-02 核桃运算股份有限公司 数据管理装置、方法及其计算机存储介质
CN111104457A (zh) * 2019-10-30 2020-05-05 武汉大学 基于分布式数据库的海量时空数据管理方法
CN112416930B (zh) * 2020-11-18 2024-12-10 国家基础地理信息中心 混合时相影像地图数据的查询方法、存储方法及相关装置
WO2022132563A1 (en) 2020-12-15 2022-06-23 Selex Es Inc. Systems and methods for electronic signature tracking
CN112732700B (zh) * 2021-01-25 2023-03-14 中冶赛迪信息技术(重庆)有限公司 一种轧钢生产数据切片方法、系统、介质及电子终端
MX2023010504A (es) 2021-03-10 2023-09-20 Selex Es Inc Sistemas y metodos para captura de informacion de vehiculos utilizando luz blanca.
US12458294B2 (en) * 2021-05-03 2025-11-04 Nihon Kohden Digital Health Solutions, Llc Method for synchronizing biological signals from different monitoring devices
US11496232B1 (en) * 2021-05-03 2022-11-08 Nihon Kohden Digital Health Solutions, Inc. Waveform synchronization system for data received from a network
DE22868062T1 (de) 2021-09-09 2024-10-24 Leonardo Us Cyber And Security Solutions, Llc Systeme und verfahren zur elektronischen signaturverfolgung und -analyse
MX2024005952A (es) 2021-11-18 2024-07-01 Leonardo Us Cyber And Security Solutions Llc Sistemas y metodos para rastrear aeronaves.
WO2023141197A1 (en) 2022-01-24 2023-07-27 Selex Es Inc. Systems and methods for parking management
US12456377B2 (en) 2022-02-25 2025-10-28 Leonardo Us Cyber And Security Solutions, Llc Systems and methods for electronic surveillance
WO2025007359A1 (zh) * 2023-07-06 2025-01-09 上海江波龙数字技术有限公司 序列数据的处理方法、存储设备及存储系统
US11907093B1 (en) 2023-09-05 2024-02-20 Armada Systems Inc. Cloud-based fleet and asset management for edge computing of machine learning and artificial intelligence workloads
US12131242B1 (en) 2023-09-05 2024-10-29 Armada Systems Inc. Fleet and asset management for edge computing of machine learning and artificial intelligence workloads deployed from cloud to edge
US12014219B1 (en) 2023-09-05 2024-06-18 Armada Systems Inc. Cloud-based fleet and asset management for edge computing of machine learning and artificial intelligence workloads
US12014634B1 (en) 2023-09-05 2024-06-18 Armada Systems Inc. Cloud-based fleet and asset management for edge computing of machine learning and artificial intelligence workloads
US11876858B1 (en) 2023-09-05 2024-01-16 Armada Systems Inc. Cloud-based fleet and asset management for edge computing of machine learning and artificial intelligence workloads
US11899671B1 (en) * 2023-09-05 2024-02-13 Armada Systems Inc. Real-time search and retrieval of streaming sensor data
US12033006B1 (en) 2023-09-05 2024-07-09 Armada Systems Inc. Edge deployment of cloud-originated machine learning and artificial intelligence workloads
WO2025053869A1 (en) * 2023-09-05 2025-03-13 Armada Systems Inc. Real-time search and retrieval of streaming sensor data
US12141541B1 (en) 2023-10-06 2024-11-12 Armada Systems, Inc. Video to narration
US11960515B1 (en) 2023-10-06 2024-04-16 Armada Systems, Inc. Edge computing units for operating conversational tools at local sites
US12067041B1 (en) 2023-10-06 2024-08-20 Armada Systems, Inc. Time series data to statistical natural language interaction
US11995412B1 (en) 2023-10-06 2024-05-28 Armada Systems, Inc. Video based question and answer
US12086557B1 (en) 2023-10-06 2024-09-10 Armada Systems, Inc. Natural language statistical model with alerts
US11935416B1 (en) 2023-10-24 2024-03-19 Armada Systems Inc. Fleet and asset management and interfaces thereof associated with edge computing deployments

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2003134435A (ja) * 2001-10-30 2003-05-09 Matsushita Electric Ind Co Ltd 映像データ送信方法及び映像データ受信方法、並びに映像監視システム
JP2008016896A (ja) * 2006-06-30 2008-01-24 Sony Corp 監視装置及び監視方法
JP2013008295A (ja) * 2011-06-27 2013-01-10 Nippon Telegr & Teleph Corp <Ntt> 情報記録装置、情報記録方法およびプログラム

Family Cites Families (26)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US5689442A (en) 1995-03-22 1997-11-18 Witness Systems, Inc. Event surveillance system
EP1508862A1 (en) * 2003-08-21 2005-02-23 Deutsche Thomson-Brandt GmbH Method for seamless real-time splitting and concatenating of a data stream
JP2007074338A (ja) 2005-09-07 2007-03-22 Matsushita Electric Ind Co Ltd ネットワークカメラ防犯システム及びそのネットワークカメラ選択方法
US20080042830A1 (en) 2005-12-30 2008-02-21 Skyetek, Inc. Virtual rfid-based tag sensor
US7930559B1 (en) * 2006-06-30 2011-04-19 Emc Corporation Decoupled data stream and access structures
US7504969B2 (en) * 2006-07-11 2009-03-17 Data Domain, Inc. Locality-based stream segmentation for data deduplication
JP2008092279A (ja) 2006-10-02 2008-04-17 Fuji Electric Systems Co Ltd 監視システム及び監視方法
US8214517B2 (en) * 2006-12-01 2012-07-03 Nec Laboratories America, Inc. Methods and systems for quick and efficient data management and/or processing
US20080246841A1 (en) 2007-04-03 2008-10-09 Taiming Chen Method and system for automatically generating personalized media collection for participants
US20090089845A1 (en) 2007-09-28 2009-04-02 William Rex Akers Video storage and retrieval system
US20090136208A1 (en) * 2007-11-28 2009-05-28 Flora Gilboa-Solomon Virtual Video Clipping and Ranking Based on Spatio-Temporal Metadata
US8290427B2 (en) * 2008-07-16 2012-10-16 Centurylink Intellectual Property Llc System and method for providing wireless security surveillance services accessible via a telecommunications device
US8401771B2 (en) * 2008-07-22 2013-03-19 Microsoft Corporation Discovering points of interest from users map annotations
US8925001B2 (en) * 2008-09-12 2014-12-30 At&T Intellectual Property I, L.P. Media stream generation based on a category of user expression
US8447740B1 (en) * 2008-11-14 2013-05-21 Emc Corporation Stream locality delta compression
US8458136B2 (en) * 2009-07-27 2013-06-04 International Business Machines Corporation Scheduling highly parallel jobs having global interdependencies
JP4992945B2 (ja) 2009-09-10 2012-08-08 株式会社日立製作所 ストリームデータ生成方法、ストリームデータ生成装置及びストリームデータ生成プログラム
KR101172586B1 (ko) * 2010-05-19 2012-08-08 한국과학기술원 미디어 클립 생성 방법 및 시스템
US20130080267A1 (en) 2011-09-26 2013-03-28 Unicorn Media, Inc. Single-url content delivery
CN102446184B (zh) 2010-10-12 2013-06-19 上海可鲁系统软件有限公司 一种基于时间序列的工业数据存储及索引方法
US10394757B2 (en) 2010-11-18 2019-08-27 Microsoft Technology Licensing, Llc Scalable chunk store for data deduplication
US9225793B2 (en) 2011-01-28 2015-12-29 Cisco Technology, Inc. Aggregating sensor data
KR20120119790A (ko) * 2011-04-22 2012-10-31 삼성전자주식회사 미디어 데이터 전송 방법 및 장치와 미디어 데이터 수신 방법 및 장치
US8825626B1 (en) * 2011-08-23 2014-09-02 Emc Corporation Method and system for detecting unwanted content of files
US9143563B2 (en) 2011-11-11 2015-09-22 Rockwell Automation Technologies, Inc. Integrated and scalable architecture for accessing and delivering data
US8909641B2 (en) 2011-11-16 2014-12-09 Ptc Inc. Method for analyzing time series activity streams and devices thereof

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2003134435A (ja) * 2001-10-30 2003-05-09 Matsushita Electric Ind Co Ltd 映像データ送信方法及び映像データ受信方法、並びに映像監視システム
JP2008016896A (ja) * 2006-06-30 2008-01-24 Sony Corp 監視装置及び監視方法
JP2013008295A (ja) * 2011-06-27 2013-01-10 Nippon Telegr & Teleph Corp <Ntt> 情報記録装置、情報記録方法およびプログラム

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
榎美紀、外1名: "3次元地図を用いた自動索引付き映像データベースシステム", 電子情報通信学会技術研究報告, vol. 105, no. 171, JPN6018036659, 6 July 2005 (2005-07-06), JP, pages 113 - 118, ISSN: 0003881758 *

Cited By (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2021502018A (ja) * 2017-11-02 2021-01-21 エヌチェーン ホールディングス リミテッドNchain Holdings Limited ブロックチェーンをデジタルツインにリンクするための、コンピュータにより実施されるシステム及び方法
JP7297742B2 (ja) 2017-11-02 2023-06-26 エヌチェーン ライセンシング アーゲー ブロックチェーンをデジタルツインにリンクするための、コンピュータにより実施されるシステム及び方法
JP2023107918A (ja) * 2017-11-02 2023-08-03 エヌチェーン ライセンシング アーゲー ブロックチェーンをデジタルツインにリンクするための、コンピュータにより実施されるシステム及び方法
JP7653466B2 (ja) 2017-11-02 2025-03-28 エヌチェーン ライセンシング アーゲー ブロックチェーンをデジタルツインにリンクするための、コンピュータにより実施されるシステム及び方法

Also Published As

Publication number Publication date
CN105765659B (zh) 2019-07-12
RU2016116811A (ru) 2017-11-02
HK1223729A1 (zh) 2017-08-04
US10061791B2 (en) 2018-08-28
RU2016116811A3 (ja) 2018-05-04
KR102231976B1 (ko) 2021-03-24
CA2924997C (en) 2021-06-08
EP3063764A1 (en) 2016-09-07
CN105765659A (zh) 2016-07-13
BR112016007138A2 (pt) 2017-08-01
RU2670573C2 (ru) 2018-10-23
WO2015066101A1 (en) 2015-05-07
EP3063764B1 (en) 2021-01-06
MX2016005426A (es) 2016-08-11
CL2016001022A1 (es) 2016-11-11
IL244460A0 (en) 2016-04-21
JP6426174B2 (ja) 2018-11-21
AU2014342430B2 (en) 2019-08-15
KR20160077080A (ko) 2016-07-01
IL244460B (en) 2021-03-25
US20150120749A1 (en) 2015-04-30
SG10201803174XA (en) 2018-06-28
MY182085A (en) 2021-01-18
PH12016500957A1 (en) 2016-07-11
AU2014342430A1 (en) 2016-03-31
SG11201603009QA (en) 2016-05-30
MX361303B (es) 2018-12-03
CA2924997A1 (en) 2015-05-07

Similar Documents

Publication Publication Date Title
JP6426174B2 (ja) 接続された装置のデータ管理
US10032032B2 (en) Software container registry inspection
US8983967B2 (en) Data storage system having mutable objects incorporating time
US11489660B2 (en) Re-encrypting data on a hash chain
WO2019041766A1 (zh) 页面资源加载方法、装置、终端设备及介质
US9244960B2 (en) Metadata-driven version management service in pervasive environment
US9639715B2 (en) Protecting user identifiable information in the transfer of telemetry data
US10635830B2 (en) Ingest proxy and query rewriter for secure data
US10956373B1 (en) Page-based metadata system for distributed filesystem
US9262646B1 (en) Systems and methods for managing web browser histories
US20190377893A1 (en) Systems and methods for detecting, tracking, and analyzing access to digital information
US12335286B1 (en) Compute environment security monitoring using data collected from a sub-kernel space
CN112181975A (zh) 用于在数据仓库中创建数据库的方法和装置
HK1223729B (zh) 針對聯網設備的數據管理
US12615271B1 (en) Compute environment security monitoring using a live state snapshot of a compute resource
CN122001947A (zh) 跨域缓存方法、装置、设备、介质和程序产品

Legal Events

Date Code Title Description
A521 Request for written amendment filed

Free format text: JAPANESE INTERMEDIATE CODE: A523

Effective date: 20171010

A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20171010

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20180831

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

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20181024

R150 Certificate of patent or registration of utility model

Ref document number: 6426174

Country of ref document: JP

Free format text: JAPANESE INTERMEDIATE CODE: R150

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

R250 Receipt of annual fees

Free format text: JAPANESE INTERMEDIATE CODE: R250

LAPS Cancellation because of no payment of annual fees