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.
Per creare un’esecuzione del flusso, devi innanzitutto disporre dell’ID di flusso di un flusso di dati pianificato per l’acquisizione una tantum.
Questo tutorial richiede una buona conoscenza dei seguenti componenti di Adobe Experience Platform:
Per informazioni su come effettuare correttamente chiamate alle API di Platform, consulta la guida su introduzione alle API di Platform.
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.
Le origini basate su tabelle includono le seguenti categorie di origini: pubblicità, analisi, consenso e preferenze, CRM, successo del cliente, database, automazione marketing, pagamenti e protocolli.
Formato API
POST /runs/
Richiesta
La richiesta seguente crea un’esecuzione di flusso per l’ID di flusso 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
.
È sufficiente fornire 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"
}
}
}'
Parametro | Descrizione |
---|---|
flowId |
ID del flusso su cui verrà creata l’esecuzione del flusso. |
params.startTime |
L’ora programmata di inizio dell’esecuzione del flusso su richiesta. Questo valore è rappresentato nel tempo unix. |
params.windowStartTime |
La prima data e ora da cui verranno recuperati i dati. Questo valore è rappresentato nel tempo unix. |
params.windowEndTime |
La data e l’ora in cui i dati verranno recuperati. Questo valore è rappresentato nel tempo unix. |
params.deltaColumn |
La colonna delta è necessaria per partizionare i dati e separare i dati appena acquisiti da quelli storici. Nota: Il deltaColumn è necessario solo durante la creazione della prima esecuzione del flusso. |
params.deltaColumn.name |
Nome della colonna delta. |
Risposta
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\""
}
]
}
Proprietà | Descrizione |
---|---|
id |
ID dell’esecuzione del flusso appena creata. Consulta la guida su recupero delle specifiche di flusso per ulteriori informazioni sulle specifiche di esecuzione basate su tabelle. |
etag |
Versione risorsa dell’esecuzione del flusso. |
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.
Le origini basate su file includono tutte le origini di archiviazione cloud.
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"
}
}'
Parametro | Descrizione |
---|---|
flowId |
ID del flusso su cui verrà creata l’esecuzione del flusso. |
params.startTime |
L’ora programmata di inizio dell’esecuzione del flusso su richiesta. Questo valore è rappresentato nel tempo unix. |
params.windowStartTime |
La prima data e ora da cui verranno recuperati i dati. Questo valore è rappresentato nel tempo unix. |
params.windowEndTime |
La data e l’ora in cui i dati verranno recuperati. Questo valore è rappresentato nel tempo unix. |
Risposta
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\""
}
]
}
Proprietà | Descrizione |
---|---|
id |
ID dell’esecuzione del flusso appena creata. Consulta la guida su recupero delle specifiche di flusso per ulteriori informazioni sulle specifiche di esecuzione basate su tabelle. |
etag |
Versione risorsa dell’esecuzione 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.