Crea un’esecuzione del flusso per l’acquisizione su richiesta utilizzando Flow Service API
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. 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.
Questa esercitazione descrive i passaggi per utilizzare l’acquisizione on-demand e creare un’esecuzione di flusso utilizzando Flow Service API.
Introduzione
Questo tutorial richiede una buona conoscenza dei seguenti componenti di Adobe Experience Platform:
- Sorgenti: Experience Platform consente di acquisire dati da varie origini e allo stesso tempo di strutturare, etichettare e migliorare i dati in arrivo tramite Platform servizi.
- Sandbox: Experience Platform fornisce sandbox virtuali che permettono di suddividere un singolo Platform in ambienti virtuali separati, per facilitare lo sviluppo e l’evoluzione delle applicazioni di esperienza digitale.
Utilizzo delle API di Platform
Per informazioni su come effettuare correttamente chiamate alle API di Platform, consulta la guida su introduzione alle API di Platform.
Creare un'esecuzione di flusso per un'origine basata su tabella
Per creare un flusso per un’origine basata su tabella, effettua una richiesta POST al Flow Service fornendo l’ID del flusso su cui desideri 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 durante la creazione della prima esecuzione del flusso. Dopo, deltaColumn verrà aggiornata come parte di copy trasformazione nel flusso e sarà trattata come la fonte della verità. Qualsiasi tentativo di modificare il deltaColumn tramite i parametri di esecuzione del flusso genererà 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 la relativa 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, effettua una richiesta POST al Flow Service fornendo l’ID del flusso su cui desideri creare i valori di esecuzione 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 la relativa 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 su monitoraggio dei flussi di dati nell’API. Per monitorare il flusso eseguito tramite l’interfaccia utente di Platform, consulta la guida su monitoraggio dei flussi di dati di origine tramite il dashboard di monitoraggio.