Notifiche di esecuzione del flusso

Adobe Experience Platform consente di acquisire dati da sorgenti esterne e allo stesso tempo di strutturare, etichettare e migliorare i dati in arrivo utilizzando i servizi Platform . È possibile acquisire dati da diverse sorgenti, come applicazioni di Adobe, archiviazione basata su cloud, database e molti altri.

Flow Service Le API vengono utilizzate per raccogliere e centralizzare i dati dei clienti da varie fonti diverse all’interno di Platform. Il servizio fornisce un’interfaccia utente e un’API RESTful da cui è possibile connettere tutte le sorgenti supportate.

Ad Adobe I/O, Eventi, puoi abbonarti agli eventi e utilizzare i webhook per ricevere notifiche sullo stato delle esecuzioni dei flussi. Queste notifiche contengono informazioni sul successo dell'esecuzione del flusso o sugli errori che hanno contribuito al fallimento di un'esecuzione.

Questo documento fornisce passaggi su come abbonarsi agli eventi, registrare i webhook e ricevere notifiche contenenti informazioni sullo stato delle esecuzioni dei flussi.

Introduzione

Questa esercitazione presuppone che sia già stata creata almeno una connessione di origine il cui flusso viene eseguito da monitorare. Se non hai ancora configurato una connessione di origine, visita la panoramica origini per configurare l'origine desiderata prima di tornare a questa guida.

Questo documento richiede anche una comprensione funzionante dei webhook e come collegare un webhook da un'applicazione a un'altra. Fai riferimento alla I/O Events documentazione per un'introduzione ai webhook.

Registra un webhook per le notifiche di esecuzione del flusso

Per ricevere le notifiche di esecuzione del flusso, è necessario utilizzare Adobe Developer Console per registrare un webhook nell’integrazione Experience Platform.

Segui l'esercitazione su iscriverti a I/O Event notifications per i passaggi dettagliati su come eseguire questa operazione.

IMPORTANTE

Durante il processo di abbonamento, assicurati di selezionare Notifiche della piattaforma come provider di eventi e di selezionare le seguenti sottoscrizioni di eventi:

  • Flusso dell'origine di Experience Platform eseguito correttamente
  • Impossibile eseguire il flusso dell'origine di Experience Platform

Ricevere notifiche di esecuzione del flusso

Con il tuo webhook collegato e l'abbonamento all'evento completato, puoi iniziare a ricevere notifiche di esecuzione del flusso attraverso il dashboard webhook.

Una notifica restituisce informazioni quali il numero di processi di acquisizione eseguiti, le dimensioni del file e gli errori. Una notifica restituisce anche un payload associato al flusso eseguito in formato JSON. Il payload di risposta può essere classificato come sources_flow_run_success o sources_flow_run_failure.

IMPORTANTE

Se durante il processo di creazione del flusso è abilitata l’acquisizione parziale, un flusso che contiene sia l’acquisizione riuscita che quella non riuscita verrà contrassegnato come sources_flow_run_success solo se il numero di errori è inferiore alla percentuale di soglia di errore impostata durante il processo di creazione del flusso. Se un'esecuzione di flusso corretta contiene errori, questi verranno comunque inclusi come parte del payload restituito.

Operazione riuscita

Una risposta corretta restituisce un set di metrics che definiscono le caratteristiche di un’esecuzione di flusso specifica e activities che delineano il modo in cui i dati vengono trasformati.

{
  "event_id": "aec55616-1715-487f-8044-ba648cc8ffee",
  "event": {
    "createdAt": 1597213529158,
    "updatedAt": 1597213530760,
    "createdBy": "{CREATED_BY}",
    "updatedBy": "{UPDATED_BY}",
    "createdClient": "{CREATED_CLIENT}",
    "updatedClient": "{UPDATED_CLIENT}",
    "sandboxId": "7127a4f0-def8-11e9-83ce-e79494b1c2a5",
    "sandboxName": "prod",
    "imsOrgId": "{IMS_ORG}",
    "id": "933cf9f4-cf01-4d75-bcf9-f4cf010d750a",
    "flowId": "1c6f1047-dcaf-48fe-af10-47dcaf08feaf",
    "providerRefId": "test1234",
    "etag": "\"5100ec97-0000-0200-0000-5f338b5b0000\"",
    "metrics": {
      "durationSummary": {
        "startedAtUTC": 1590512053,
        "completedAtUTC": 1590512053
      },
      "sizeSummary": {
        "inputBytes": 2048,
        "outputBytes": 1024
      },
      "recordSummary": {
        "inputRecordCount": 100,
        "outputRecordCount": 70
      },
      "fileSummary": {
        "inputFileCount": 10,
        "outputFileCount": 10
      },
      "statusSummary": {
        "status": "success"
      }
    },
    "activities": [
      {
        "id": "copyActivity",
        "updatedAtUTC": 87473822,
        "durationSummary": {
          "startedAtUTC": 1590512053,
          "completedAtUTC": 1590512053
        },
        "sizeSummary": {
          "inputBytes": 2048,
          "outputBytes": 1098
        },
        "recordSummary": {
          "inputRecordCount": 100,
          "outputRecordCount": 100
        },
        "fileSummary": {
          "inputFileCount": 10,
          "outputFileCount": 10
        },
        "statusSummary": {
          "status": "success",
          "extensions": {
            "adf/pipeline/id": "abcd",
            "adf/run/id": "1234"
          }
        },
        "sourceInfo": [
          {
            "id": "sourceConnectionId1",
            "type": "SourceConnection",
            "reference": {
              "type": "AdfRunId"
            }
          }
        ]
      },
      {
        "id": "promotionActivity",
        "updatedAtUTC": 87473822,
        "durationSummary": {
          "completedAtUTC": 1590512053
        },
        "sizeSummary": {
          "inputBytes": 1098,
          "outputBytes": 1024
        },
        "recordSummary": {},
        "fileSummary": {
          "inputFileCount": 10,
          "outputFileCount": 10,
          "extensions": {
            "manifest": {
              "fileInfo": "https://platform-int.adobe.io/data/foundation/export/batches/01E4TSJNM2H5M74J0XB8MFWDHK/meta?path=input_files"
            }
          }
        },
        "statusSummary": {
          "status": "success",
          "extensions": {
            "batchId": "b1",
            "acp_request_id": "1234"
          }
        },
        "targetInfo": [
          {
            "id": "targetConnectionId1",
            "type": "TargetConnection",
            "reference": {
              "type": "batch"
            }
          }
        ]
      }
    ],
    "slaCreatedAt": 1597213531124,
    "processStartTime": 1597213531213,
    "header": {
      "_adobeio": {
        "imsOrgId": "{IMS_ORG}",
        "providerMetadata": "platform_notifications",
        "eventCode": "sources_flow_run_success"
      }
    },
    "transformedTime": 1597213531214
  }
}
Proprietà Descrizione
metrics Definisce le caratteristiche dei dati nell'esecuzione del flusso.
activities Definisce i diversi passaggi e attività che vengono eseguiti per trasformare i dati.
durationSummary Definisce l'ora di inizio e di fine dell'esecuzione del flusso.
sizeSummary Definisce il volume dei dati in byte.
recordSummary Definisce il conteggio dei record dei dati.
fileSummary Definisce il conteggio dei file dei dati.
fileInfo URL che consente di visualizzare una panoramica dei file acquisiti correttamente.
statusSummary Definisce se l'esecuzione del flusso è un successo o un errore.

Errore

La risposta seguente è un esempio di esecuzione non riuscita del flusso, con un errore che si verifica quando i dati copiati vengono elaborati. Gli errori possono inoltre verificarsi durante la copia dei dati dall’origine. Un'esecuzione di flusso non riuscita include informazioni sugli errori che hanno contribuito al fallimento dell'esecuzione, inclusi l'errore e la descrizione.

[
  {
    "messages": [
      {
        "msgType": "eventNotification",
        "version": "1.0",
        "timestamp": 1597434157622,
        "imsOrgId": "{IMS_ORG}",
        "schema": {
          "name": "run-notification",
          "version": "1.0"
        },
        "provider": "FlowService",
        "_eventNotificationMeta": {
          "category": "Platform Notifications",
          "type": "sources_flow_run_failed"
        },
        "value": {
          "createdAt": 1597434147259,
          "updatedAt": 1597434157567,
          "createdBy": "{CREATED_BY}",
          "updatedBy": "{UPDATED_BY}",
          "createdClient": "{CREATED_CLIENT}",
          "updatedClient": "{UPDATED_CLIENT}",
          "sandboxId": "e49ebb00-d0fa-11e9-b164-ed6a398c8b35",
          "sandboxName": "prod",
          "imsOrgId": "{IMS_ORG}",
          "id": "d9024c32-2174-4271-824c-322174627101",
          "flowId": "cf4fce79-8822-456d-8fce-798822556dc6",
          "etag": "\"0c003dbf-0000-0200-0000-5f36e92d0000\"",
          "metrics": {
            "durationSummary": {
              "startedAtUTC": 1597434147190
            },
            "sizeSummary": {
              "inputBytes": -1
            },
            "fileSummary": {
              "inputFileCount": -1
            },
            "statusSummary": {
              "status": "failed",
              "errors": [
                {
                  "code": "CONNECTOR-2001-500",
                  "message": "Error in processing (parsing, validation or transformation) the copied data."
                }
              ]
            }
          },
          "activities": [
            {
              "id": "promotionActivity",
              "updatedAtUTC": 1597434157529,
              "durationSummary": {
                "startedAtUTC": 1597434147190,
                "completedAtUTC": 1597434157212
              },
              "sizeSummary": {
                "inputBytes": -1
              },
              "recordSummary": {},
              "fileSummary": {
                "inputFileCount": -1,
                "extensions": {
                  "manifest": {
                    "fileInfo": "https://platform-stage.adobe.io/data/foundation/export/batches/6f6a900f-e40d-4f0e-9bb9-b614436c3465/meta?path=input_files"
                  }
                }
              },
              "statusSummary": {
                "status": "failed",
                "errors": [
                  {
                    "code": "CONNECTOR-2001-500",
                    "message": "Error in processing (parsing, validation or transformation) the copied data."
                  }
                ],
                "extensions": {
                  "errors": [
                    {
                      "code": "133",
                      "message": "We are unable to locate any files uploaded for this batch. Please upload files to ingest."
                    }
                  ]
                }
              },
              "targetInfo": [
                {
                  "id": "e88737aa-27b8-4795-8737-aa27b8f7959e",
                  "type": "TargetConnection",
                  "reference": {
                    "type": "Batch",
                    "ids": [
                      "6f6a900f-e40d-4f0e-9bb9-b614436c3465"
                    ]
                  }
                }
              ]
            }
          ]
        }
      }
    ]
  }
]
Proprietà Descrizione
fileInfo URL che consente di visualizzare una panoramica dei file che sono stati acquisiti con successo e senza successo.
NOTA

Per ulteriori informazioni sui messaggi di errore, consulta l’ appendice .

Passaggi successivi

Ora puoi abbonarti a eventi che ti consentono di ricevere notifiche in tempo reale sugli stati di esecuzione del flusso. Per ulteriori informazioni sulle esecuzioni di flusso e sulle sorgenti, consulta la panoramica origini.

Appendice

Le sezioni seguenti forniscono informazioni aggiuntive per l’utilizzo delle notifiche di esecuzione del flusso.

Informazioni sui messaggi di errore

Gli errori di acquisizione possono verificarsi quando i dati vengono copiati dall’origine o quando i dati copiati vengono elaborati in Platform. Per ulteriori informazioni su errori specifici, consulta la tabella seguente.

Errore Descrizione
CONNECTOR-1001-500 Errore durante la copia dei dati da un'origine.
CONNECTOR-2001-500 Errore durante l'elaborazione dei dati copiati in Platform. Questo errore potrebbe riguardare l’analisi, la convalida o la trasformazione.

In questa pagina