Stripe Data Pipeline 新增实时同步至 Lakebase Postgres

如果你的业务运行在 Stripe 上，你的应用程序需要在运行时访问 Stripe 数据，以响应客户活动，无论是确认付款、更新订阅访问权限，还是显示账单详情。传统上，要让这些数据与 Stripe 保持同步，意味着需要构建并维护与 API 或 webhook 的自定义集成。

这种情况正在改变。Stripe Data Pipeline 现在支持实时同步到 Postgres [链接 Stripe 的博客文章]，而 Databricks Lakebase 是受支持的目标之一（博客和文档），由 OpenSharing 提供支持。Stripe 将实时 API 数据流式传输到 Lakebase，并端到端地管理同步。

Databricks 中的 Stripe 数据：一条管道，两个目标

今年早些时候，Stripe 数据可通过 Stripe Data Pipeline 同步到 Databricks。借助实时同步到 Postgres，一个 Stripe 账户现在可以同时向两个 Databricks 目标提供数据，每个目标都为不同类型的工作而构建。

Unity Catalog，用于分析和 AI

Stripe 通过 Delta Sharing 将你的付款、客户、订阅、退款和提现数据共享到你的工作区，因此你的 Stripe 数据就变成了 Unity Catalog 中的另一张表，受到治理，并可与你的其他业务数据一起使用。

团队用它来评分哪些客户可能流失，向 Genie 询问按地理划分的 MRR，在月末核对付款，并为财务团队提供受治理的应用来探索付款数据。这些工作负载会查看数千名客户和数周历史记录中的模式。

Lakebase，用于应用程序

借助 Stripe Data Pipeline 的实时同步到 Postgres，你的付款、客户、订阅和其他 Stripe 数据会持续同步到 Lakebase，更新会在几秒内到达。

你的应用程序可以查询这些数据来驱动其逻辑，根据最新的 Stripe 数据视图确定要采取哪些操作以及要呈现哪些内容。

让 Stripe 数据与你的应用程序保持同步

让应用程序的数据库与实时 Stripe 数据保持同步需要持续投入。如今，大多数团队依赖以下两种方法之一：

调用 Stripe API：这在较低流量下可行，但随着流量增长和速率限制的出现，运营会变得更加困难。
Webhook：每个事件都需要一个处理程序，还需要针对失败投递的重试逻辑，以及针对遗漏或乱序到达事件的对账流程。

无论哪种方式，都需要构建、监控和维护一套单独的基础设施。而当它失败时，客户最终会获得错误的访问权限或过时的账户详情。

使用 Stripe Data Pipeline，这些基础设施工作就消失了。选择要同步到 Lakebase 的 Stripe 表，Stripe 会通过其无代码管道处理回填、持续投递和数据审计，帮助你的数据保持完整和最新。

借助 Lakebase 中的实时 Stripe 数据，你的应用程序可以访问最新的付款和订阅信息，以支持核心产品功能和客户体验，包括：

控制产品和功能访问权限

当客户升级其套餐时，他们的新订阅详情会在几秒内反映到 Lakebase 中，你的应用程序会在他们的下一次请求时解锁高级功能。当订阅被取消或续订失败时，访问权限也会同样迅速地改变，中间没有事件处理程序，也不会出现付费客户被困在免费套餐上的窗口期。

保持账单和账户信息及时更新

客户期望他们的账户页面能反映刚刚发生的事情：他们当前使用的套餐、今天早上已支付的发票、需要更新的银行卡。通过将订阅、发票和支付数据同步到 Lakebase，你的应用可以在客户管理账户的任何地方显示准确的账单信息，而无需在每次页面加载时调用 Stripe API。

提供实时财务可见性

随着扣款、退款和打款持续同步，你可以构建仪表板，实时展示每日销售额、打款和退款情况。

触发个性化优惠

将订阅和支付历史直接放在你的应用数据库中，你就能在合适的时机提供情境化优惠：客户取消后不久发送挽回折扣，当用量超出其套餐时提示升级，或在支付方式即将过期时发送提醒。

开始使用

面向 Stripe Data Pipeline 的 Postgres 实时同步现已进入公开预览，且可免费开始使用。在 Stripe Dashboard 中创建管道，并阅读文档以了解更多。

Lakebase 是 Databricks 的无服务器 Postgres 数据库，专为应用和 AI 智能体打造，并与 Databricks Data + AI Platform 的其他部分集成。免费开始使用。