Использование портов порядка выполнения

Узлы соединены только потоками данных. При запуске подмодели извне её внутренняя логика не выполняется, так как отсутствуют порты, инициирующие запуск цепочки.

В начале сценария (перед узлом импорта) и в конце (после узла экспорта) добавлены порты порядка выполнения. Это обеспечивает полное выполнение всех этапов при запуске подмодели из любого внешнего сценария, так как порты задают четкую последовательность: импорт → обработка → экспорт.

Используется узел импорта Loginom Data файла для получения и обработки данных.

Имя	Метка
class	Класс
idClient	Код Клиента
idQuarter	Квартал

На данном этапе аналитик может реализовать свой вариант обработки данных. В демопримере с помощью узла Группировка настроена группировка по полю Код клиента.

Настройка узла Группировка произведены следующим образом:

• Группа — Код клиента
• Показатели — Класс (Последний) и Квартал (Последний)

Обработанные данные выгружаются в Excel файл.

Узлы экспорта не имеют портов порядка выполнения, поэтому запись в таблицу выполняется параллельно. Это приводит к конфликтам при одновременном обращении к базе данных и возникновению ошибки database is locked.

Что происходит:

• Все узлы экспорта пытаются одновременно записать данные в одну таблицу

• Возникает конфликт доступа к БД

• Система возвращает ошибку database is locked

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

Как настроено:

• Порты порядка выполнения установлены между всеми узлами экспорта

• Запись выполняется строго по очереди, без параллельных обращений

• Конфликты исключены, ошибка database is locked не возникает

На странице Подключения настроено подключение SQLite:

• Имя файла — data/sqlite_db.db

Выполняется получение данных используя узел импорта Excel файл.

Таблица id_value_1.xlsx

Имя	Метка
id	id
value_1	value_1

Таблица id_value_2.xlsx

Имя	Метка
id	id
value_2	value_2

Таблица id_value_3.xlsx

Имя	Метка
id	id
value_3	value_3

• Имя таблицы — table
• Тип экспорта — Обновить существующие записи в таблице
• Ключевое поле — id

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

В сценарии узел Соединение (переменные) используется для сбора статусов выполненых запросов к БД SQLite и вывода их наружу.

В подмодели формируется URL-строки для получение ответа от сервиса ipapi.co. В первую очередь выполняется импорт Excel файла с IP-адресами и их форматами, в котором должен вернуть ответ API-сервис.

Имя	Метка	Комментарий
ip	ip	IP-адрес, по которому нужно получить информацию
format	format	Формат, в котором должен вернуть ответ API-сервис. В данном примере используется формат JSON.

После импорта данных, извлекается первый IP-адресс и его формат, используя узел Таблица в переменные.

В узле Калькулятор (переменные) формируется URL с параметрами по маске https://ipapi.co/{ip}/{format}/

В узле JavaScript реализуется принудительная задержка перед вызовом API-сервиса. Во входные переменные узла передается переменная sleep_time, в которой указывается количество секунд задержки.

На странице Подключения настроено подключение REST-сервис:

• URL сервиса — https://ipapi.co/{ip}/{format}/
• Метод — GET
• Тип URL параметров — Строка запроса
• Допустимы Content-Type ответа — application/json

На вход узла REST-сервис, созданного на основе настроенного подключения, подан URL, сформированный в узле Сборка URL.

Узел REST-запрос отправляет REST-сервису запрос и получает ответ в формате JSON.

Выполняет основной алгоритм обработки данных:

• Импорт данных
• Обработка данных
• Экспорт обработанных данных в Excel-файл

Сигналом для отправки уведомления является выгрузка данных в Excel-файл.

Отправляет уведомление в Telegram-чат о завершении работы.