Работа с Parquet в ClickHouse
Parquet — это эффективный формат файла для хранения данных в колонно-ориентированном виде. ClickHouse поддерживает как чтение, так и запись файлов Parquet.
При указании пути к файлу в запросе, откуда ClickHouse попытается прочитать, будет зависеть от варианта ClickHouse, который вы используете.
Если вы используете clickhouse-local
, он будет читать из места, относительно того, где вы запустили ClickHouse Local.
Если вы используете ClickHouse Server или ClickHouse Cloud через clickhouse client
, он будет читать из места, относительно директории /var/lib/clickhouse/user_files/
на сервере.
Импорт из Parquet
Перед загрузкой данных мы можем использовать функцию file() для изучения структуры примерного файла parquet:
Мы использовали Parquet в качестве второго аргумента, чтобы ClickHouse знал формат файла. Это выведет колонки с типами:
Мы также можем исследовать файлы перед фактическим импортом данных, используя всю мощь SQL:
Мы можем пропустить явную установку формата для file()
и INFILE
/OUTFILE
.
В этом случае ClickHouse автоматически определит формат на основе расширения файла.
Импорт в существующую таблицу
Давайте создадим таблицу, в которую мы будем импортировать данные Parquet:
Теперь мы можем импортировать данные, используя предложение FROM INFILE
:
Обратите внимание, что ClickHouse автоматически конвертировал строки Parquet (в колонке date
) в тип Date
. Это происходит потому, что ClickHouse автоматически выполняет операцию преобразования типов на основе типов в целевой таблице.
Вставка локального файла на удаленный сервер
Если вы хотите вставить локальный файл Parquet на удаленный сервер ClickHouse, вы можете сделать это с помощью передачи содержимого файла в clickhouse-client
, как показано ниже:
Создание новых таблиц из Parquet файлов
Поскольку ClickHouse читает схему файла parquet, мы можем создавать таблицы на лету:
Это автоматически создаст и заполнит таблицу на основе заданного файла parquet:
По умолчанию ClickHouse строго относится к именам колонок, типам и значениям. Но иногда мы можем пропустить отсутствующие колонки или неподдерживаемые значения во время импорта. Это можно управлять с помощью настроек Parquet.
Экспорт в формат Parquet
При использовании INTO OUTFILE
с ClickHouse Cloud вам потребуется выполнять команды в clickhouse client
на машине, где будет записан файл.
Чтобы экспортировать любую таблицу или результат запроса в файл Parquet, мы можем использовать предложение INTO OUTFILE
:
Это создаст файл export.parquet
в рабочем каталоге.
Типы данных ClickHouse и Parquet
Типы данных ClickHouse и Parquet в основном идентичны, но все-таки немного различаются. Например, ClickHouse экспортирует тип DateTime
как int64
в Parquet. Если мы затем импортируем это обратно в ClickHouse, мы увидим числа (файл time.parquet):
В этом случае можно использовать преобразование типов:
Дальнейшее чтение
ClickHouse вводит поддержку множества форматов, как текстовых, так и бинарных, чтобы покрыть различные сценарии и платформы. Изучите больше форматов и способов работы с ними в следующих статьях:
- CSV и TSV форматы
- Avro, Arrow и ORC
- JSON форматы
- Regex и шаблоны
- Нативные и бинарные форматы
- SQL форматы
Также ознакомьтесь с clickhouse-local - переносным полнофункциональным инструментом для работы с локальными/удаленными файлами без необходимости в сервере Clickhouse.