使用Flow Service API为电子商务源创建数据流
本教程介绍了从电子商务源检索数据以及使用Flow Service API将这些数据引入Experience Platform的步骤。
注意- 要创建数据流，您必须已具有包含电子商务源的有效基本连接ID。 如果您没有此ID，请查看源概述，以了解可创建基础连接的电子商务源的列表。
- 要让Experience Platform摄取数据，必须将所有基于表的批处理源的时区配置为UTC时区。
快速入门
本教程要求您实际了解Adobe Experience Platform的以下组件：
-
Experience Data Model (XDM) System： Experience Platform用于组织客户体验数据的标准化框架。
-
Catalog Service：目录是Experience Platform内数据位置和历程的记录系统。
-
Batch ingestion：批量摄取API允许您将数据作为批处理文件摄取到Experience Platform。
-
Sandboxes： Experience Platform提供了将单个Experience Platform实例划分为多个单独的虚拟环境的虚拟沙箱，以帮助开发和改进数字体验应用程序。
使用Experience Platform API
有关如何成功调用Experience Platform API的信息，请参阅Experience Platform API快速入门指南。
创建源连接
您可以通过向Flow Service API发出POST请求来创建源连接。 源连接由连接ID、源数据文件的路径以及连接规范ID组成。
要创建源连接，还必须为数据格式属性定义一个枚举值。
为基于文件的连接器使用以下枚举值：
| 数据格式 | 枚举值 |
|---|---|
| 已分隔 | delimited |
| JSON | json |
| Parquet | parquet |
对于所有基于表的连接器，将该值设置为tabular。
API格式
POST /sourceConnections
请求
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
-H 'Authorization: Bearer {ACCESS_TOKEN}' \
-H 'x-api-key: {API_KEY}' \
-H 'x-gw-ims-org-id: {ORG_ID}' \
-H 'x-sandbox-name: {SANDBOX_NAME}' \
-H 'Content-Type: application/json' \
-d '{
"name": "Shopify source connection",
"baseConnectionId": "582f4f8d-71e9-4a5c-a164-9d2056318d6c",
"description": "Shopify source connection",
"data": {
"format": "tabular"
},
"params": {
"tableName": "Shopify.Orders",
"columns": [
{
"name": "Email",
"type": "string"
},
{
"name": "Phone",
"type": "string"
},
]
},
"connectionSpec": {
"id": "4f63aa36-bd48-4e33-bb83-49fbcd11c708",
"version": "1.0"
}
}'
| 属性 | 描述 |
|---|---|
baseConnectionId | 电子商务源的连接ID。 |
params.path | 源文件的路径。 |
connectionSpec.id | 电子商务来源的连接规范ID。 |
响应
成功的响应返回新创建的源连接的唯一标识符(id)。 在后续步骤中，创建目标连接时需要此ID。
{
"id": "c278ab14-acdf-440b-b67f-1265d15a7655",
"etag": "\"10007c3f-0000-0200-0000-5fa9be720000\""
}