创建源连接和数据流,以使用用户界面流式传输LAVA数据

请按照此分步指南进行操作,以帮助您在Experience Platform用户界面中设置自己的LAVA源连接器。

IMPORTANT
此文档页面由LAVA团队创建。 如有任何查询或更新请求,请直接通过info@lava.ai联系他们。

快速入门

本教程需要对以下Experience Platform组件有一定的了解:

TIP
在开始本教程之前,请查看LAVA 源连接器概述,确保您满足所有先决条件。

连接您的LAVA帐户

在Experience Platform UI中,从左侧导航栏中选择​ ​以访问源工作区。 Catalog屏幕显示您可以用来创建帐户的各种源。

您可以从屏幕左侧的目录中选择相应的类别。 或者,您可以使用搜索选项查找您要使用的特定源。

在​ ​类别下,选择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指南

成功映射源数据后,选择​下一步

源工作流的映射步骤。

审阅

将显示​ 审核 ​步骤,允许您在创建新数据流之前对其进行审核。 详细信息分为以下类别:

  • 连接:显示源类型、所选源文件的相关路径以及该源文件中的列数。
  • 分配数据集和映射字段:显示要将源数据摄取到哪个数据集,包括数据集所遵循的架构。

查看数据流后,选择​完成,然后等待一些时间来创建数据流。

源工作流的审核步骤。

获取您的流端点URL和数据流ID

创建流数据流后,您现在可以检索流端点URL和数据流ID。 这些将用于配置LAVA,以允许您的流源与Experience Platform通信。

要检索您的流端点,请转到刚刚创建的数据流的数据流活动页面,并从属性面板的底部复制端点。

数据流活动中的流终结点。

将LAVA与您的webhook集成

LAVA控制台中,导航到​Resources > Data Export

数据导出菜单

选择​Create New Export,然后选择​ Adobe Source Connector ​作为目标类型。 接下来,选择要发送的源数据,并输入流端点URL以及数据流ID。

新建导出

recommendation-more-help
experience-platform-help-sources