現実世界のデータに支払いを行うことは、データパイプラインが接続のギャップを乗り越えられる場合にのみエージェントを支援する。 本日@vangrid_ioから発表された新しいアクティビティは、エージェントがリアルな作業を実行するためにデータを購入していることを示唆している。 ストリーミングレイヤーには、そのアイデアの下により難しい課題が存在する。 Vangridは1つの地理的ゾーンに対して接続を維持し、新しいグランドトゥルースイベントが到着した時点でプッシュできる。 各イベントには、独自のタイムスタンプ、ジオメトリ、観測タイプ、信頼度、ノード数、および出所ハッシュが含まれる。 新規データが到着しない場合、サーバーは30秒ごとにハートビートを送信する。 しかし、このストリームにはリプレイバッファは存在しない。 接続を切断すると、そのギャップ中に到着した観測データは自動的に再送信されない。 クライアントは再接続した後、空間クエリエンドポイントを使用して、ストリームが切断されていた間に発生したデータをバックフィルする必要がある。 これは、ロボットや物理的エージェント向けに異なる統合パターンを生み出す。 接続中は世界をストリーミングし、 ギャップを検出し、 欠落した期間をクエリし、 欠落した観測値をマージした後、 ライブフィードから継続する。 ダッシュボードにとっては、短い切断はチャート上の空白領域を意味する。 一方、物理世界を移動するマシンにとっては、同じギャップが車両の存在、通行不能な経路、または環境の変化を隠す可能性がある。 リアルタイムデータだけではこの問題を解決できない。 それを消費するシステムは、接続が切断された後に状態を再構築する手段も必要とする。 Vangridはこの責任を明確にAPIの境界に置いている。 ライブイベントはストリームを通じて到着し、 履歴の復元は空間クエリを通じて実行される。 同じ物理的状態に対する2つの経路だ。 この区別は、ソフトウェアエージェントが単にデータを読み取るだけでなく、グランドトゥルースを使ってリアルな作業を開始するようになると、さらに重要になる。