Анализ в реальном времени—ArcGIS Velocity

Аналитика в реальном времени выполняет обработку данных, поступающих через тип канала, анализируя каждое сообщение по мере его получения. Аналитика в реальном времени используется для трансформации данных, определении геозон и выявлении инцидентов. Аналитика завершается созданием одного или нескольких типов вывода, например, сохранением данных в векторный слой или отправкой оповещения по электронной почте.

Примеры анализа в реальном времени

Ниже приведены примеры использования анализа в реальном времени:

В качестве менеджера по чрезвычайным ситуациям вы можете в режиме реального времени отслеживать и архивировать текущие местоположения ваших полевых бригад, отправлять оповещения, если экипаж находится в запретной зоне, и вычислять расстояние от местоположения полевых бригад до назначенной им операционной базы.
В качестве аналитика цепочки поставок в нефтегазовой компании вы можете подключиться к потоку данных автоматической идентификационной системы (AIS), чтобы отслеживать свои суда, вычислять ожидаемое время прибытия и определять, находятся ли суда внутри или вне зон интереса.
В качестве аналитика по логистике в транспортной компании вы можете отслеживать перемещения транспортных средств в реальном времени, визуализировать и архивировать статистику движения, такую как скорость, расстояние и время простоя. Вы можете хранить все эти местоположения и наблюдения атрибутов в векторном слое.
В качестве ученого-эколога, управляющего большим количеством датчиков, вы можете архивировать наблюдения для их последующей обработки.

Компоненты аналитики в реальном времени

Существует четыре компонента аналитики в реальном времени: каналы, источники, инструменты и выходы. Эти компоненты описаны ниже:

Каналы:
- Канал — это поток данных в реальном времени, поступающий в ArcGIS Velocity. Каналы обычно подключаются к внешним источникам данных наблюдений, таким как платформы Интернета вещей (IoT), агенты сообщений или сторонние API. Каналы разбирают входящие данные в виде таблиц, точек, полилиний или полигонов и предоставляют их для дальнейшего анализа и визуализации.
Источники:
- Источник данных используется для загрузки статических или близких к реальному времени данных в аналитике больших данных.
- Источники данных аналитики в реальном времени используются только в качестве вторичного набора данных в таких инструментах, как Присоединить объекты, Фильтр по геометрии, Вычислить расстояние и т.д.
Инструменты:
- Инструменты обрабатывают и анализируют события, которые берутся из каналов. Не включает несколько инструментов или ни одного в аналитику в реальном времени в зависимости от варианта использования.
- Одни инструменты могут быть связаны с другими, причем выходные данные одного инструмента становятся входными для другого.
- Не все инструменты, доступные в аналитике больших данных, доступны для аналитики в реальном времени. Это связано с тем, что некоторые инструменты, в частности, анализ Поиска горячих точек, анализируют весь набор данных сразу. Аналитика в реальном времени, напротив, работает отдельно с каждым входящим событием, по мере его получения.
Выходы:
- Типы выходов определяют, что должно быть сделано с каждым событием при его обработке аналитикой в реальном времени.
- Варианты выходов включают сохранение объектов в новый или существующий векторный слой, отправку электронной почты, отправку сообщений в Kafka или RabbitMQ и другие действия. Дополнительные сведения см. в разделе Основы выходных данных аналитики.
- События, получаемые из инструмента или канала, могут быть отправлены в несколько выходных данных.

Обработка без сохранения состояния и с сохранением состояния

Большинство инструментов аналитики в реальном времени функционируют без сохранения состояния, что означает, что они работают с каждым полученным наблюдением и не хранят в памяти записи каких-либо предыдущих наблюдений. Однако некоторые из доступных инструментов работают с отслеживанием состояния, а не с отдельными наблюдениями.

Инструменты с отслеживанием состояния собирают несколько последовательных наблюдений для каждого трека, чтобы сравнить пространственные и/или атрибутные условия на каждом треке и обнаружить изменения. Когда наблюдение получено для каждого трека, оно добавляется в небольшой кеш наблюдений для этого трека. Это используется, например, для определения того, вошёл ли трек в геозону или покинул её, путём сравнения последнего наблюдения с предыдущим.

Доступные инструменты с отслеживанием состояния:

Инструменты с отслеживанием состояния не могут поддерживать неопределенное количество наблюдений в памяти, поэтому, чтобы избежать чрезмерного потребления ресурсов памяти, кэш для каждой дорожки периодически очищается от наблюдений, которые старше указанного возраста.

Некоторые инструменты с отслеживанием состояния позволяют указать продолжительность очистки с помощью параметра Целевое временное окно. Когда происходит очистка, наблюдения старше значения, указанного в параметре Целевое временное окно, удаляются из памяти. Очистка влияет только на наблюдения, хранящиеся в памяти для целей обработки с отслеживанием состояния. Очистка не влияет на наблюдения, отправленные в выходные данные, и не удаляет сами данные.

Параметр Целевое временное окно должен быть установлен на значение, равное или превышающее самый длительный ожидаемый период времени между наблюдениями для любого отдельного трека. Например, если транспортные средства сообщают о своем местонахождении каждые пять минут, и вы используете инструмент Фильтр по геометрии, чтобы определять, когда каждое транспортное средство въезжает в определенную область, вы должны установить значение параметра Целевое временное окно в фильтре чуть более пяти минут, чтобы обеспечить получение нескольких наблюдений перед очисткой. Если установить значение меньше пяти минут, кэш будет содержать только одно наблюдение на трек, что исключает возможность определить изменение пространственного положения транспортного средства к геозоне с наружнего на внутреннее. Инструменты Вычислить статистику движения, Выявление инцидентов, Фильтр по геометрии и Присоединить объекты имеют параметр Целевое временное окно.

Геозоны

Геозоны - это квинтэссенция пространственного анализа в реальном времени, в котором объекты (часто точки отслеживания) сравниваются с интересующими областями (часто с полигональными областями). Чаще всего анализируются точечные наблюдения, чтобы определить, вошли ли они в виртуальный периметр или вышли из него.

В ряде инструментов аналитики в реальном времени и аналитики больших данных можно выполнять геозонирование для выявления пространственных отношений, которые могут возникать между объектами в целевом канале или источнике данных и набором пространственных объединяемых объектов или геозон. Объекты, используемые в качестве геозон, должны быть подключены к порту присоединения инструмента геозон. Геозоны могут быть точками, линиями или полигонами. Пространственные отношения зависят от типа геометрии входной цели и данных соединения.

Инструменты аналитики больших данных и данных в реальном времени, поддерживающие геозонирование, включают следующее:

Дополнительные сведения и примеры использования см. в разделе Анализ геозонирования.

Динамическое геозонирование

В ряде инструментов аналитики в реальном времени можно выполнять динамическое геозонирование для выявления пространственных отношений между объектами в целевом канале и набором объектов в другом канале объединения (геозоны), оба из которых обновляются в реальном времени или близком к нему. Инструмент, выполняющий геозонирование, использует самые последние наблюдения любого заданного идентификатора трека в качестве геозон.

Если канал подключен к порту соединения, объекты соединения (геозоны) постоянно обновляются в зависимости от входящих объектов в канал соединения. В этом случае геозонирование выполняется динамически на основе изменяющихся объектов как в целевом, так и в присоединенном канале.
При динамическом геозонировании требуется параметр Временное окно присоединения.
- Если в канале присоединения отсутствует поле с тегом END_TIME, а последнее известное наблюдение для объекта присоединения старше указанного временного окна присоединения, то инструмент очищает эти наблюдения из своей памяти и не включает их в анализ.
- Если в канале присоединения есть поле с тегом END_TIME, то объект удаляется из хранилища геозоны в соответствии со значением в поле END_TIME или при завершении временного окна присоединения — в зависимости от того, что наступит раньше.

Инструменты аналитики в реальном времени, поддерживающие динамические геозоны:

Примечание:

Максимальный размер геозон, который поддерживается в аналитике реального времени, не может превышать 768 МБ.

Дополнительные сведения и примеры использования см. в разделе Анализ геозонирования.

Отзыв по этому разделу?