Все ноды/Data/DataFrame Ops
DF: склейка
SQL UNION ALL / column-stack: склеивает два DataFrame по строкам или колонкам.
Тип в графе: df_concat
Exec
Можно включить ветку ошибки (expose_error_output) и обработать сбой отдельным путём.
Порты можно разделить на исполнение и данные (split ports).
Как попробовать
Минимальный рабочий воркфлоу
- Исполнение + данные
Запускается сразу
Как применять
Складывает две таблицы в одну: либо одну под другую (SQL UNION ALL), либо бок о бок. Берите её, когда таблицы однотипны — выгрузки за два месяца, ответы двух источников. Соединение по общему ключу — это df_merge.
Входы такие же, как у соединения: «Left» запускает ноду и приносит значение, «Right» приносит только значение. Ветка, готовящая правую таблицу, должна отработать раньше по цепочке выполнения, иначе нода упадёт с сообщением, что на входе не таблица.
Как это работает
«Ось» = rows — строки правой таблицы дописываются после строк левой. Колонки сопоставляются по
именам, а не по позициям; колонка, которой нет во второй таблице, заполняется у её строк
пустыми значениями. В отличие от SQL UNION, совпадение набора колонок не обязательно.
«Ось» = columns — таблицы ставятся рядом и совмещаются по номерам строк, а не по значениям.
«Игнорировать исходный индекс» перенумеровывает строки результата с нуля. На оси columns
переключатель скрыт: там нумерация строк и есть то, по чему таблицы совмещаются, и трогать её
нельзя.
Частые ошибки
- Склейка по колонкам после фильтра. df_query сохраняет исходную нумерацию строк, а df_sort и df_drop_duplicates её переписывают. Если совместить бок о бок таблицы с разной нумерацией, строки разъедутся и появятся пустые ячейки. Совмещать по значению умеет только df_merge.
- Ожидание, что склейка уберёт повторы. Это UNION ALL: одинаковые строки останутся обе. Поставьте следом df_drop_duplicates.
- Одно и то же поле названо по-разному.
emailиEmailна осиrowsдадут две колонки, наполовину пустые. Приведите имена через df_select до склейки.
Входы
| Порт | Провод | Данные | Примечания |
|---|---|---|---|
Leftleft | Исполнение + данныеexecute_data | dataframe | |
Rightright | Данныеdata | dataframe |
Выходы
| Порт | Провод | Данные | Примечания |
|---|---|---|---|
Successoutput | Исполнение + данныеexecute_data | dataframe | |
Erroron_error | Исполнение + данныеexecute_data | — | показывается, когда expose_error_output = true |
Настройки
| Поле | Тип | По умолчанию | Описание |
|---|---|---|---|
Осьaxis | string | rows | ``rows`` = добавить A, затем B (UNION ALL); ``columns`` = соединить бок о бок по индексу. Варианты: |
Игнорировать исходный индексignore_index | boolean | true | Перенумеровать строки 0..n-1 вместо сохранения индексов источников. показывается при axis = rows |
Общие поля
Эти три поля есть у каждой ноды: платформа добавляет их сама, а не автор ноды.
expose_error_output— Если включено, показывает выход выполнения для подключения нод, которые запускаются при сбое этого шага.split_ports_in— Показывать отдельные порты входа для выполнения и данных вместо одного объединённого.split_ports_out— Показывать отдельные порты выхода для выполнения и данных вместо одного объединённого.