简介
支持的数据源
| 名称 | 徽标 | 类型 | 状态 | 描述 |
|---|---|---|---|---|
| Apache Kafka | 流式 | 稳定版本 | 配置 ClickPipes,开始将 Apache Kafka 中的流式数据摄取到 ClickHouse Cloud。 | |
| Confluent Cloud | 流式 | 稳定版本 | 通过我们的直接集成,充分发挥 Confluent 与 ClickHouse Cloud 的组合优势。 | |
| Redpanda | 流式 | 稳定版本 | 配置 ClickPipes,开始将 Redpanda 中的流式数据摄取到 ClickHouse Cloud。 | |
| AWS MSK | 流式 | 稳定版本 | 配置 ClickPipes,开始将 AWS MSK 中的流式数据摄取到 ClickHouse Cloud。 | |
| Azure Event Hubs | 流式 | 稳定版本 | 配置 ClickPipes,开始将 Azure Event Hubs 中的流式数据摄取到 ClickHouse Cloud。有关说明,请参阅 Azure Event Hubs FAQ。 | |
| WarpStream | 流式 | 稳定版本 | 配置 ClickPipes,开始将 WarpStream 中的流式数据摄取到 ClickHouse Cloud。 | |
| Amazon S3 | 对象存储 | 稳定版本 | 配置 ClickPipes 以从对象存储摄取海量数据。 | |
| Google Cloud Storage | 对象存储 | 稳定版本 | 配置 ClickPipes 以从对象存储摄取海量数据。 | |
| DigitalOcean Spaces | 对象存储 | 稳定版本 | 配置 ClickPipes 以从对象存储摄取海量数据。 | |
| Azure Blob 存储 | 对象存储 | 稳定版本 | 配置 ClickPipes 以从对象存储摄取海量数据。 | |
| Amazon Kinesis | 流式 | 稳定版本 | 配置 ClickPipes,开始将 Amazon Kinesis 中的流式数据摄取到 ClickHouse Cloud。 | |
| Postgres | DBMS | 稳定版本 | 配置 ClickPipes,开始将 Postgres 中的数据摄取到 ClickHouse Cloud。 | |
| MySQL | DBMS | Public Beta | 配置 ClickPipes,开始将 MySQL 中的数据摄取到 ClickHouse Cloud。 | |
| MongoDB | DBMS | 私有预览 | 配置 ClickPipes,开始将 MongoDB 中的数据摄取到 ClickHouse Cloud。 |
静态 IP 列表
- eu-central-1:适用于所有未明确列出的 EU 区域,以及 Azure EU 区域和在 2026 年 5 月 27 日之前创建的 Google Cloud EU 服务。
- eu-west-1:适用于 AWS
eu-west-1中所有在 2026 年 1 月 20 日或之后创建的服务 (在此日期之前创建的服务使用eu-central-1IP) 。 - us-east-1:适用于 AWS
us-east-1中的所有服务。 - ap-south-1:适用于 AWS
ap-south-1中所有在 2025 年 6 月 25 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ap-northeast-2:适用于 AWS
ap-northeast-2中所有在 2025 年 11 月 14 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - af-south-1:适用于 AWS
af-south-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ap-east-1:适用于 AWS
ap-east-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ap-northeast-1:适用于 AWS
ap-northeast-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ap-southeast-1:适用于 AWS
ap-southeast-1中所有在 2026 年 3 月 18 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ap-southeast-2:适用于 AWS
ap-southeast-2中所有在 2025 年 6 月 25 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ap-southeast-3:适用于 AWS
ap-southeast-3中所有在 2026 年 3 月 6 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - ca-central-1:适用于 AWS
ca-central-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - eu-north-1:适用于 AWS
eu-north-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用eu-central-1IP) 。 - eu-west-2:适用于 AWS
eu-west-2中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用eu-central-1IP) 。 - il-central-1:适用于 AWS
il-central-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - sa-east-1:适用于 AWS
sa-east-1中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - us-west-2:适用于 AWS
us-west-2中所有在 2025 年 6 月 24 日或之后创建的服务 (在此日期之前创建的服务使用us-east-2IP) 。 - us-east-2:适用于所有不符合上述规则的其他区域,包括 Azure 区域以及在 2026 年 5 月 27 日之前创建的 Google Cloud 服务。
AWS 静态 NAT IP 地址
| AWS 区域 | IP 地址 |
|---|---|
| eu-central-1 - 法兰克福 | 18.195.233.217, 3.127.86.90, 35.157.23.2, 18.197.167.47, 3.122.25.29, 52.28.148.40 |
| eu-west-1 - 爱尔兰 (自 2026 年 1 月 20 日起) | 54.228.1.92 , 54.72.101.254, 54.228.16.208, 54.76.200.104, 52.211.2.177, 54.77.10.134 |
| us-east-1 - 弗吉尼亚北部 | 54.82.38.199, 3.90.133.29, 52.5.177.8, 3.227.227.145, 3.216.6.184, 54.84.202.92, 3.131.130.196, 3.23.172.68, 3.20.208.150 |
| us-east-2 - 俄亥俄州 | 3.131.130.196, 3.23.172.68, 3.20.208.150, 3.132.20.192, 18.119.76.110, 3.134.185.180 |
| ap-south-1 - 孟买 (自 2025 年 6 月 25 日起) | 13.203.140.189, 13.232.213.12, 13.235.145.208, 35.154.167.40, 65.0.39.245, 65.1.225.89 |
| ap-northeast-2 - 首尔 (2025 年 11 月 14 日起) | 3.38.68.69, 52.78.68.128, 13.209.152.13, 3.38.24.84, 3.37.159.31, 3.34.25.104 |
| ap-southeast-1 - 新加坡 (自 2026 年 3 月 18 日起) | 13.215.65.134, 18.139.118.108, 47.130.197.47, 54.251.134.219, 54.254.98.29, 54.255.153.106 |
| ap-southeast-2 - 悉尼 (自 2025 年 6 月 25 日起) | 3.106.48.103, 52.62.168.142, 13.55.113.162, 3.24.61.148, 54.206.77.184, 54.79.253.17 |
| af-south-1 - 开普敦 (自 2026 年 4 月 15 日起) | 13.245.187.24, 15.240.60.178, 15.240.81.191, 13.245.25.101, 13.245.91.225, 15.240.54.195 |
| ap-east-1 - 香港 (自 2026 年 4 月 15 日起) | 18.166.168.168, 43.199.224.85, 95.40.0.242, 16.162.107.229, 43.199.125.240, 54.46.86.27 |
| ap-northeast-1 - 东京 (自 2026 年 4 月 15 日起) | 54.168.88.92, 35.76.97.79, 54.64.100.89, 54.178.40.17, 52.195.101.208, 13.193.109.245 |
| ap-southeast-1 - 新加坡 (2026 年 3 月 18 日起) | 47.130.197.47, 54.251.134.219, 18.139.118.108, 54.255.153.106, 54.254.98.29, 13.215.65.134 |
| ap-southeast-3 - 雅加达 (2026 年 3 月 6 日起) | 16.78.195.195, 43.218.184.235, 16.79.88.54, 16.78.153.162, 16.79.6.125, 108.137.52.155 |
| ca-central-1 - 加拿大 (自2026年4月15日起) | 52.60.123.235, 3.97.222.98, 3.99.62.248, 15.223.61.186, 3.96.255.101, 3.97.29.96 |
| eu-north-1 - 斯德哥尔摩 (自 2026 年 4 月 15 日起) | 13.63.1.65, 16.171.127.30, 56.228.76.44, 13.63.101.248, 16.170.124.188, 13.60.109.201 |
| eu-west-2 - 伦敦 (自 2026 年 4 月 15 日起) | 13.134.82.158, 16.60.209.167, 18.134.221.203, 16.60.139.176, 13.43.66.75, 3.11.78.183 |
| il-central-1 - 特拉维夫 (自 2026 年 4 月 15 日起) | 16.164.25.13, 51.84.162.29, 51.85.90.183, 51.84.36.146, 51.84.72.29, 51.85.28.184 |
| sa-east-1 - 圣保罗 (自2026年4月15日起) | 18.230.164.131, 56.126.1.234, 18.230.39.24, 15.229.102.116, 18.230.174.204, 18.229.237.116 |
| us-west-2 - 俄勒冈州 (自 2025 年 6 月 24 日起) | 52.42.100.5, 44.242.47.162, 52.40.44.52, 44.227.206.163, 44.246.241.23, 35.83.230.19 |
Google Cloud 静态 NAT IP 地址
| Google Cloud 区域 | IP 地址 |
|---|---|
| asia-northeast1 - 东京 (自 2026 年 5 月 27 日起) | 104.198.114.210, 35.221.66.81, 35.243.126.127, 136.110.107.86, 34.85.18.112 |
| asia-southeast1 - 新加坡 (自 2026 年 5 月 27 日起) | 34.21.197.28, 35.197.141.23, 35.197.157.90, 136.110.17.200, 35.185.179.231 |
| europe-west2 - 伦敦 (自 2026 年 5 月 27 日起) | 35.242.131.178, 34.39.77.101, 34.39.47.179, 34.89.53.234, 8.228.63.151 |
| europe-west4 - 荷兰 (自 2026 年 5 月 27 日起) | 34.34.86.3, 34.6.175.56, 34.178.6.187, 34.91.204.220, 34.12.85.206 |
| us-central1 - 爱荷华州 (自 2026 年 5 月 27 日起) | 34.28.24.54, 34.42.56.195, 34.63.141.9, 35.238.146.37, 34.10.251.49 |
| us-east1 - 南卡罗来纳州 (自 2026 年 5 月 27 日起) | 34.24.134.232, 34.24.214.165, 34.24.20.1, 35.243.193.248, 34.23.98.76 |
调整 ClickHouse 设置
- 创建自定义角色
CREATE ROLE my_clickpipes_role SETTINGS ...。详情请参见 CREATE ROLE 语法。 - 在创建 ClickPipes 的过程中,在
Details and Settings步骤将该自定义角色添加给 ClickPipes 用户。
调整 ClickPipes 高级设置
对象存储 ClickPipes
| Setting | Default value | Description |
|---|---|---|
Max insert bytes | 10 GB | 单个插入批次中处理的字节数。 |
Max file count | 100 | 单个插入批次中处理的最大文件数。 |
Max threads | auto(3) | 用于文件处理的最大并发线程数。 |
Max insert threads | 1 | 用于文件处理的最大并发插入线程数。 |
Min insert block size bytes | 1 GB | 可插入表的块最小字节数。 |
Max download threads | 4 | 最大并发下载线程数。 |
Object storage polling interval | 30 s | 配置将数据插入 ClickHouse 集群前的最长等待时间。 |
Parallel distributed insert select | 2 | 并行 Distributed insert select 设置。 |
Parallel view processing | false | 是否启用以并发而非顺序方式推送到已附加视图。 |
Use cluster function | true | 是否在多个节点上并行处理文件。 |
流式 ClickPipes
| 设置 | 默认值 | 描述 |
|---|---|---|
Streaming max insert wait time | 5 s | 配置在将数据插入 ClickHouse 集群之前允许的最长等待时间。 |
错误报告
记录错误
<destination_table_name>_clickpipes_error 结尾。该表会包含因数据格式错误或 schema 不匹配而产生的所有错误,并保留完整的无效消息内容。该表的生存时间 (TTL)为 7 天。
系统错误
system.clickpipes_log 表中。该表还会记录与你的 ClickPipe 运行有关的其他错误 (如网络、连接等) 。此表的 生存时间 (TTL) 为 7 天。
如果 ClickPipes 在 15 分钟后仍无法连接到数据源,或在 1 小时后仍无法连接到目标端,ClickPipes 实例将停止,并在系统错误表中记录相应的消息 (前提是 ClickHouse 实例可用) 。
监控
FAQ
- 什么是 ClickPipes? ClickPipes 是 ClickHouse Cloud 的一项功能,可让您轻松将 ClickHouse 服务连接到外部数据源,尤其是 Kafka。借助 ClickPipes for Kafka,您可以持续、轻松地将数据加载到 ClickHouse 中,使其可用于实时分析。
- ClickPipes 是否支持数据转换? 是的,ClickPipes 通过提供 DDL 创建能力来支持基础数据转换。随后,您可以在数据加载到 ClickHouse Cloud 服务中的目标表时,借助 ClickHouse 的 materialized views 功能 对数据进行更高级的转换。
- 使用 ClickPipes 会产生额外费用吗? ClickPipes 按两个维度计费:Ingested Data 和 Compute。有关定价的完整详情,请参见此页面。运行 ClickPipes 还可能在目标 ClickHouse Cloud 服务上产生间接的计算和存储成本,这与任何摄取工作负载类似。
- 使用 ClickPipes for Kafka 时,有办法处理错误或故障吗? 可以。ClickPipes for Kafka 在从 Kafka 消费数据时,如果遇到任何运行问题 (包括网络问题、连接问题等) ,都会自动重试。如果出现格式错误的数据或无效的 schema,ClickPipes 会将该记录存储到 record_error 表中,并继续处理。