UIを使用してLAVA データをストリーミングするソース接続とデータフローを作成します

最終更新日： 2026年5月15日

トピック：
Sources

作成対象：

Developer

このステップバイステップガイドに従って、Experience Platform ユーザーインターフェイスで独自のLAVA ソースコネクタを設定します。

IMPORTANT

このドキュメントページはLAVA チームによって作成されました。お問い合わせやアップデートのリクエストについては、info@lava.aiから直接お問い合わせください。

はじめに

このチュートリアルは、 Experience Platform の次のコンポーネントを実際に利用および理解しているユーザーを対象としています。

Experience Data Model (XDM) システム：Experience Platform が顧客体験データの整理に使用する標準化されたフレームワーク。
- スキーマ構成の基本：スキーマ構成の主要な原則やベストプラクティスなど、XDM スキーマの基本的な構成要素について学びます。
- スキーマエディターのチュートリアル：スキーマエディター UI を使用してカスタムスキーマを作成する方法を説明します。
Real-Time Customer Profile：複数のソースからの集計データに基づいて、統合されたリアルタイムの顧客プロファイルを提供します。

TIP

このチュートリアルを開始する前に、LAVA ソースコネクタの概要を確認して、すべての前提条件を満たしていることを確認してください。

LAVA アカウントを接続

Experience Platform UIで、左側のナビゲーションバーから「ソース」を選択して、ソースワークスペースにアクセスします。カタログ画面には、アカウントを作成するための様々なソースが表示されます。

画面の左側にあるカタログから適切なカテゴリを選択することができます。または、使用する特定のソースを検索オプションを使用して探すこともできます。

「ストリーミング」カテゴリで「LAVA」を選択し、「データを追加」を選択します。

Experience Platform ソースカタログ

データの選択

「データを選択」手順が表示され、Platformに取り込むデータを選択するためのインターフェイスが提供されます。

インターフェイスの左側の部分は、アカウント内で利用可能なデータストリームを表示できるブラウザーです。
インターフェイスの右側では、JSON ファイルから最大100行のデータをプレビューできます。

「ファイルをアップロード」を選択して、ローカルシステムからJSON ファイルをアップロードするか、設定しているデータセットに対応する「概要」セクションからサンプルファイルをアップロードします。または、アップロードするJSON ファイルをファイルをドラッグ&ドロップパネルにドラッグ&ドロップすることもできます。

ソースワークフローのデータ追加手順。

ファイルをアップロードすると、プレビューインターフェイスが更新され、アップロードしたスキーマのプレビューが表示されます。プレビューインターフェイスを使用すると、ファイルの内容と構造を検査できます。検索フィールドユーティリティを使用して、スキーマ内から特定の項目にアクセスすることもできます。

完了したら、次へを選択します。

ソースワークフローのプレビューステップ。

データフローの詳細

データフローの詳細 ステップが表示され、既存のデータセットを使用するか、データフロー用に新しいデータセットを確立するオプションと、データフローの名前と説明を入力する機会が提供されます。この手順では、プロファイルの取り込み、エラー診断、部分取り込み、アラートの設定も行うことができます。

完了したら、次へを選択します。

ソースワークフローのデータフロー詳細ステップ。

マッピング

マッピング手順が表示され、ソーススキーマのフィールドをターゲットスキーマの適切なターゲット XDM フィールドにマッピングするためのインターフェイスが表示されます。

LAVAの指定されたスキーマを使用する場合は、次の推奨マッピングを使用します。

メンバープロファイル

table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 layout-auto
LAVA Source コネクタフィールド	LAVA プロファイルスキーマフィールド
`lavaId`	`_tenant.lavaId`
`firstName`	`person.name.firstName`
`lastName`	`person.name.lastName`
`email`	`personalEmail.address`
`phone`	`mobilePhone.number`

メンバー残高

table 0-row-2 1-row-2 2-row-2 layout-auto
LAVA Source コネクタフィールド	LAVA プロファイルスキーマフィールド
`lavaId`	`_tenant.lavaId`
`balances[]`	`_tenant.balances[]`

組み合わせイベント

table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2 7-row-2 8-row-2 9-row-2 10-row-2 11-row-2 12-row-2 13-row-2 14-row-2 15-row-2 16-row-2 17-row-2 18-row-2 19-row-2 20-row-2 21-row-2 22-row-2 23-row-2 24-row-2 25-row-2 26-row-2 27-row-2 28-row-2 layout-auto
LAVA Source コネクタフィールド	LAVA イベントスキーマフィールド
計算フィールド `to_map("LavaId",to_array(false,to_object("id",lavaId,"primary",true)))`	`identityMap`
`type`	`eventType`
`timestamp`	`timestamp`
`eventId`	`_tenant.ticketScan.eventId`
`eventName`	`_tenant.ticketScan.eventName`
`eventLabel`	`_tenant.ticketScan.eventLabel`
`venue`	`_tenant.ticketScan.venue`
`venueLabel`	`_tenant.ticketScan.venueLabel`
`section`	`_tenant.ticketScan.section`
`sectionLabel`	`_tenant.ticketScan.sectionLabel`
`row`	`_tenant.ticketScan.row`
`seat`	`_tenant.ticketScan.seat`
`gate`	`_tenant.ticketScan.gate`
`gateLabel`	`_tenant.ticketScan.gateLabel`
`transactionId`	`_tenant.transaction.transactionId`
`referenceId`	`_tenant.transaction.referenceId`
`subtotal`	`_tenant.transaction.subtotal`
`total`	`_tenant.transaction.total`
`location`	`_tenant.transaction.location`
`items[]`	`_tenant.transaction.items[]`
`redeemedAmount`	`_tenant.transaction.redeemedAmount`
`rewardsApplied[]`	`_tenant.transaction.rewardsApplied[]`
`amount`	`_tenant.ledger.amount`
`expiresAt`	`_tenant.ledger.expiresAt`
`rewardId`	`_tenant.ledger.rewardId`
`rewardName`	`_tenant.ledger.rewardName`
`rewardSlug`	`_tenant.ledger.rewardSlug`
`rewardType`	`_tenant.ledger.rewardType`

チケットスキャンイベント

table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2 7-row-2 8-row-2 9-row-2 10-row-2 11-row-2 12-row-2 13-row-2 14-row-2 layout-auto
LAVA Source コネクタフィールド	LAVA イベントスキーマフィールド
計算フィールド `to_map("LavaId",to_array(false,to_object("id",lavaId,"primary",true)))`	`identityMap`
`eventId`	`_tenant.ticketScan.eventId`
`eventName`	`_tenant.ticketScan.eventName`
`eventLabel`	`_tenant.ticketScan.eventLabel`
`venue`	`_tenant.ticketScan.venue`
`venueLabel`	`_tenant.ticketScan.venueLabel`
`section`	`_tenant.ticketScan.section`
`sectionLabel`	`_tenant.ticketScan.sectionLabel`
`row`	`_tenant.ticketScan.row`
`seat`	`_tenant.ticketScan.seat`
`gate`	`_tenant.ticketScan.gate`
`gateLabel`	`_tenant.ticketScan.gateLabel`
`type`	`eventType`
`timestamp`	`timestamp`

トランザクションイベント

table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2 7-row-2 8-row-2 9-row-2 10-row-2 11-row-2 layout-auto
LAVA Source コネクタフィールド	LAVA イベントスキーマフィールド
計算フィールド `to_map("LavaId",to_array(false,to_object("id",lavaId,"primary",true)))`	`identityMap`
`transactionId`	`_tenant.transaction.transactionId`
`referenceId`	`_tenant.transaction.referenceId`
`subtotal`	`_tenant.transaction.subtotal`
`total`	`_tenant.transaction.total`
`location`	`_tenant.transaction.location`
`items[]`	`_tenant.transaction.items[]`
`redeemedAmount`	`_tenant.transaction.redeemedAmount`
`rewardsApplied[]`	`_tenant.transaction.rewardsApplied[]`
`type`	`eventType`
`timestamp`	`timestamp`

元帳イベント

table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2 7-row-2 8-row-2 9-row-2 layout-auto
LAVA Source コネクタフィールド	LAVA イベントスキーマフィールド
計算フィールド `to_map("LavaId",to_array(false,to_object("id",lavaId,"primary",true)))`	`identityMap`
`amount`	`_tenant.ledger.amount`
`expiresAt`	`_tenant.ledger.expiresAt`
`rewardId`	`_tenant.ledger.rewardId`
`rewardName`	`_tenant.ledger.rewardName`
`rewardSlug`	`_tenant.ledger.rewardSlug`
`rewardType`	`_tenant.ledger.rewardType`
`type`	`eventType`
`timestamp`	`timestamp`

あるいは、ユースケースに合わせてマッピングルールを手動で調整することもできます。必要に応じて、フィールドを直接マッピングするか、データ準備機能を使用してソースデータを変換して計算値を導き出すかを選択できます。マッパーインターフェイスと計算フィールドの使用に関する包括的な手順については、データ準備UI ガイドを参照してください。

ソースデータが正常にマッピングされたら、次へを選択します。

ソースワークフローのマッピングステップ。