POSTGRESQL_DATA_WRITER
POSTGRESQL_DATA_WRITER массовый загрузчик, подходящий для загрузки большого количества записей в базу данных PostgreSQL. Считывает данные через входной порт. Использует специальную утилиту Copy, которая позволяет загружать данные очень быстро. Для остальных случаев лучше использовать DATABASE_WRITER, для которого не требуется использование специальной утилиты.
Порты POSTGRESQL_DATA_WRITER:
| Тип порта | Номер | Обязательный | Описание | Метаданные |
|---|---|---|---|---|
| Input | 1-n | да | Записи для загрузки в базу данных | Любые |
Атрибуты POSTGRESQL_DATA_WRITER:
| Атрибут | Обязательный | Описание | Возможные значения |
|---|---|---|---|
| dbConnection | да | Параметры соединения с базой данных. В список параметров для подключения могут входить: database, user, password, host, port. Параметры можно указать в атрибуте конкретного узла либо в глобальных параметрах графа. |
|
| table | да | Имя таблицы, в которую производится запись |
|
| parameters | нет | Параметры, которые могут использоваться в качестве параметров утилитой psql или оператором \copy. Указывается последовательность ключ=значение, отделенные друг от друга точкой с запятой, двоеточием или вертикальной чертой. Если значение какого-либо параметра содержит точку с запятой, двоеточие или вертикальную черту, такое значение должно быть заключено в двойные кавычки. Сейчас доступны к указанию columns |
|
Пример.
Необходимо загрузить записи с метаданными «Product» (string), «Amount» (int), «date» (date) и «Price» (float) в таблицу Products в базу данных postgres с именем пользователя user001.
- Cоздать подключение CONN
URL="postgres://user001:pass123@localhost:5432/postgres"
- Настроить узел, передающий данные.
- Создать метаданные.
- Заполнить атрибуты узла POSTGRESQL_DATA_WRITER
dbConnection="CONN"
table="Products"
parameters="columns=${COLUMNS}"
После запуска графа данные будут внесены в базу:
