StartEvent_1 Task_step-1 Task_step-2 Task_step-3 Task_step-4 Task_step-5 Task_step-6 Task_step-7 Task_step-8 Task_step-9 Task_step-10 Task_step-11 GW_1 EndEvent_logged_not_found EndEvent_ready Flow_start_step_1 Airflow запускает DAG по расписанию. Система: Airflow Время: Мгновенно Flow_startevent_1_step_1 Flow_step_1_step_2 DAG ожидает подтверждения завершения сбора фида PCM от команды PCM. Система: Airflow Время: Зависит от команды PCM Flow_step_1_step_2 Flow_step_2_step_3 DAG скачивает фид PCM по предоставленной ссылке или получает доступ к данным фида из ClickHouse. Система: Airflow, ClickHouse Время: 5-30 мин Flow_step_2_step_3 Flow_step_3_step_4 Нормализация полей `article`, `original_article`, `brand` в данных фида PCM. Система: Airflow Время: 10-60 мин Flow_step_3_step_4 Flow_step_4_step_5 Выполнение GraphQL-запроса к Pimcore для получения текущих запчастей и жидкостей с их кроссами. Система: Airflow, Pimcore Время: 5-30 мин Flow_step_4_step_5 Flow_step_5_step_6 Для каждой запчасти/жидкости (clean) из Pimcore выполняется поиск в нормализованном фиде PCM. Система: Airflow Время: 30-120 мин Flow_step_5_step_6 Flow_step_6_gw_1 Проверка поля `original_article` и поиск уникальных значений, затем дедупликация результатов. Система: Airflow Время: 10-60 мин Flow_gw_1_step_7 Flow_step_7_step_9 Запись в лог информации о запчастях/жидкостях из Pimcore, которые не были найдены в фиде PCM. Система: Airflow Время: Мгновенно Flow_gw_1_step_8 Flow_step_8_end_logged_not_found Определение типа кросса (двухсторонний, замена) на основе условий поиска. Система: Airflow Время: 5-30 мин Flow_step_7_step_9 Flow_step_9_step_10 Запись или обновление информации о кроссах в коллекции `parts_crosses` в MongoDB. Система: Airflow, MongoDB Время: 5-30 мин Flow_step_9_step_10 Flow_step_10_step_11 Отправка данных о созданных/обновленных кроссах в очередь RabbitMQ для дальнейшей обработки и обновления в Pimcore. Система: Airflow, RabbitMQ Время: 1-10 мин Flow_step_10_step_11 Flow_step_11_end_ready Flow_step_6_gw_1 Flow_gw_1_step_7 Flow_gw_1_step_8 Запчасти/жидкости, не найденные в фиде PCM, залогированы. Процесс завершен для этих элементов. Flow_step_8_end_logged_not_found Кроссы созданы/обновлены в MongoDB и отправлены в RabbitMQ для обновления в Pimcore. Flow_step_11_end_ready ДА НЕТ