Neon Postgres 数据源设置指南

将 Neon Postgres 实例配置为 ClickPipes 的数据源

这是一篇介绍如何设置 Neon Postgres 的指南，您可以将其用于 ClickPipes 中的复制。 请确保您已登录 Neon console 以进行此设置。

​

创建具有相应权限的用户

以管理员用户身份连接到您的 Neon 实例，并执行以下命令：

1. 为 ClickPipes 创建一个专用用户：

   CREATE USER clickpipes_user PASSWORD 'some-password';
   

2. 为上一步创建的用户授予 schema 级别的只读权限。以下示例展示了 public schema 的权限。对于每个包含要复制表的 schema，都需要重复执行这些命令：

   GRANT USAGE ON SCHEMA "public" TO clickpipes_user;
   GRANT SELECT ON ALL TABLES IN SCHEMA "public" TO clickpipes_user;
   ALTER DEFAULT PRIVILEGES IN SCHEMA "public" GRANT SELECT ON TABLES TO clickpipes_user;
   

3. 为该用户授予复制权限：

   ALTER USER clickpipes_user WITH REPLICATION;
   

4. 使用您要复制的表创建一个 publication。我们强烈建议只将所需的表包含在 publication 中，以避免额外的性能开销。

publication 中包含的任何表都必须已定义主键，_或者_将其副本标识配置为 FULL。有关如何界定范围的指导，请参阅 Postgres FAQs。

• 为特定表创建 publication：

  CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;
  

  • 为特定 schema 中的所有表创建 publication：

    CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";
    

clickpipes publication 定义了将流式传输到 ClickPipes 的那组表的变更事件。除非您打算复制每一张表，否则我们不建议使用 FOR ALL TABLES，因为包含不必要的表会增加从 Postgres 到 ClickPipes 的 WAL 流量，并降低整体复制效率。

​

启用逻辑复制

在 Neon 中，您可以通过 UI 启用逻辑复制。这是 ClickPipes 的 CDC (变更数据捕获) 复制数据所必需的。 前往 Settings 选项卡，然后进入 Logical Replication 部分。

点击 Enable 即可完成此项设置。启用后，您应该会看到如下成功消息。

接下来，请验证您的 Neon Postgres 实例中的以下设置：

SHOW wal_level; -- should be logical
SHOW max_wal_senders; -- should be 10
SHOW max_replication_slots; -- should be 10

​

IP 白名单 (适用于 Neon Enterprise 套餐)

如果您使用的是 Neon Enterprise 套餐，可以将 ClickPipes IP 地址 加入白名单，以允许 ClickPipes 将数据复制到您的 Neon Postgres 实例。 为此，请点击 Settings 选项卡，然后进入 IP Allow 部分。

​

复制连接详情

现在用户和 publication 已准备就绪，且已启用复制，我们可以复制连接详情来创建新的 ClickPipe。 前往 Dashboard，在显示连接字符串的文本框中， 将视图切换为 仅参数。下一步会用到这些参数。

​

下一步是什么？

你现在可以创建你的 ClickPipe，并开始将 Postgres 实例中的数据摄取到 ClickHouse Cloud。 请务必记下你在设置 Postgres 实例时使用的连接详情，因为在创建 ClickPipe 的过程中会用到这些信息。