(Beta) Crea un’esecuzione del flusso per l’acquisizione su richiesta utilizzando Flow Service API

IMPORTANTE

L’acquisizione on-demand è attualmente in versione beta e la tua organizzazione potrebbe non averne ancora accesso. Le funzionalità descritte in questa documentazione sono soggette a modifiche.

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 illustra i passaggi per utilizzare l’acquisizione on-demand e creare un’esecuzione di flusso utilizzando Flow Service API.

Introduzione

NOTA

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:

  • 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.

SUGGERIMENTO

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.

NOTA

È 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 Numero intero che definisce l'ora di inizio dell'esecuzione. Il valore è rappresentato nel tempo dell'epoca unix.
params.windowStartTime Numero intero che definisce l'ora di inizio della finestra durante la quale devono essere estratti i dati. Il valore è rappresentato nel tempo Unix.
params.windowEndTime Numero intero che definisce l'ora di fine della finestra durante la quale devono essere estratti i dati. Il 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.

Creare 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.

SUGGERIMENTO

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 Numero intero che definisce l'ora di inizio dell'esecuzione. Il valore è rappresentato nel tempo dell'epoca unix.
params.windowStartTime Numero intero che definisce l'ora di inizio della finestra durante la quale devono essere estratti i dati. Il valore è rappresentato nel tempo Unix.
params.windowEndTime Numero intero che definisce l'ora di fine della finestra durante la quale devono essere estratti i dati. Il 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.

Monitorare 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.

In questa pagina