Stripe 数据几秒进 Postgres，Webhook 不会因此消失

Databricks 的 Stripe Data Pipeline 现在支持实时同步到 Lakebase Postgres。Stripe 的客户、订阅、发票、扣款等数据会在几秒内进入这个 Postgres 数据库，应用不用再等批处理，也不用每次页面加载都去调 Stripe API。

对用过 Stripe 的团队，这个场景不陌生。Stripe 管支付，Databricks 管数据分析和 AI，Lakebase 是 Databricks 的 serverless Postgres 数据库，面向应用和 AI agent。现在同一条 Stripe 管道可以往两个地方送数据：Unity Catalog 做分析，Lakebase 给应用查实时状态。Databricks 博客文章由 Carlota Soto 发布，文章里说 Stripe 负责端到端管理同步，底层走 OpenSharing。

一个管道，两个目的地

分析侧通过 Delta Sharing 把 payments、customers、subscriptions、refunds、payouts 等数据放进 Unity Catalog，当成普通表用。应用侧把 payment、customer、subscription 等数据持续同步到 Lakebase，更新在几秒内到达。两个目的地服务的是不同工作负载：一个看几千个客户和数周历史里的模式，一个在请求发生时决定给用户看什么、开什么权限。

Webhook 的成本不在收事件

传统做法通常两种。调用 Stripe API，量小还行，流量上来后限流和运维会变麻烦。用 Webhook，每个事件都要写 handler，还要处理失败重试，漏掉或乱序的事件得单独对账。真正费劲的地方在收事件之后：保证数据库里那张表可信。同步失败时，用户可能拿到错误权限，或者看到过期账单。

Stripe Data Pipeline 把这层接过去。选要同步的 Stripe 表，Stripe 处理历史回填、持续交付和数据审计，不需要写代码。应用在 Lakebase 里用 SQL 查最新数据。Databricks 博客列了几个典型用法：订阅升级后几秒内解锁功能；取消或续费失败后及时收回权限；账户页显示刚付的发票和需要更新的卡；用 charges、refunds、payouts 做实时财务面板；在用户取消后推挽留优惠，或者用量超计划时提示升级。

怎么开始

这个实时同步到 Postgres 的能力现在公开预览，免费开始。在 Stripe Dashboard 创建 pipeline，具体步骤看 Stripe 文档。Lakebase 的入口在 Databricks 文档，原文在 Databricks 博客。

公开预览也意味着对账和审计要求高的业务仍要自己确认数据完整性和权限边界。Webhook 不会因此消失，复杂业务事件、内部系统联动、Stripe 之外的数据流，还是要自己接。这个更新省掉的是重复维护同步管道的那部分工作，复杂集成逻辑仍要自己写。