DocumentazioneExperience PlatformGuida ai connettori di origini

Creare un'esecuzione di flusso per l'acquisizione su richiesta utilizzando l'API Flow Service

Last update: Wed Jul 31 2024 00:00:00 GMT+0000 (Coordinated Universal Time)
  • Argomenti:

Creato per:

  • Sviluppatore

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.

Questo tutorial illustra i passaggi per utilizzare l'acquisizione su richiesta e creare un'esecuzione del flusso utilizzando Flow Service API.

Introduzione

NOTE
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:

  • 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 Platform.
  • Sandbox: Experience Platform fornisce sandbox virtuali che suddividono una singola istanza di Platform in ambienti virtuali separati, utili per le attività di sviluppo e aggiornamento delle applicazioni di esperienza digitale.

Utilizzo delle API di Platform

Per informazioni su come effettuare correttamente chiamate alle API di Platform, consulta la guida in guida introduttiva 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, 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.

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

NOTE
È necessario fornire 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"
          }
      }
  }'
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: 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 l'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. Per ulteriori informazioni sulle specifiche di esecuzione basate su tabelle, vedere la guida al recupero delle specifiche di flusso.
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, effettuare 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.

TIP
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 l'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. Per ulteriori informazioni sulle specifiche di esecuzione basate su tabelle, vedere la guida al recupero delle specifiche di flusso.
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 sul monitoraggio dei flussi di dati nell'API. Per monitorare le esecuzioni del flusso tramite l'interfaccia utente di Platform, consulta la guida su flussi di dati di origine monitoraggio tramite il dashboard di monitoraggio.

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089