レイクハウス分析にデータを提供する同じStripeパイプラインで、アプリケーションも強化できるようになりました
によって Carlota Soto による投稿
ビジネスでStripeを利用している場合、支払いの確認、サブスクリプションアクセスの更新、請求詳細の表示など、顧客のアクティビティに対応するためにアプリケーションが実行時にStripeデータにアクセスする必要があります。これまでは、そのデータをStripeと同期させるために、APIやWebフックを使用したカスタム統合を構築・維持する必要がありました。
その状況が変わりつつあります。Stripe Data PipelineがPostgresへのリアルタイム同期に対応し[link Stripe's blog post]、OpenSharingを活用した接続先としてDatabricks Lakebaseがサポート対象となりました（ブログおよびドキュメントを参照）。StripeはリアルタイムのAPIデータをLakebaseに ストリーミング配信し、同期をエンドツーエンドで管理します。
今年前半、Stripe Data Pipelineを通じてStripeデータをDatabricksに同期可能になりました。Postgresへのリアルタイム同期により、1つのStripeアカウントから2つのDatabricks送信先（それぞれ異なる作業タイプ向けに設計）へデータを提供できるようになりました。
StripeはDelta Sharingを介して、支払い、顧客、サブスクリプション、返金、売上入金データをワークスペースと共有します。これにより、Stripeデータはガバナンスが機能した状態でUnity Catalog内の標準的なテーブルとして利用可能になり、他のビジネスデータと結合できるようになります。
チームはこれを利用して、解約可能性のある顧客のスコアリング、Genieに対する地域別MRRの問い合せ、月末の支払い照合、財務チームが支払いデータを探索するためのガバナンス対応アプリの提供などを行っています。これらのワークロードは、何千もの顧客と何週間にもわたる履歴のパターンを調査します。
Stripe Data PipelineのPostgresへのリアルタイム同期機能により、支払い、顧客、サブスクリプション、その他 のStripeデータがLakebaseへ継続的に同期され、数秒以内に更新が反映されます。
アプリケーションはこのデータをクエリしてロジックを実行し、最新のStripeデータに基づいて実行すべきアクションや表示すべきコンテンツを決定できます。
アプリケーションのデータベースをリアルタイムのStripeデータで最新に維持するには、継続的な労力が必要です。現在、多くのチームは次の2つのアプローチのいずれかに依存しています。
どちらの方法であっても、構築・監視・保守のための個別インフラが必要になります。またトラブルが発生すると、顧客に不適切なアクセス権限が付与されたり、古いアカウント詳細が表示されたりします。
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翻訳ツールを使用して翻訳されています) 原文記事
ブログを購読して、最新の投稿を受信トレイにお届けします。