온디맨드 수집은 현재 베타 버전이며 조직에서 아직 액세스하지 못할 수 있습니다. 이 설명서에 설명된 기능은 변경될 수 있습니다.
흐름 실행은 흐름 실행의 인스턴스를 나타냅니다. 예를 들어 흐름이 매시간 오전 9:00, 오전 10:00 및 오전 11:00에 실행되도록 예약되어 있는 경우 세 개의 흐름 실행 인스턴스가 생깁니다. 플로우 실행은 특정 조직에만 해당됩니다.
온디맨드 수집은 주어진 데이터 흐름에 대해 실행되는 흐름을 만들 수 있는 기능을 제공합니다. 이를 통해 사용자는 서비스 토큰 없이 주어진 매개 변수를 기반으로 흐름 실행을 만들고 수집 주기를 만들 수 있습니다. 온디맨드 수집에 대한 지원은 배치 출처에 대해서만 사용할 수 있습니다.
이 튜토리얼에서는 온디맨드 수집을 사용하고 를 사용하여 플로우 실행을 만드는 방법에 대한 단계를 설명합니다. Flow Service API.
플로우 실행을 만들려면 먼저 1회 수집으로 예약된 데이터 흐름의 플로우 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를 사용하여 플로우 실행을 모니터링하려면 의 안내서를 참조하십시오. 모니터링 대시보드를 사용하여 소스 데이터 흐름 모니터링.