Оплата данных из реального мира помогает агенту только тогда, когда конвейер данных способен переживать разрывы соединения. Свежая активность от @vangrid_io сегодня указывает на то, что агенты платят за данные, чтобы выполнять реальную работу. Слой потоковой передачи раскрывает более сложную проблему, лежащую в основе этой идеи. Vangrid может поддерживать открытое соединение для одной географической зоны и отправлять новые события истинных данных по мере их поступления. Каждое событие содержит собственную метку времени, геометрию, тип наблюдения, уровень достоверности, количество нод и хеш происхождения. Когда новые данные не поступают, сервер отправляет «heartbeat» каждые 30 секунд. Однако поток не хранит буфер воспроизведения. Если соединение прерывается, наблюдения, пришедшие во время этого разрыва, не возвращаются автоматически. Клиент должен заново подключиться и использовать пространственный запрос для восполнения всех событий, произошедших во время отсутствия потока. Это создает иной шаблон интеграции для роботов и физических агентов: — Транслируйте мир, пока соединение активно; — Обнаружьте разрыв; — Запросите недостающий интервал; — Объедините пропущенные наблюдения; — Продолжите с живого потока. Для дашборда короткий разрыв может означать пустой участок на графике. Для машины, движущейся в физическом мире, тот же разрыв может скрыть транспортное средство, заблокированный путь или изменённую среду. Одних только данных в реальном времени недостаточно, чтобы решить эту проблему. Система, потребляющая эти данные, также должна иметь возможность восстановить состояние после разрыва связи. Vangrid четко возлагает эту ответственность на границу API: — Живые события приходят через поток; — Восстановление исторических данных — через пространственные запросы. Два пути к одному и тому же физическому состоянию. Это различие становится всё более важным, когда программные агенты начинают использовать истинные данные не просто для чтения, а для выполнения реальной работы.