Skip to main content
Skip to main content
Edit this page

Интерфейс gRPC

Введение​

ClickHouse поддерживает интерфейс gRPC. Это система удаленного вызова процедур с открытым исходным кодом, которая использует HTTP/2 и Protocol Buffers. В реализации gRPC в ClickHouse поддерживаются:

  • SSL;
  • аутентификация;
  • сессии;
  • сжатие;
  • параллельные запросы, выполняемые через один канал;
  • отмена запросов;
  • получение прогресса операций и логов;
  • внешние таблицы.

Спецификация интерфейса содержится в clickhouse_grpc.proto.

Конфигурация gRPC​

Чтобы сделать доступным интерфейс gRPC, нужно задать порт с помощью настройки grpc_port в конфигурации сервера. Другие настройки приведены в примере:

<grpc_port>9100</grpc_port>
    <grpc>
        <enable_ssl>false</enable_ssl>

        <!-- Пути к файлам сертификатов и ключей. Используются при включенном SSL -->
        <ssl_cert_file>/path/to/ssl_cert_file</ssl_cert_file>
        <ssl_key_file>/path/to/ssl_key_file</ssl_key_file>

        <!-- Запрашивает ли сервер сертификат клиента -->
        <ssl_require_client_auth>false</ssl_require_client_auth>

        <!-- Используется, если необходимо запрашивать сертификат -->
        <ssl_ca_cert_file>/path/to/ssl_ca_cert_file</ssl_ca_cert_file>

        <!-- Алгоритм сжатия по умолчанию (применяется, если клиент не указывает алгоритм, см. result_compression в QueryInfo).
             Поддерживаются алгоритмы: none, deflate, gzip, stream_gzip -->
        <compression>deflate</compression>

        <!-- Уровень сжатия по умолчанию (применяется, если клиент не указывает уровень сжатия, см. result_compression в QueryInfo).
             Поддерживаемые уровни: none, low, medium, high -->
        <compression_level>medium</compression_level>

        <!-- Ограничение в байтах на размер отправляемых и принимаемых сообщений. -1 означает отсутствие ограничения -->
        <max_send_message_size>-1</max_send_message_size>
        <max_receive_message_size>-1</max_receive_message_size>

        <!-- Выводить ли детализированные логи -->
        <verbose_logs>false</verbose_logs>
    </grpc>

Встроенный клиент​

Можно написать клиент на любом языке программирования, который поддерживается gRPC, с использованием спецификации. Также можно воспользоваться встроенным Python клиентом. Он расположен в utils/grpc-client/clickhouse-grpc-client.py в репозитории. Для работы встроенного клиента требуются Python модули grpcio и grpcio-tools.

Клиент поддерживает аргументы:

  • --help – вывести справку и завершить работу.
  • --host HOST, -h HOST – имя сервера. Значение по умолчанию: localhost. Можно задать адрес IPv4 или IPv6.
  • --port PORT – номер порта. Этот порт должен быть задан в конфигурации сервера ClickHouse настройкой grpc_port. Значение по умолчанию: 9100.
  • --user USER_NAME, -u USER_NAME – имя пользователя. Значение по умолчанию: default.
  • --password PASSWORD – пароль. Значение по умолчанию: пустая строка.
  • --query QUERY, -q QUERY – запрос, который выполнится, когда используется неинтерактивный режим работы.
  • --database DATABASE, -d DATABASE – база данных по умолчанию. Если не указана, то будет использована база данных, заданная в настройках сервера (по умолчанию default).
  • --format OUTPUT_FORMAT, -f OUTPUT_FORMAT – формат вывода результата. Значение по умолчанию для интерактивного режима: PrettyCompact.
  • --debug – вывод отладочной информации.

Чтобы запустить клиент в интерактивном режиме, не указывайте аргумент --query.

В неинтерактивном режиме данные запроса можно передать через stdin.

Пример использования клиента

В примере создается таблица, и в нее загружаются данные из CSV файла. Затем выводится содержимое таблицы.

./clickhouse-grpc-client.py -q "CREATE TABLE grpc_example_table (id UInt32, text String) ENGINE = MergeTree() ORDER BY id;"
echo "0,Input data for" > a.txt ; echo "1,gRPC protocol example" >> a.txt
cat a.txt | ./clickhouse-grpc-client.py -q "INSERT INTO grpc_example_table FORMAT CSV"

./clickhouse-grpc-client.py --format PrettyCompact -q "SELECT * FROM grpc_example_table;"

Результат:

┌─id─┬─text──────────────────┐
│  0 │ Input data for        │
│  1 │ gRPC protocol example │
└────┴───────────────────────┘