按需摄取当前为测试版,您的组织可能还不能访问它。 本文档中描述的功能可能会发生更改。
流运行表示流执行的实例。 例如,如果某个流计划在上午9:00、上午10:00和上午11:00每小时运行一次,则您将运行该流的三个实例。 流运行特定于您的特定组织。
按需引入允许您针对给定数据流创建流运行。 这允许您的用户基于给定的参数创建流运行并创建引入周期,而无需服务令牌。 仅对批来源提供按需摄取支持。
本教程介绍了如何使用按需引入和创建流运行的步骤 Flow Service API.
要创建流运行,您必须首先具有计划一次性摄取的数据流的流ID。
本教程要求您实际了解Adobe Experience Platform的以下组件:
有关如何成功调用Platform API的信息,请参阅 Platform API快速入门.
要为基于表的来源创建流,请向以下地址发出POST请求: Flow Service API,同时提供要创建运行的流的ID,以及开始时间、结束时间和增量列的值。
基于表的源包括以下源类别:广告、分析、同意和偏好设置、CRM、客户成功、数据库、营销自动化、支付和协议。
API格式
POST /runs/
请求
以下请求创建流ID的流运行 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
.
您只需提供 deltaColumn
创建第一个流运行时。 之后, deltaColumn
将作为的一部分进行修补 copy
和的转变将被视为真理的来源。 任何更改 deltaColumn
流运行参数中的值将导致错误。
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/runs' \
-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 '{
"flowId": "3abea21c-7e36-4be1-bec1-d3bad0e3e0de",
"params": {
"startTime": "1663735590",
"windowStartTime": "1651584991",
"windowEndTime": "16515859567",
"deltaColumn": {
"name": "DOB"
}
}
}'
参数 | 描述 |
---|---|
flowId |
将创建流运行的流的ID。 |
params.startTime |
一个整数,定义运行的开始时间。 该值以unix epoch时间表示。 |
params.windowStartTime |
一个整数,定义要在其中提取数据的窗口的开始时间。 该值以unix时间表示。 |
params.windowEndTime |
一个整数,定义要在其中提取数据的窗口的结束时间。 该值以unix时间表示。 |
params.deltaColumn |
需要增量列对数据分区并将新摄取的数据与历史数据分离。 注释:此 deltaColumn 仅在创建首次流运行时需要。 |
params.deltaColumn.name |
增量列的名称。 |
响应
成功的响应将返回新创建的流运行的详细信息,包括其唯一运行 id
.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
属性 | 描述 |
---|---|
id |
新创建的流运行的ID。 请参阅指南,网址为 正在检索流规范 有关基于表的运行规范的详细信息。 |
etag |
流运行的资源版本。 |
POST要为基于文件的源创建流,请向 Flow Service API,同时提供要创建运行的流的ID,以及开始时间和结束时间的值。
基于文件的源包括所有云存储源。
API格式
POST /runs/
请求
以下请求创建流ID的流运行 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
.
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/runs' \
-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 '{
"flowId": "3abea21c-7e36-4be1-bec1-d3bad0e3e0de",
"params": {
"startTime": "1663735590",
"windowStartTime": "1651584991",
"windowEndTime": "16515859567"
}
}'
参数 | 描述 |
---|---|
flowId |
将创建流运行的流的ID。 |
params.startTime |
一个整数,定义运行的开始时间。 该值以unix epoch时间表示。 |
params.windowStartTime |
一个整数,定义要在其中提取数据的窗口的开始时间。 该值以unix时间表示。 |
params.windowEndTime |
一个整数,定义要在其中提取数据的窗口的结束时间。 该值以unix时间表示。 |
响应
成功的响应将返回新创建的流运行的详细信息,包括其唯一运行 id
.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
属性 | 描述 |
---|---|
id |
新创建的流运行的ID。 请参阅指南,网址为 正在检索流规范 有关基于表的运行规范的详细信息。 |
etag |
流运行的资源版本。 |
创建流运行后,您可以监视通过它摄取的数据,以查看有关流运行、完成状态和错误的信息。 要使用API监控流量运行,请参阅关于的教程 监测API中的数据流 . 要使用Platform UI监控流量运行,请参阅上的指南 使用监视仪表板监视源数据流.