Все ноды/Data/DataFrame Ops

DF: склейка

SQL UNION ALL / column-stack: склеивает два DataFrame по строкам или колонкам.

DF: склейка
LeftSuccess
RightError

Тип в графе: df_concat

Exec

Можно включить ветку ошибки (expose_error_output) и обработать сбой отдельным путём.

Порты можно разделить на исполнение и данные (split ports).

Как попробовать

Минимальный рабочий воркфлоу

Вход
DF: склейка
Выход
  • Исполнение + данные
Нажмите «Скопировать ноды», откройте редактор и нажмите Ctrl+V на холсте.

Запускается сразу

Как применять

Складывает две таблицы в одну: либо одну под другую (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_datadataframe
RightrightДанныеdatadataframe

Выходы

ПортПроводДанныеПримечания
SuccessoutputИсполнение + данныеexecute_datadataframe
Erroron_errorИсполнение + данныеexecute_data

показывается, когда expose_error_output = true

Настройки

ПолеТипПо умолчаниюОписание
Осьaxisstringrows

``rows`` = добавить A, затем B (UNION ALL); ``columns`` = соединить бок о бок по индексу.

Варианты: rows, columns

Игнорировать исходный индексignore_indexbooleantrue

Перенумеровать строки 0..n-1 вместо сохранения индексов источников.

показывается при axis = rows

Общие поля

Эти три поля есть у каждой ноды: платформа добавляет их сама, а не автор ноды.

  • expose_error_output — Если включено, показывает выход выполнения для подключения нод, которые запускаются при сбое этого шага.
  • split_ports_in — Показывать отдельные порты входа для выполнения и данных вместо одного объединённого.
  • split_ports_out — Показывать отдельные порты выхода для выполнения и данных вместо одного объединённого.