Stripe Data Pipeline에서 이제 실시간 Stripe 데이터를 Lakebase Postgres로 동기화합니다

Stripe 기반으로 비즈니스를 운영하는 경우 결제 확인, 구독 액세스 업데이트, 청구 세부 정보 표시 등 고객 활동에 대응하려면 애플리케이션 실행 시 Stripe 데이터에 액세스해야 합니다. 그동안 이러한 데이터를 Stripe와 동기화된 상태로 유지하려면 API나 웹훅을 사용하는 커스텀 연동을 구축하고 유지 관리해야 했습니다.

이제 이 방식이 달라집니다. Stripe Data Pipeline이 이제 Postgres로의 실시간 동기화를 지원하며[Stripe 블로그 게시물 링크], Databricks Lakebase는 OpenSharing 기반으로 지원되는 대상 중 하나입니다(블로그 및 문서). Stripe는 실시간 API 데이터를 Lakebase로 스트리밍하고 엔드투엔드로 동기화를 관리합니다.

Databricks의 Stripe 데이터: 하나의 파이프라인, 두 개의 대상

올해 초 Stripe Data Pipeline을 통해 Stripe 데이터를 Databricks로 동기화할 수 있게 되었습니다. Postgres 실시간 동기화 기능을 활용하면 이제 하나의 Stripe 계정으로 서로 다른 작업을 위해 제작된 두 개의 Databricks 대상에 데이터를 공급할 수 있습니다.

분석 및 AI를 위한 Unity Catalog

Stripe는 Delta Sharing을 통해 결제, 고객, 구독, 환불 및 정산 데이터를 워크스페이스와 공유합니다. 따라서 Stripe 데이터는 Unity Catalog에서 거버넌스가 적용된 또 하나의 테이블이 되어 다른 비즈니스 데이터와 간편하게 조인할 수 있습니다.

팀은 이를 활용해 이탈 가능성이 높은 고객의 점수를 매기고, Genie에게 지역별 MRR을 물어보며, 월말 결제를 정산하고, 재무 팀에 결제 데이터를 탐색할 수 있는 거버넌스 앱을 제공합니다. 이러한 워크로드는 수천 명의 고객과 수주에 걸친 이력 전반의 패턴을 분석합니다.

애플리케이션을 위한 Lakebase

Stripe Data Pipeline의 Postgres 실시간 동기화를 통해 결제, 고객, 구독 및 기타 Stripe 데이터가 Lakebase로 계속 동기화되며, 수 초 이내에 업데이트가 반영됩니다.

애플리케이션은 이 데이터를 쿼리하여 로직을 실행하고 최신 Stripe 데이터를 기반으로 수행할 작업과 표시할 콘텐츠를 결정할 수 있습니다.

애플리케이션과 Stripe 데이터 동기화 유지

애플리케이션의 데이터베이스를 실시간 Stripe 데이터로 최신 상태로 유지하려면 지속적인 노력이 필요합니다. 현재 대부분의 팀은 다음 두 가지 방식 중 하나에 의존하고 있습니다.

• Stripe API 호출: 처리량이 적을 때는 잘 작동하지만, 트래픽이 늘어나고 속도 제한(rate limit)이 적용되면 운영이 어려워집니다.
• 웹훅: 모든 이벤트에 핸들러가 필요하며, 전송 실패 시 재시도 로직과 누락되거나 순서가 뒤바뀌어 도착한 이벤트를 위한 정산 프로세스가 추가로 필요합니다.

어느 방식이든 별도의 인프라를 구축하고 모니터링하며 유지 관리해야 합니다. 그리고 오류가 발생하면 고객이 잘못된 액세스 권한을 갖게 되거나 오래된 계정 정보가 표시될 수 있습니다.

 

Stripe Data Pipeline을 사용하면 이러한 인프라 작업이 사라집니다. Lakebase로 동기화할 Stripe 테이블을 선택하기만 하면 Stripe가 노코드 파이프라인을 통해 백필, 지속적인 전송, 데이터 감사를 처리하여 데이터를 완전하고 최신 상태로 유지하도록 도와줍니다.

 

Lakebase에 구현된 실시간 Stripe 데이터를 바탕으로 애플리케이션은 최신 결제 및 구독 정보에 액세스하여 다음과 같은 핵심 제품 기능 및 고객 경험을 지원할 수 있습니다.

제품 및 기능 액세스 제어

고객이 요금제를 업그레이드하면 새로운 구독 정보가 수 초 이내에 Lakebase에 반영되며, 애플리케이션은 다음 요청 시 프리미엄 기능을 즉시 해제합니다. 구독이 취소되거나 갱신에 실패하는 경우에도 별도의 이벤트 핸들러 없이 액세스 권한이 그만큼 빠르게 변경되므로, 결제한 고객이 무료 요금제에 묶여 있는 일이 없습니다.

청구 및 계정 세부 정보를 최신 상태로 유지

고객은 계정 페이지에 사용 중인 요금제, 오늘 아침에 결제된 청구서, 업데이트가 필요한 카드 등 방금 일어난 내용이 바로 반영되기를 원합니다. 구독, 청구서, 결제 데이터가 Lakebase에 동기화되므로 페이지를 로드할 때마다 Stripe API를 호출하지 않고도 고객이 계정을 관리하는 모든 위치에서 정확한 청구 정보를 보여줄 수 있습니다.

실시간 재무 가시성 제공

청구, 환불 및 정산 내역이 지속적으로 동기화되므로 일일 매출액, 정산 및 환불 현황을 실시간으로 보여주는 대시보드를 구축할 수 있습니다.

맞춤형 오퍼 실행

구독 및 결제 이력이 애플리케이션 데이터베이스에 직접 저장되어 있으므로 적절한 순간에 맥락에 맞는 오퍼를 제공할 수 있습니다. 고객이 취소한 직후의 재유치 할인, 사용량이 요금제 한도를 초과할 때의 업그레이드 안내, 결제 수단 만료 임박 시 알림 등을 활용할 수 있습니다.

시작하기

Stripe Data Pipeline의 Postgres 실시간 동기화 기능은 공개 프리뷰로 제공되며 무료로 시작할 수 있습니다. 자세한 내용은 Stripe 대시보드에서 파이프라인을 생성하고 문서를 참조하세요.

Lakebase는 애플리케이션과 AI 에이전트를 위해 구축되고 나머지 Databricks Data + AI Platform과 통합된 Databricks의 서버리스 Postgres 데이터베이스입니다. 무료로 시작해 보세요.

(이 글은 AI의 도움을 받아 번역되었습니다. 원문이 궁금하시다면 여기를 클릭해 주세요)