Adobe Experience Platform consente l'acquisizione di dati da origini esterne, fornendo al contempo la possibilità di strutturare, etichettare e migliorare i dati in arrivo tramite Platform i servizi. È possibile acquisire dati da origini diverse, come applicazioni Adobe, storage basato su cloud, database e molti altri.
Adobe Experience Platform Flow Service viene utilizzato per raccogliere e centralizzare i dati dei clienti da varie fonti all'interno Platform. Il servizio fornisce un'interfaccia utente e RESTful API da cui sono collegate tutte le origini supportate.
Con Adobe I/O Events, potete iscrivervi agli eventi e utilizzare i webhooks per ricevere le notifiche relative allo stato delle esecuzioni dei flussi. Queste notifiche contengono informazioni sull'esito positivo dell'esecuzione di flusso o sugli errori che hanno contribuito al fallimento di un'esecuzione.
In questo documento sono descritti i passaggi necessari per effettuare la sottoscrizione agli eventi, registrare i webhooks e ricevere le notifiche contenenti informazioni sullo stato delle esecuzioni di flusso.
Questa esercitazione presuppone che sia già stata creata almeno una connessione di origine il cui flusso viene eseguito da monitorare. Se non avete ancora configurato una connessione di origine, visitate la panoramica delle origini per configurare l'origine desiderata prima di tornare a questa guida.
Questo documento richiede anche una buona conoscenza dei webhooks e di come collegare un webhook da un'applicazione all'altra. Fare riferimento alla I/O Events documentazione per un'introduzione ai webhooks.
Per ricevere le notifiche di esecuzione del flusso, è necessario utilizzare console Sviluppatore di Adobe per registrare un webhook nell' Experience Platform integrazione.
Seguite l’esercitazione sulle notifiche I/O Event di iscrizione per i passaggi dettagliati su come ottenere questo risultato.
Durante il processo di iscrizione, accertatevi di selezionare Platform notifications come fornitore dell'evento e di selezionare le seguenti iscrizioni all'evento:
Con il webhook collegato e l'iscrizione all'evento completata, puoi iniziare a ricevere notifiche di esecuzione del flusso tramite il dashboard del webhook.
Una notifica restituisce informazioni quali il numero di processi di assimilazione eseguiti, la dimensione del file ed errori. Una notifica restituisce anche un payload associato alla tua esecuzione di flusso in formato JSON. Il payload di risposta può essere classificato come sources_flow_run_success
o sources_flow_run_failure
.
Se durante il processo di creazione del flusso è abilitata l’assimilazione parziale, un flusso che contiene sia l’assimilazione riuscita che quella non riuscita sarà 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 errori verranno comunque inclusi nel payload restituito.
Una risposta corretta restituisce un set di metrics
elementi 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à eseguiti per trasformare i dati. |
durationSummary |
Definisce l'ora iniziale e finale dell'esecuzione del flusso. |
sizeSummary |
Definisce il volume dei dati in byte. |
recordSummary |
Definisce il conteggio record dei dati. |
fileSummary |
Definisce il conteggio dei file dei dati. |
fileInfo |
Un URL che porta a una panoramica dei file acquisiti correttamente. |
statusSummary |
Definisce se l'esecuzione del flusso è riuscita o meno. |
La risposta seguente è un esempio di esecuzione di flusso non riuscita, con un errore che si verifica durante l'elaborazione dei dati copiati. Gli errori possono verificarsi anche durante la copia dei dati dall'origine. Un'esecuzione di flusso non riuscita include informazioni sugli errori che hanno contribuito all'errore dell'esecuzione, incluso 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 |
Un URL che porta a una panoramica dei file che sono stati acquisiti con successo e non con successo. |
Per ulteriori informazioni sui messaggi di errore, vedere l' appendice .
Ora puoi abbonarti agli 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 origini, consulta la panoramica sulle origini.
Le sezioni seguenti forniscono informazioni aggiuntive per l'utilizzo delle notifiche di esecuzione del flusso.
Gli errori di inserimento possono verificarsi quando i dati vengono copiati dall'origine o quando i dati copiati vengono elaborati in Platform. Per ulteriori informazioni su errori specifici, vedere 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 può riguardare l'analisi, la convalida o la trasformazione. |