当前位置：首页 > news >正文

DeepSeek总结的clickhousectl v0.2.0: Postgres, ClickPipes 等更多功能

news 2026/5/24 23:08:52

来源：https://clickhouse.com/blog/clickhousectl-v0-2-0-postgres-clickpipes-more

clickhousectl v0.2.0: Postgres, ClickPipes 等更多功能

作者:Al Brown
日期:2026年5月20日
阅读时间:7分钟

我们发布了 clickhousectl v0.2.0。此版本增加了对 Postgres（本地和 ClickHouse Cloud 托管）的支持、对所有支持来源的 ClickPipes 管理、针对云服务的 SQL over HTTP、一些对代理友好的输出调整，以及一个用于 ClickHouse Cloud API 的独立 Rust 客户端库。

如果您已安装 clickhousectl，请使用以下命令更新：

clickhousectl update

如果您未安装，请使用以下命令安装：

curlhttps://clickhouse.com/cli|sh

Postgres

clickhousectl 现在也管理 Postgres。就像 ClickHouse 一样，您可以在本地（基于 Docker）和 ClickHouse Cloud（托管 Postgres）中使用它。在本地开发，当您准备好投入生产时再转到云环境。由 ClickHouse 管理的 Postgres 为您提供最快、企业级的云 Postgres，由 NVMe 支持，具备高可用性、只读副本和时间点恢复功能。

本地 Postgres 作为 Docker 容器运行，由（名称，主版本）标识。数据位于.clickhouse/servers/<name>-pg<major>/data/下，因此单个名称可以托管多个具有隔离状态的 Postgres 主版本。支持的版本有 16、17 和 18。

# 预拉取镜像（可选；start 会按需拉取）clickhousectllocalinstallpostgres@16# 启动一个 Postgres 实例clickhousectllocalpostgres start--namedev--version16--port5433# 使用 psql 连接（如果安装了 host psql，则使用它，否则使用 docker exec）clickhousectllocalpostgres client--namedev--query"SELECT 1"# 将连接变量写入 .envclickhousectllocalpostgres dotenv--namedev# 停止 / 移除clickhousectllocalpostgres stop dev clickhousectllocalpostgres remove dev

ClickHouse 和 Postgres 服务器共享同一个服务器列表，因此您可以在一个命令中并排看到两个引擎。

云托管的 Postgres 需要 ClickHouse Cloud 帐户，并且 CLI 必须使用 API 密钥进行身份验证。

# 创建一个托管的 Postgres 服务clickhousectl cloud postgres create\--namemy-pg\--regionus-east-1\--sizec6gd.large\--storage-gb100\--pg-version17\--ha-typesync

ClickPipes

clickhousectl 现在创建和管理 ClickPipes，这是 ClickHouse Cloud 用于流式和批量摄取的托管连接器。

支持的来源：

来源	模式	子命令
S3 / GCP / Azure Blob	批量	`clickpipe create object-storage`
Kafka / Redpanda / Confluent / MSK	流式	`clickpipe create kafka`
Amazon Kinesis	流式	`clickpipe create kinesis`
Postgres	CDC	`clickpipe create postgres`
MySQL	CDC	`clickpipe create mysql`
MongoDB	CDC	`clickpipe create mongodb`
BigQuery	快照	`clickpipe create bigquery`

创建 Kafka 管道：

clickhousectl cloud clickpipe create kafka<service-id>\--namemy-kafka-pipe\--brokers'broker:9092'--topicsevents\--formatJSONEachRow\--kafka-type redpanda\--authSCRAM-SHA-256--usernameuser--passwordpass\--ca-certificate ./ca.crt\--databasedefault--tableevents\--column"event_id:Int64"--column"name:String"

创建 Postgres CDC 管道：

clickhousectl cloud clickpipe create postgres<service-id>\--namemy-pg-pipe\--hostdb.example.com --pg-database mydb\--usernamepguser--passwordpgpass\--table-mapping"public.users:public_users"\--table-mapping"public.orders:public_orders"

一旦管道运行，您可以列出、启动、停止、扩展、重新同步（对于 CDC 管道）和删除它：

clickhousectl cloud clickpipe list<service-id>clickhousectl cloud clickpipe scale<service-id><clickpipe-id>\--replicas2--cpu-millicores250--memory-gb1clickhousectl cloud clickpipe resync<service-id><clickpipe-id>

改进

查询 ClickHouse Cloud 中的 ClickHouse 服务

查询 ClickHouse Cloud 中的 ClickHouse 服务不再需要本地 ClickHouse 二进制文件作为客户端。CLI 现在使用 ClickHouse Cloud 的查询端点通过 HTTP 发送 SQL。

cloud service create默认在新服务上预置一个查询端点。系统会创建一个新的 API 密钥，其权限范围仅限于新服务（因此不能用于恶意行为），并且查询端点本身被锁定，只能使用新的 API 密钥。CLI 将新密钥与您现有的 API 密钥一起存储。然后，cloud service query使用该密钥通过 HTTP 运行 SQL：

clickhousectl cloudservicequery--namemy-service--query"SELECT 1"clickhousectl cloudservicequery--id<service-id>\--query"SELECT count() FROM system.tables"\--formatJSONEachRowecho"SELECT 1+1"|clickhousectl cloudservicequery--namemy-service

对于没有查询端点或存储密钥的现有服务，cloud service query会在首次使用时惰性地预置一个。传递--no-auto-enable将使其失败，或者在service create时传递--no-enable-query以跳过创建时的钩子。

查询端点绑定使用角色sql_console_admin创建，该角色仅允许在所绑定服务内进行读写操作。API 密钥本身没有组织级别的角色，因此该绑定是授予访问权限的唯一途径：被盗的密钥只能攻击为其生成的服务。cloud service delete会从credentials.json中删除存储的密钥。

使用体验

两个小的更改，当代理（或人类）读取输出时会有所不同。

更轻量的表格。表格输出现在使用带有 ASCII 分隔符的 Markdown 风格表格，而不是带圆角的 Unicode 框线绘制字符。这使得复制到 markdown 文件、PR 描述或与 LLM 的聊天中更加友好，并且当代理读取时使用更少的令牌。

用于凭据解析的--debug。向任何 cloud 命令传递--debug，可以在命令运行前将解析出的凭据源和 API URL 打印到 stderr。

clickhousectl cloud--debugservicelist# [debug] auth source: credentials file (.clickhouse/credentials.json)# [debug] api url: https://api.clickhouse.cloud/v1# ... 正常输出 ...