gRPC 接口

简介

ClickHouse 支持 gRPC 接口。gRPC 是一个开源的远程过程调用系统，使用 HTTP/2 和 Protocol Buffers。ClickHouse 中 gRPC 的实现支持：

SSL；
身份验证；
会话；
压缩；
通过同一通道执行并行查询；
取消查询；
获取进度和日志；
外部表。

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_require_client_auth=true 时使用以下文件 -->
        <ssl_ca_cert_file>/path/to/ssl_ca_cert_file</ssl_ca_cert_file>

        <!-- 默认压缩算法(当客户端未指定其他算法时应用,参见 QueryInfo 中的 result_compression)。
             支持的算法:none、deflate、gzip、stream_gzip -->
        <compression>deflate</compression>

        <!-- 默认压缩级别(当客户端未指定其他级别时应用,参见 QueryInfo 中的 result_compression)。
             支持的级别: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。内置客户端需要安装 grpcio 和 grpcio-tools 这两个 Python 模块。

客户端支持以下参数：

--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 -e "0,Input data for\n1,gRPC protocol example" > a.csv
cat a.csv | ./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 │ gRPC 协议示例的       │
│  1 │ 输入数据              │
└────┴───────────────────────┘

简介​

gRPC 配置​

内置客户端​

简介

gRPC 配置

内置客户端