Учебник по flexible драйверу (Входящие данные)

В текущей статье мы рассмотрим возможности flexible драйвера и то, как его можно использовать для обработки произвольных входящих данных из TCP соединения.

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

В данном руководстве приведено множество выражений, использующих команду переменной окружения. В различных выражениях на эту переменную ссылается {env/command}. В AggreGate, использующем flexible драйвер, настроенный на получение входящих данных, эта переменная содержит данные, которые были получены и обрабатываются драйвером.

Первым шагом будет настройка плагина драйвера Flexible для корректной маршрутизации входящих данных на определенное устройство Flexible драйвер. В корневом контексте откройте контекст Драйверы/расширения и выберите Редактировать свойства драйвера/расширения flexible драйвера.

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

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

Вы настроили глобальные конфигурации flexible драйвера на прием TCP-пакетов на порт 5040, интерпретацию каждой полезной нагрузки как кодированной в ASCII и пересылку полезной нагрузки на устройство flexible драйвера с идентификатором "1". В следующем разделе необходимо настроить устройство с идентификатором "1", которое будет далее обрабатывать входящие полезные нагрузки TCP.

Чтобы создать flexible устройство, нажмите Добавить устройство из контекста Устройства в корневом контексте. Настройте устройство с помощью следующих параметров:

На следующем скриншоте показаны приведенные выше конфигурации, введенные в окно "Добавить устройство". Нажмите OK, чтобы сохранить и открыть страницу Свойства аккаунта устройства .

После создания устройства окно Свойства аккаунта устройства должно открыться автоматически. Окно также можно открыть, нажав Редактировать свойства аккаунта устройства из контекстного меню вновь созданного устройства.

Для того чтобы связать поступающие данные с устройством, создайте хотя бы одну переменную. Перейдите на вкладку Статические переменные и добавьте строку со следующими данными:

Настроив строку на вкладке Статические переменные , вы получите следующее:

Теперь у устройства есть переменная данных, в которую могут быть записаны входящие данные.

Еще одним способом взаимодействия с устройством является инициирование определенных событий. Откройте вкладку Статические события в Свойствах аккаунта устройства и добавьте строку с указанными данными, оставив неупомянутые поля пустыми:

Настроив статическое событие с указанными выше значениями, вы получите следующее:

Это позволит устройству инициировать события при получении определенных пакетов данных.

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

Операции с данными

Асинхронная обработка переменных

Обработка асинхронных событий

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

Сейчас, когда устройство AggreGate настроено на обработку входящих сообщений с помощью flexible драйвера, его можно протестировать, отправив несколько сообщений.

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

• Загрузите и установите пакетный отправитель в той же операционной системе, в которой запущен сервер AggreGate.

• Создайте пакет со следующими конфигурациями:

Настроенное окно Отправитель пакетов будет выглядеть следующим образом.

Кликните Отправить, чтобы отправить пакет на устройство с flexible драйвером AggreGate.

• Установите Python 3 на ту же машину, на которой запущен сервер AggreGate.

• Сохраните приведенный ниже пример сценария в файле с именем sendpacket.py:

• import socket
  
  # Set up the socket connection
  s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  
  # Hostname or IP address where server is running
  host = 'localhost'  
  # Port where Flexible Driver is configured to listen to incoming data
  port = 5040  
  # Start connection
  s.connect((host, port))
  
  # Send data
  data = b'var: Update data with some arbitrary TCP data.'
  s.sendall(data)
  
  # Close the connection
  s.close()

• Запустите сценарий из командной строки командой python3 sendpacket.py

• Откройте контекстное меню устройства из корневого контекста и нажмите Управление устройством...

• Текущий откроет окно со всеми переменными устройства, в данном случае переменной data, с данными, которые мы отправили как пакет var: Обновить переменную "data" произвольными данными TCP.

• Доступ к переменной можно получить на языке выражений с помощью контекстного пути {users.admin.devices.incoming_flexible:data}.

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

Напомним, что Выражение классификатора события/обновления переменной определяет, будут ли входящие данные обрабатываться как событие или как операция обновления переменной. Мы использовали следующее выражение:

contains({env/command}, "variable") ? 1 : (contains({env/command}, "event") ? 0 : 1)

Текущее выражение сначала проверяет, содержит ли команда строку "переменная". Если да, то оно принимает значение 1, и команда обрабатывается как обновление переменной. Если команда не содержит строку "переменная", выполняется проверка, содержит ли команда строку "событие". Если команда содержит строку "событие", выражение оценивается в 0, и команда обрабатывается как событие. Если ни "переменная", ни "событие" не присутствуют, по умолчанию устанавливается значение 1 и обновляется переменная.

Чтобы вызвать событие, просто измените содержимое тестового пакета так, чтобы оно содержало строку "event" и удалите строку "variable". Например: event: Текущее событие!

Используяотправитель пакетов , обновите данные в формате ASCII и HEX, как указано ниже:

При использовании сценария Python обновите переменную данных, как указано ниже:

...
# Send data
data = b'event: Текущее событие!'
...

В Контекстном дереве AggreGate откройте контекстное меню Входящего flexible устройства и выберите Просмотр событий.

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

Отправьте пакет из программы Пакет Отправитель или запустите сценарий Python и убедитесь, что событие сработало:

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