Функция таблицы file
Движок таблицы, который предоставляет интерфейс, похожий на таблицу, для выполнения SELECT и INSERT в файлы, аналогично функции таблицы s3. Используйте file(), работая с локальными файлами, и s3(), работая с хранилищами объектов, такими как S3, GCS или MinIO.
Функцию file можно использовать в запросах SELECT и INSERT для чтения из файлов или записи в них.
Синтаксис
Параметры
path— Относительный путь к файлу от user_files_path. В режиме только для чтения поддерживает следующие глобусы:*,?,{abc,def}(где'abc'и'def'являются строками) и{N..M}(гдеNиMявляются числами).path_to_archive- Относительный путь к архиву zip/tar/7z. Поддерживает такие же глобусы, какpath.format— формат файла.structure— Структура таблицы. Формат:'column1_name column1_type, column2_name column2_type, ...'.compression— Существующий тип сжатия при использовании в запросеSELECTили желаемый тип сжатия при использовании в запросеINSERT. Поддерживаемые типы сжатия:gz,br,xz,zst,lz4иbz2.
Возвращаемое значение
Таблица для чтения или записи данных в файла.
Примеры записи в файл
Запись в TSV файл
В результате данные записываются в файл test.tsv:
Разделенная запись в несколько TSV файлов
Если вы укажете выражение PARTITION BY при вставке данных в функцию таблицы типа file(), то для каждой партиции будет создан отдельный файл. Разделение данных на отдельные файлы помогает улучшить производительность операций чтения.
В результате данные записываются в три файла: test_1.tsv, test_2.tsv и test_3.tsv.
Примеры чтения из файла
SELECT из CSV файла
Сначала установите user_files_path в конфигурации сервера и подготовьте файл test.csv:
Затем прочитайте данные из test.csv в таблицу и выберите ее первые две строки:
Вставка данных из файла в таблицу
Чтение данных из table.csv, находящегося в archive1.zip и/или archive2.zip:
Глобусы в пути
Пути могут использовать глобальную подстановку. Файлы должны соответствовать всему шаблону пути, а не только суффиксу или префиксу. Есть одно исключение: если путь указывает на существующий
каталог и не использует глобусы, к пути будет неявно добавлен *, чтобы
выбрать все файлы в каталоге.
*— Представляет произвольное количество символов, кроме/, включая пустую строку.?— Представляет произвольный один символ.{some_string,another_string,yet_another_one}— Заменяет любую из строк'some_string', 'another_string', 'yet_another_one'. Строки могут содержать символ/.{N..M}— Представляет любое число>= Nи<= M.**- Представляет все файлы внутри папки рекурсивно.
Конструкции с {} аналогичны функциям таблиц remote и hdfs.
Пример
Предположим, есть следующие файлы с относительными путями:
some_dir/some_file_1some_dir/some_file_2some_dir/some_file_3another_dir/some_file_1another_dir/some_file_2another_dir/some_file_3
Запросите общее количество строк во всех файлах:
Альтернативное выражение пути, которое достигает того же:
Запросите общее количество строк в some_dir, используя неявный *:
Если ваш список файлов содержит числовые диапазоны с ведущими нулями, используйте конструкцию с фигурными скобками для каждой цифры отдельно или используйте ?.
Пример
Запросите общее количество строк в файлах с именами file000, file001, ... , file999:
Пример
Запросите общее количество строк из всех файлов внутри каталога big_dir/ рекурсивно:
Пример
Запросите общее количество строк из всех файлов file002 внутри любой папки в каталоге big_dir/ рекурсивно:
Виртуальные колонки
_path— Путь к файлу. Тип:LowCardinality(String)._file— Имя файла. Тип:LowCardinality(String)._size— Размер файла в байтах. Тип:Nullable(UInt64). Если размер файла неизвестен, значение равноNULL._time— Время последнего изменения файла. Тип:Nullable(DateTime). Если время неизвестно, значение равноNULL.
Разделение, аналогичное Hive
Когда use_hive_partitioning установлен в 1, ClickHouse будет обнаруживать разделение в стиле Hive в пути (/name=value/) и позволит использовать столбцы партиции в качестве виртуальных столбцов в запросе. Эти виртуальные столбцы будут иметь такие же имена, как в разделенном пути, но начиная с _.
Пример
Использование виртуального столбца, созданного с разделением в стиле Hive
Настройки
- engine_file_empty_if_not_exists - позволяет выбирать пустые данные из файла, который не существует. По умолчанию отключено.
- engine_file_truncate_on_insert - позволяет очищать файл перед вставкой в него. По умолчанию отключено.
- engine_file_allow_create_multiple_files - позволяет создавать новый файл при каждой вставке, если формат имеет суффикс. По умолчанию отключено.
- engine_file_skip_empty_files - позволяет пропускать пустые файлы при чтении. По умолчанию отключено.
- storage_file_read_method - метод чтения данных из файла хранилища, один из: read, pread, mmap (только для clickhouse-local). Значение по умолчанию:
preadдля clickhouse-server,mmapдля clickhouse-local.
Смотрите также