(Beta) Crea un’esecuzione di flusso per l’acquisizione on-demand utilizzando Flow Service API

IMPORTANTE

L’acquisizione su richiesta è attualmente in versione beta e la tua organizzazione potrebbe non averne ancora accesso. La funzionalità descritta in questa documentazione è soggetta a modifiche.

Le esecuzioni del flusso rappresentano un'istanza di esecuzione del flusso. Ad esempio, se un flusso viene pianificato per essere eseguito ogni ora alle 09:00, 10:00 e 11:00, si avranno tre istanze di un’esecuzione di flusso. Le esecuzioni dei flussi sono specifiche per la tua organizzazione specifica.

L’acquisizione su richiesta consente di creare un’esecuzione di flusso rispetto a un determinato flusso di dati. Questo consente agli utenti di creare un’esecuzione di flusso, in base a determinati parametri e di creare un ciclo di acquisizione, senza token di servizio. Il supporto per l’acquisizione on-demand è 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

NOTA

Per creare un’esecuzione di flusso, devi prima disporre dell’ID di flusso di un flusso di dati pianificato per l’inserimento una tantum.

Questa esercitazione richiede una buona comprensione dei seguenti componenti di Adobe Experience Platform:

  • Origini: Experience Platform consente l’acquisizione di dati da varie sorgenti, fornendo al contempo la possibilità di strutturare, etichettare e migliorare i dati in arrivo utilizzando Platform servizi.
  • Sandbox: Experience Platform fornisce sandbox virtuali che suddividono un singolo Platform in ambienti virtuali separati per sviluppare e sviluppare applicazioni di esperienza digitale.

Utilizzo delle API di Platform

Per informazioni su come effettuare correttamente le chiamate alle API di Platform, consulta la guida su guida introduttiva alle API di Platform.

Creazione di un'esecuzione di flusso per un'origine basata su tabella

Per creare un flusso per un’origine basata su tabella, invia una richiesta POST al Flow Service API 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 origine: pubblicità, analisi, consenso e preferenze, CRM, successo cliente, database, automazione marketing, pagamenti e protocolli.

Formato API

POST /runs/

Richiesta

La seguente richiesta crea un’esecuzione di flusso per l’ID di flusso 3abea21c-7e36-4be1-bec1-d3bad0e3e0de.

NOTA

Devi solo fornire deltaColumn durante la creazione della prima esecuzione di flusso. Dopo questo, deltaColumn saranno patch come parte di copy trasformazione nel flusso e sarà trattato come la fonte della verità. Qualsiasi tentativo di modificare il deltaColumn attraverso i parametri di esecuzione del flusso si verifica 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 in cui verrà creata l'esecuzione del flusso.
params.startTime Un numero intero che definisce l'ora di inizio dell'esecuzione. Il valore è rappresentato in tempo unix epoch.
params.windowStartTime Un numero intero che definisce l'ora iniziale della finestra durante la quale i dati devono essere estratti. Il valore è rappresentato in tempo unix.
params.windowEndTime Un numero intero che definisce l'ora di fine della finestra durante la quale i dati devono essere estratti. Il valore è rappresentato in tempo unix.
params.deltaColumn La colonna delta è necessaria per suddividere i dati e separare i dati appena acquisiti dai dati storici. Nota: La deltaColumn è necessario solo durante la creazione della prima esecuzione di flusso.
params.deltaColumn.name Nome della colonna delta.

Risposta

Una risposta corretta restituisce i dettagli della nuova esecuzione di flusso creata, inclusa la sua esecuzione univoca id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}
Proprietà Descrizione
id ID della nuova esecuzione di flusso 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.

Creazione di un'esecuzione di flusso per un'origine basata su file

Per creare un flusso per un’origine basata su file, invia una richiesta POST al Flow Service API fornendo l’ID del flusso con cui desideri creare i valori di esecuzione rispetto a 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 seguente richiesta 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 in cui verrà creata l'esecuzione del flusso.
params.startTime Un numero intero che definisce l'ora di inizio dell'esecuzione. Il valore è rappresentato in tempo unix epoch.
params.windowStartTime Un numero intero che definisce l'ora iniziale della finestra durante la quale i dati devono essere estratti. Il valore è rappresentato in tempo unix.
params.windowEndTime Un numero intero che definisce l'ora di fine della finestra durante la quale i dati devono essere estratti. Il valore è rappresentato in tempo unix.

Risposta

Una risposta corretta restituisce i dettagli della nuova esecuzione di flusso creata, inclusa la sua esecuzione univoca id.

{
    "items": [
        {
            "id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
            "etag": "\"1100c53e-0000-0200-0000-627138980000\""
        }
    ]
}
Proprietà Descrizione
id ID della nuova esecuzione di flusso 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 dei flussi

Una volta creata l’esecuzione di flusso, puoi monitorare i dati che vengono acquisiti tramite di essa per visualizzare informazioni sulle esecuzioni di flusso, sullo stato di completamento e sugli errori. Per monitorare le esecuzioni di flusso utilizzando l’API, consulta l’esercitazione su monitoraggio dei flussi di dati nell’API . Per monitorare le esecuzioni del flusso tramite l’interfaccia utente di Platform, consulta la guida su monitoraggio dei flussi di dati delle origini tramite il dashboard di monitoraggio.

In questa pagina