创建源连接和数据流,以使用用户界面流式传输LAVA数据
请按照此分步指南进行操作,以帮助您在Experience Platform用户界面中设置自己的LAVA源连接器。
快速入门
本教程需要对以下Experience Platform组件有一定的了解:
-
Experience Data Model (XDM) 系统: Experience Platform用于组织客户体验数据的标准化框架。
-
Real-Time Customer Profile:根据来自多个源的汇总数据,提供统一的实时使用者个人资料。
连接您的LAVA帐户
在Experience Platform UI中,从左侧导航栏中选择 源 以访问源工作区。 Catalog屏幕显示您可以用来创建帐户的各种源。
您可以从屏幕左侧的目录中选择相应的类别。 或者,您可以使用搜索选项查找您要使用的特定源。
在 流 类别下,选择LAVA,然后选择添加数据。
选择数据
此时将显示 选择数据 步骤,该步骤为您提供了一个用于选择将数据带到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指南。
成功映射源数据后,选择下一步。
审阅
将显示 审核 步骤,允许您在创建新数据流之前对其进行审核。 详细信息分为以下类别:
- 连接:显示源类型、所选源文件的相关路径以及该源文件中的列数。
- 分配数据集和映射字段:显示要将源数据摄取到哪个数据集,包括数据集所遵循的架构。
查看数据流后,选择完成,然后等待一些时间来创建数据流。
获取您的流端点URL和数据流ID
创建流数据流后,您现在可以检索流端点URL和数据流ID。 这些将用于配置LAVA,以允许您的流源与Experience Platform通信。
要检索您的流端点,请转到刚刚创建的数据流的数据流活动页面,并从属性面板的底部复制端点。
将LAVA与您的webhook集成
在LAVA控制台中,导航到Resources > Data Export。
选择Create New Export,然后选择 Adobe Source Connector 作为目标类型。 接下来,选择要发送的源数据,并输入流端点URL以及数据流ID。