Flow Service API를 사용하여 온디맨드 수집에 대한 흐름 실행을 만듭니다.
흐름 실행은 흐름 실행의 인스턴스를 나타냅니다. 예를 들어 흐름이 매시간 오전 9:00, 오전 10:00 및 오전 11:00에 실행되도록 예약되어 있는 경우 세 개의 흐름 실행 인스턴스가 생깁니다. 플로우 실행은 특정 조직에만 해당됩니다.
온디맨드 수집은 주어진 데이터 흐름에 대해 실행되는 흐름을 만들 수 있는 기능을 제공합니다. 이를 통해 사용자는 서비스 토큰 없이 주어진 매개 변수를 기반으로 흐름 실행을 만들고 수집 주기를 만들 수 있습니다. 온디맨드 수집에 대한 지원은 배치 출처에 대해서만 사용할 수 있습니다.
이 자습서에서는 온디맨드 수집을 사용하고 Flow Service API를 사용하여 흐름 실행을 만드는 방법에 대한 단계를 다룹니다.
시작하기
이 자습서를 사용하려면 Adobe Experience Platform의 다음 구성 요소를 잘 알고 있어야 합니다.
Platform API 사용
Platform API를 성공적으로 호출하는 방법에 대한 자세한 내용은 Platform API 시작에 대한 안내서를 참조하십시오.
테이블 기반 소스에 대한 흐름 실행 만들기
테이블 기반 소스에 대한 흐름을 만들려면 실행을 만들 흐름의 ID와 시작 시간, 종료 시간 및 델타 열에 대한 값을 제공하면서 Flow Service API에 POST 요청을 합니다.
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
params.startTime
params.windowStartTime
params.windowEndTime
params.deltaColumn
deltaColumn
은(는) 첫 번째 흐름 실행을 만들 때만 필요합니다.params.deltaColumn.name
응답
응답이 성공하면 고유한 실행 id
을(를) 포함하여 새로 만든 흐름 실행의 세부 정보가 반환됩니다.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
id
etag
파일 기반 소스에 대한 흐름 실행 만들기
파일 기반 소스에 대한 흐름을 만들려면 실행할 흐름의 ID와 시작 시간 및 종료 시간에 대한 값을 제공하면서 Flow Service API에 POST 요청을 합니다.
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
params.startTime
params.windowStartTime
params.windowEndTime
응답
응답이 성공하면 고유한 실행 id
을(를) 포함하여 새로 만든 흐름 실행의 세부 정보가 반환됩니다.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
id
etag
플로우 실행 모니터링
플로우 실행이 생성되면 플로우 실행을 통해 수집되는 데이터를 모니터링하여 플로우 실행, 완료 상태 및 오류에 대한 정보를 확인할 수 있습니다. API를 사용하여 흐름 실행을 모니터링하려면 API의 데이터 흐름 모니터링에 대한 자습서를 참조하십시오. 플랫폼 UI를 사용하여 플로우 실행을 모니터링하려면 모니터링 대시보드를 사용하여 소스 데이터 흐름 모니터링에 대한 안내서를 참조하십시오.