Табличная Функция S3
Предоставляет табличный интерфейс для выбора/вставки файлов в Amazon S3. Эта табличная функция похожа на hdfs, но обеспечивает специфические для S3 возможности.
Синтаксис
Aргументы
path
— URL-адрес бакета с указанием пути к файлу. Поддерживает следующие подстановочные знаки в режиме "только чтение":*, ?, {abc,def} и {N..M}
гдеN, M
— числа,'abc', 'def'
— строки. Подробнее смотри здесь.format
— формат файла.structure
— cтруктура таблицы. Формат'column1_name column1_type, column2_name column2_type, ...'
.compression
— автоматически обнаруживает сжатие по расширению файла. Возможные значения:none
,gzip/gz
,brotli/br
,xz/LZMA
,zstd/zst
. Необязательный параметр.
Возвращаемые значения
Таблица с указанной структурой для чтения или записи данных в указанный файл.
Примеры
Создание таблицы из файла S3 https://storage.yandexcloud.net/my-test-bucket-768/data.csv
и выбор первых трех столбцов из нее:
Запрос:
Результат:
То же самое, но файл со сжатием gzip
:
Запрос:
Результат:
Примеры использования
Предположим, у нас есть несколько файлов со следующими URI на S3:
- 'https://storage.yandexcloud.net/my-test-bucket-768/some_prefix/some_file_1.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/some_prefix/some_file_2.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/some_prefix/some_file_3.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/some_prefix/some_file_4.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/another_prefix/some_file_1.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/another_prefix/some_file_2.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/another_prefix/some_file_3.csv'
- 'https://storage.yandexcloud.net/my-test-bucket-768/another_prefix/some_file_4.csv'
Подсчитаем количество строк в файлах, заканчивающихся цифрами от 1 до 3:
Подсчитаем общее количество строк во всех файлах этих двух каталогов:
Если список файлов содержит диапазоны чисел с ведущими нулями, используйте конструкцию с фигурными скобками для каждой цифры отдельно или используйте ?
.
Подсчитаем общее количество строк в файлах с именами file-000.csv
, file-001.csv
, ... , file-999.csv
:
Запишем данные в файл test-data.csv.gz
:
Запишем данные из существующей таблицы в файл test-data.csv.gz
:
Партиционирование при записи данных
Если при добавлении данных в таблицу S3 указать выражение PARTITION BY
, то для каждого значения ключа партиционирования создается отдельный файл. Это повышает эффективность операций чтения.
Примеры
- При использовании ID партиции в имени ключа создаются отдельные файлы:
В результате данные будут записаны в три файла: file_x.csv
, file_y.csv
и file_z.csv
.
- При использовании ID партиции в названии бакета создаются файлы в разных бакетах:
В результате будут созданы три файла в разных бакетах: my_bucket_1/file.csv
, my_bucket_10/file.csv
и my_bucket_20/file.csv
.
Смотрите также