Все ноды/Data/DataFrame Ops
DF: выбор столбцов
SQL SELECT: выбирает/переименовывает/выкидывает колонки. Каждая строка списка задаёт source → alias или drop.
Тип в графе: df_select
Exec
Можно включить ветку ошибки (expose_error_output) и обработать сбой отдельным путём.
Порты можно разделить на исполнение и данные (split ports).
Как попробовать
Минимальный рабочий воркфлоу
- Исполнение + данные
Запускается сразу
Как применять
Работает с колонками таблицы: оставляет нужные, переименовывает, выбрасывает лишние. Строки она не трогает — отбор строк это df_query, схлопывание повторов — df_drop_duplicates.
Чаще всего её ставят перед выгрузкой (чтобы в файл ушли только нужные колонки с человеческими заголовками) и перед df_merge — соединение требует, чтобы ключевые колонки в обеих таблицах назывались одинаково.
Как это работает
Каждая строка списка «Столбцы» описывает одну колонку: source — имя во входной таблице,
alias — новое имя (пусто = оставить прежнее), drop — отметка «убрать».
Дальше список делится надвое. Если есть хотя бы одна строка без drop, результат состоит
ровно из таких строк и в том порядке, в котором вы их перечислили; всё остальное отбрасывается.
Если drop стоит у всех строк, включается обратный режим: берутся все колонки входа, минус
перечисленные. Пустой список пропускает таблицу без изменений.
Колонка, попавшая в список и как сохраняемая, и как удаляемая, будет удалена.
Частые ошибки
- Одна строка с
dropрядом со строками без него. Это не «убрать одну колонку из двенадцати»: как только в списке есть хоть одна строка на сохранение, в результат попадёт только она. Чтобы выбросить одну колонку и оставить прочие, все строки списка должны быть помеченыdrop. - Опечатка в имени сохраняемой колонки. Нода падает с сообщением, что такой колонки нет. Удаление несуществующей колонки, наоборот, проходит молча — убирать нечего.
- Порядок строк списка недооценивают. Это и есть порядок колонок на выходе: заголовки в CSV встанут именно так.
- Переименование ждут от
alias, а колонку не перечислили.aliasработает только у строки, которая колонку сохраняет; если её нет в списке при непустом списке сохраняемых, колонка просто исчезнет.
Входы
| Порт | Провод | Данные | Примечания |
|---|---|---|---|
DataFramedf | Исполнение + данныеexecute_data | dataframe |
Выходы
| Порт | Провод | Данные | Примечания |
|---|---|---|---|
Successoutput | Исполнение + данныеexecute_data | dataframe | |
Erroron_error | Исполнение + данныеexecute_data | — | показывается, когда expose_error_output = true |
Настройки
| Поле | Тип | По умолчанию | Описание |
|---|---|---|---|
Столбцыcolumns | array | — | Если пусто, все столбцы сохраняются без изменений. Строки с ``drop`` удаляются, остальные образуют список сохраняемых столбцов (в этом порядке). |
Общие поля
Эти три поля есть у каждой ноды: платформа добавляет их сама, а не автор ноды.
expose_error_output— Если включено, показывает выход выполнения для подключения нод, которые запускаются при сбое этого шага.split_ports_in— Показывать отдельные порты входа для выполнения и данных вместо одного объединённого.split_ports_out— Показывать отдельные порты выхода для выполнения и данных вместо одного объединённого.