Роль Postgres Pro, которой позволено выполнять запросы в DuckDB и использовать секреты. По умолчанию доступ есть только у суперпользователей. Если этот параметр настроен, но роль не существует в момент выполнения CREATE EXTENSION pgpro_duckdb, она будет создана автоматически. У этой роли будет доступ к секретам DuckDB.

По умолчанию: ""

Доступ: необходимо указать в файле postgresql.conf и перезапустить сервер

Отключает и запрещает доступ к конкретным файловым системам. Этот параметр применяется только к обычным пользователям. Суперпользователи всегда имеют полный доступ ко всем файловым системам. Если в duckdb.postgres_role указан недоверенный пользователь, рекомендуется отключить LocalFileSystem. В противном случае пользователи смогут читать и записывать любые файлы, к которым Postgres Pro имеет доступ.

По умолчанию: "LocalFileSystem"

Доступ: только суперпользователь

Определяет, разрешена ли автоматическая установка расширений, если они необходимы для выполнения запроса DuckDB.

По умолчанию: true

Доступ: только суперпользователь

Определяет, разрешён ли автоматический запуск расширений, если они необходимы для выполнения запроса DuckDB.

По умолчанию: true

Отключает установку расширений сообщества.

По умолчанию: false

Доступ: только суперпользователь

Предоставляет DuckDB доступ к внешним хранилищам (например, HTTP, S3 и т.д.). В настоящее время этот параметр недостаточно протестирован, и его отключение может привести ошибкам при работе с функциями pgpro_duckdb.

По умолчанию: true

Доступ: только суперпользователь

Максимальный объём памяти, который DuckDB может использовать в рамках одного подключения Postgres Pro. Этот параметр сравним с параметром Postgres Pro work_mem. Если указана пустая строка, по умолчанию используется 80% оперативной памяти, как в DuckDB.

По умолчанию: "4GB"

Доступ: только суперпользователь

Максимальное количество потоков DuckDB для каждого подключения Postgres Pro. -1 означает, что будет использоваться значение по умолчанию DuckDB, то есть количество потоков будет соответствовать количеству процессоров (ЦП).

По умолчанию: -1

Доступ: только суперпользователь

Максимальное количество рабочих процессов PostgreSQL, используемых для одного сканирования Postgres Pro. Этот параметр сравним с параметром Postgres Pro max_parallel_workers_per_gather.

По умолчанию: 2

Доступ: общий

Позволяет DuckDB запускать расширения с неверными или отсутствующими подписями. Этот параметр полезен при разработке расширений DuckDB.

По умолчанию: false

Доступ: только суперпользователь

Читает Parquet-файл из удалённого (через httpfs) или локального хранилища.

Возвращает строки DuckDB. Их можно расширить с помощью * или выбрать конкретные столбцы с помощью синтаксиса r['mycol']. Чтобы выбрать конкретные столбцы, вызову функции необходимо присвоить простой псевдоним, например r:

SELECT * FROM read_parquet('file.parquet');
SELECT r['id'], r['name'] FROM read_parquet('file.parquet') r WHERE r['age'] > 21;
SELECT COUNT(*) FROM read_parquet('file.parquet');

Полезные ресурсы:

Требуются следующие аргументы:

Необязательные параметры повторяют параметры функции DuckDB read_parquet. Чтобы указать дополнительные параметры, используйте parameter := 'value'.

Читает CSV-файл из удалённого (через httpfs) или локального хранилища.

Возвращает строки DuckDB. Их можно расширить с помощью * или выбрать конкретные столбцы с помощью синтаксиса r['mycol']. Чтобы выбрать конкретные столбцы, вызову функции необходимо присвоить простой псевдоним, например r:

SELECT * FROM read_csv('file.csv');
SELECT r['id'], r['name'] FROM read_csv('file.csv') r WHERE r['age'] > 21;
SELECT COUNT(*) FROM read_csv('file.csv');

Полезные ресурсы:

Требуются следующие аргументы:

Необязательные параметры повторяют параметры функции DuckDB read_csv. Чтобы указать дополнительные параметры, используйте parameter := 'value'.

Особенности совместимости:

Читает JSON-файл из удалённого (через httpfs) или локального хранилища.

Возвращает строки DuckDB. Их можно расширить с помощью * или выбрать конкретные столбцы с помощью синтаксиса r['mycol']. Чтобы выбрать конкретные столбцы, вызову функции необходимо присвоить простой псевдоним, например r:

SELECT * FROM read_parquet('file.parquet');
SELECT r['id'], r['name'] FROM read_parquet('file.parquet') r WHERE r['age'] > 21;
SELECT COUNT(*) FROM read_parquet('file.parquet');

Полезные ресурсы:

Требуются следующие аргументы:

Необязательные параметры повторяют параметры функции DuckDB read_json. Чтобы указать дополнительные параметры, используйте parameter := 'value'.

Особенности совместимости:

Читает таблицу Iceberg из удалённого (через httpfs) или локального хранилища.

Чтобы использовать iceberg_scan, включите расширение iceberg:

SELECT duckdb.install_extension('iceberg');

Возвращает строки DuckDB. Их можно расширить с помощью * или выбрать конкретные столбцы с помощью синтаксиса r['mycol']. Чтобы выбрать конкретные столбцы, вызову функции необходимо присвоить простой псевдоним, например r:

SELECT * FROM iceberg_scan('data/iceberg/table');
SELECT r['id'], r['name'] FROM iceberg_scan('data/iceberg/table') r WHERE r['age'] > 21;
SELECT COUNT(*) FROM iceberg_scan('data/iceberg/table');

Полезные ресурсы:

Требуются следующие аргументы:

Необязательные параметры повторяют параметры функции DuckDB iceberg_scan. Чтобы указать дополнительные параметры, используйте parameter := 'value'.

Чтобы использовать iceberg_metadata, включите расширение iceberg:

SELECT duckdb.install_extension('iceberg');

Возвращает метаданные таблицы Iceberg. Данные возвращаются в виде набора icerberg_metadata_record, который определяется следующим образом:

CREATE TYPE duckdb.iceberg_metadata_record AS (
  manifest_path TEXT,
  manifest_sequence_number NUMERIC,
  manifest_content TEXT,
  status TEXT,
  content TEXT,
  file_path TEXT
);

Полезные ресурсы:

Требуются следующие аргументы:

Необязательные параметры повторяют параметры функции DuckDB iceberg_metadata. Чтобы указать дополнительные параметры, используйте parameter := 'value'.

Читает набор данных Delta из удалённого (через httpfs) или локального хранилища.

Чтобы использовать delta_scan, включите расширение delta:

SELECT duckdb.install_extension('delta');

Возвращает строки DuckDB. Их можно расширить с помощью * или выбрать конкретные столбцы с помощью синтаксиса r['mycol']. Чтобы выбрать конкретные столбцы, вызову функции необходимо присвоить простой псевдоним, например r:

SELECT * FROM delta_scan('/path/to/delta/dataset');
SELECT r['id'], r['name'] FROM delta_scan('/path/to/delta/dataset') r WHERE r['age'] > 21;
SELECT COUNT(*) FROM delta_scan('/path/to/delta/dataset');

Полезные ресурсы:

Требуются следующие аргументы:

Устанавливает расширение DuckDB и включает его автоматический запуск в каждом сеансе, который использует pgpro_duckdb.

SELECT duckdb.install_extension('iceberg');
SELECT duckdb.install_extension('avro', 'community');

По умолчанию эта функция может быть вызвана только суперпользователем, так как её можно использовать для загрузки и установки любых расширений. Чтобы позволить вызывать эту функцию другому администратору, например my_admin, ему можно выдать следующие права:

GRANT ALL ON FUNCTION duckdb.install_extension(TEXT, TEXT) TO my_admin;
GRANT ALL ON TABLE duckdb.extensions TO my_admin;
GRANT ALL ON SEQUENCE duckdb.extensions_table_seq TO my_admin;

Требуются следующие аргументы:

Напрямую выполняет запрос SELECT к DuckDB. Это может потребоваться, если запрос проще составить в синтаксисе DuckDB или если требуется использовать функцию, которая пока не поддерживается pgpro_duckdb. Например, ниже приведён запрос, в котором FROM помещён перед SELECT и используется списковое включение (list comprehension). Обе эти возможности не поддерживаются Postgres Pro.

SELECT * FROM duckdb.query('FROM range(10) as a(a) SELECT [a for i in generate_series(0, a)] as arr');

Напрямую выполняет запрос к DuckDB. В отличие от duckdb.query эта функция позволяет выполнять любой запрос, а не только SELECT. Основной недостаток заключается в том, что результат запроса записывается в журнал вместо того, чтобы вернуть строки. Рекомендуется по возможности использовать duckdb.query, а эту функцию использовать только при необходимости, например, чтобы запустить DDL.

pgpro_duckdb оставляет экземпляр DuckDB открытым между транзакциями. Это делается для того, чтобы сохранить состояние уровня сеанса, например вручную выполненные команды SET. Чтобы очистить состояние уровня сеанса, открытый экземпляр DuckDB можно закрыть с помощью следующего запроса:

CALL duckdb.recycle_ddb();