Stripe Data Pipeline 实时同步至 Lakebase Postgres

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

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

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

今年早些时候，通过 Stripe Data Pipeline，Stripe 数据已可同步到 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 仪表板中创建一个管道，并阅读文档以了解更多。

Lakebase 是 Databricks 的无服务器 Postgres 数据库，专为应用程序和 AI 代理而构建，并与 Databricks Data + AI 平台的其余部分集成。 免费开始使用。