跳转到主要内容

简介

ClickPipes 是一个托管式集成平台,让从多种数据源摄取数据变得像点几下按钮一样简单。ClickPipes 专为要求最严苛的工作负载而设计,其强大且可扩展的架构可确保始终如一的性能与可靠性。ClickPipes 既可用于长期流式摄取需求,也可用于一次性数据加载任务。 ClickPipes 既可以通过 ClickPipes UI 手动部署和管理,也可以通过 OpenAPITerraform 以编程方式进行部署和管理。

支持的数据源

名称徽标类型状态描述
Apache KafkaApache Kafka 徽标流式稳定版本配置 ClickPipes,开始将 Apache Kafka 中的流式数据摄取到 ClickHouse Cloud。
Confluent CloudConfluent Cloud 徽标流式稳定版本通过我们的直接集成,充分发挥 Confluent 与 ClickHouse Cloud 的组合优势。
RedpandaRedpanda 徽标流式稳定版本配置 ClickPipes,开始将 Redpanda 中的流式数据摄取到 ClickHouse Cloud。
AWS MSKAWS MSK 徽标流式稳定版本配置 ClickPipes,开始将 AWS MSK 中的流式数据摄取到 ClickHouse Cloud。
Azure Event HubsAzure Event Hubs 徽标流式稳定版本配置 ClickPipes,开始将 Azure Event Hubs 中的流式数据摄取到 ClickHouse Cloud。有关说明,请参阅 Azure Event Hubs FAQ
WarpStreamWarpStream 徽标流式稳定版本配置 ClickPipes,开始将 WarpStream 中的流式数据摄取到 ClickHouse Cloud。
Amazon S3Amazon S3 徽标对象存储稳定版本配置 ClickPipes 以从对象存储摄取海量数据。
Google Cloud StorageGoogle Cloud Storage 徽标对象存储稳定版本配置 ClickPipes 以从对象存储摄取海量数据。
DigitalOcean SpacesDigital Ocean 徽标对象存储稳定版本配置 ClickPipes 以从对象存储摄取海量数据。
Azure Blob 存储Azure Blob Storage 徽标对象存储稳定版本配置 ClickPipes 以从对象存储摄取海量数据。
Amazon KinesisAmazon Kenesis 徽标流式稳定版本配置 ClickPipes,开始将 Amazon Kinesis 中的流式数据摄取到 ClickHouse Cloud。
PostgresPostgres 徽标DBMS稳定版本配置 ClickPipes,开始将 Postgres 中的数据摄取到 ClickHouse Cloud。
MySQLMySQL 徽标DBMSPublic Beta配置 ClickPipes,开始将 MySQL 中的数据摄取到 ClickHouse Cloud。
MongoDBMongoDB 徽标DBMS私有预览配置 ClickPipes,开始将 MongoDB 中的数据摄取到 ClickHouse Cloud。
更多连接器将陆续加入 ClickPipes,更多信息请联系我们

静态 IP 列表

下表列出了 ClickPipes 用于连接您的外部服务的静态 NAT IP 地址。请将为您的 ClickHouse Cloud 服务提供支持的 ClickPipes 区域对应的 IP 地址添加到 IP allow list 中。对于对象存储管道,您还应将 ClickHouse 集群 IP 添加到 IP allow list 中。 下方 Google Cloud 表中列出的 Google Cloud 区域内的服务,只有在 2026 年 5 月 27 日或之后创建时,才会使用这些 Google Cloud IP。对于 2026 年 5 月 27 日之前在这些区域中创建的服务,则会继续使用下方列出的默认区域 IP。 对于其他服务,ClickPipes 流量会根据服务所在位置从默认区域发出:
  • eu-central-1:适用于所有未明确列出的 EU 区域,以及 Azure EU 区域和在 2026 年 5 月 27 日之前创建的 Google Cloud EU 服务。
  • eu-west-1:适用于 AWS eu-west-1 中所有在 2026 年 1 月 20 日或之后创建的服务 (在此日期之前创建的服务使用 eu-central-1 IP) 。
  • us-east-1:适用于 AWS us-east-1 中的所有服务。
  • ap-south-1:适用于 AWS ap-south-1 中所有在 2025 年 6 月 25 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ap-northeast-2:适用于 AWS ap-northeast-2 中所有在 2025 年 11 月 14 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • af-south-1:适用于 AWS af-south-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ap-east-1:适用于 AWS ap-east-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ap-northeast-1:适用于 AWS ap-northeast-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ap-southeast-1:适用于 AWS ap-southeast-1 中所有在 2026 年 3 月 18 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ap-southeast-2:适用于 AWS ap-southeast-2 中所有在 2025 年 6 月 25 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ap-southeast-3:适用于 AWS ap-southeast-3 中所有在 2026 年 3 月 6 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • ca-central-1:适用于 AWS ca-central-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • eu-north-1:适用于 AWS eu-north-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 eu-central-1 IP) 。
  • eu-west-2:适用于 AWS eu-west-2 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 eu-central-1 IP) 。
  • il-central-1:适用于 AWS il-central-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • sa-east-1:适用于 AWS sa-east-1 中所有在 2026 年 4 月 15 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • us-west-2:适用于 AWS us-west-2 中所有在 2025 年 6 月 24 日或之后创建的服务 (在此日期之前创建的服务使用 us-east-2 IP) 。
  • 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 设置

ClickHouse Cloud 为大多数使用场景提供了合理的默认设置。不过,如果你需要为 ClickPipes 目标表调整某些 ClickHouse 设置,那么为 ClickPipes 配置一个专用角色是最灵活的解决方案。 步骤:
  1. 创建自定义角色 CREATE ROLE my_clickpipes_role SETTINGS ...。详情请参见 CREATE ROLE 语法。
  2. 在创建 ClickPipes 的过程中,在 Details and Settings 步骤将该自定义角色添加给 ClickPipes 用户。

调整 ClickPipes 高级设置

ClickPipes 提供了适用于大多数场景的合理默认设置。如果你的场景需要进一步微调,可以调整以下设置:

对象存储 ClickPipes

SettingDefault valueDescription
Max insert bytes10 GB单个插入批次中处理的字节数。
Max file count100单个插入批次中处理的最大文件数。
Max threadsauto(3)用于文件处理的最大并发线程数
Max insert threads1用于文件处理的最大并发插入线程数
Min insert block size bytes1 GB可插入表的块最小字节数
Max download threads4最大并发下载线程数
Object storage polling interval30 s配置将数据插入 ClickHouse 集群前的最长等待时间。
Parallel distributed insert select2并行 Distributed insert select 设置
Parallel view processingfalse是否启用以并发而非顺序方式推送到已附加视图。
Use cluster functiontrue是否在多个节点上并行处理文件。

流式 ClickPipes

设置默认值描述
Streaming max insert wait time5 s配置在将数据插入 ClickHouse 集群之前允许的最长等待时间。

错误报告

ClickPipes 会根据摄取过程中遇到的错误类型,将错误分别存储在两个独立的表中。

记录错误

ClickPipes 会在目标表旁创建一张表,表名以后缀 <destination_table_name>_clickpipes_error 结尾。该表会包含因数据格式错误或 schema 不匹配而产生的所有错误,并保留完整的无效消息内容。该表的生存时间 (TTL)为 7 天。

系统错误

与 ClickPipe 运行相关的错误会存储在 system.clickpipes_log 表中。该表还会记录与你的 ClickPipe 运行有关的其他错误 (如网络、连接等) 。此表的 生存时间 (TTL) 为 7 天。 如果 ClickPipes 在 15 分钟后仍无法连接到数据源,或在 1 小时后仍无法连接到目标端,ClickPipes 实例将停止,并在系统错误表中记录相应的消息 (前提是 ClickHouse 实例可用) 。

监控

除了控制台内的监控外,ClickPipes 还会将指标暴露到一个兼容 Prometheus 的端点,以便抓取。这些指标会与其他 ClickHouse Cloud 服务指标一同发布,因此你可以将 ClickPipes 的监控集成到现有的可观测性技术栈中 (例如 GrafanaDatadog) 。有关可用指标的完整列表,请参阅 Monitoring ClickPipes

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 表中,并继续处理。
最后修改于 2026年6月10日