Creare un'esecuzione di flusso per l'acquisizione su richiesta utilizzando l'API Flow Service
Le esecuzioni del flusso rappresentano un’istanza dell’esecuzione del flusso. Ad esempio, se un flusso è pianificato per essere eseguito ogni ora alle 9:00, alle 10:00 e alle 11:00, sono disponibili tre istanze di un flusso eseguito. Le esecuzioni del flusso sono specifiche per la tua particolare organizzazione.
L’acquisizione su richiesta consente di creare un flusso eseguito su un determinato flusso di dati. Questo consente agli utenti di creare un’esecuzione del flusso, basata su parametri specifici, e un ciclo di acquisizione, senza token di servizio. Il supporto per l’acquisizione su richiesta è disponibile solo per le origini batch.
Questo tutorial illustra i passaggi per utilizzare l'acquisizione su richiesta e creare un'esecuzione del flusso utilizzando Flow Service API.
Introduzione
Questo tutorial richiede una buona conoscenza dei seguenti componenti di Adobe Experience Platform:
- Origini: Experience Platform consente l'acquisizione di dati da varie origini e consente di strutturare, etichettare e migliorare i dati in arrivo tramite i servizi Experience Platform.
- Sandbox: Experience Platform fornisce sandbox virtuali che suddividono una singola istanza di Experience Platform in ambienti virtuali separati, utili per le attività di sviluppo e aggiornamento delle applicazioni di esperienza digitale.
Utilizzo delle API di Experience Platform
Per informazioni su come effettuare correttamente chiamate alle API di Experience Platform, consulta la guida introduttiva alle API di Experience Platform.
Creare un'esecuzione di flusso per un'origine basata su tabella
Per creare un flusso per un'origine basata su tabella, eseguire una richiesta POST all'API Flow Service fornendo l'ID del flusso su cui si desidera creare l'esecuzione, nonché i valori per l'ora di inizio, l'ora di fine e la colonna delta.
Formato API
POST /runs/
Richiesta
La richiesta seguente crea un'esecuzione di flusso per l'ID di flusso 3abea21c-7e36-4be1-bec1-d3bad0e3e0de.
deltaColumn solo quando si crea la prima esecuzione del flusso. In seguito, deltaColumn riceverà la patch come parte della trasformazione copy nel flusso e verrà trattato come l'origine della verità. Eventuali tentativi di modificare il valore deltaColumn tramite i parametri di esecuzione del flusso genereranno un errore.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"
}
}
}'
flowIdparams.startTimeparams.windowStartTimeparams.windowEndTimeparams.deltaColumndeltaColumn è necessario solo durante la creazione della prima esecuzione del flusso.params.deltaColumn.nameRisposta
In caso di esito positivo, la risposta restituisce i dettagli della nuova esecuzione di flusso creata, inclusa l'esecuzione univoca id.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
idetagCreare un'esecuzione di flusso per un'origine basata su file
Per creare un flusso per un'origine basata su file, eseguire una richiesta POST all'API Flow Service fornendo l'ID del flusso su cui si desidera creare i valori e per l'ora di inizio e di fine.
Formato API
POST /runs/
Richiesta
La richiesta seguente crea un'esecuzione di flusso per l'ID di flusso 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"
}
}'
flowIdparams.startTimeparams.windowStartTimeparams.windowEndTimeRisposta
In caso di esito positivo, la risposta restituisce i dettagli della nuova esecuzione di flusso creata, inclusa l'esecuzione univoca id.
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
idetagMonitorare le esecuzioni del flusso
Una volta creata l’esecuzione del flusso, puoi monitorare i dati che vengono acquisiti tramite di essa per visualizzare informazioni sulle esecuzioni del flusso, sullo stato di completamento e sugli errori. Per monitorare il flusso eseguito utilizzando l'API, consulta l'esercitazione sul monitoraggio dei flussi di dati nell'API. Per monitorare le esecuzioni del flusso tramite l'interfaccia utente di Experience Platform, consulta la guida su flussi di dati di origine monitoraggio tramite il dashboard di monitoraggio.