Invia aggiornamenti riga parziali a Profile Service utilizzo Data Prep

Upsert in streaming Data Prep consente di inviare aggiornamenti di riga parziali a Profile Service e allo stesso tempo creare e stabilire nuovi collegamenti di identità con una singola richiesta API.

Gli aggiornamenti in streaming consentono di mantenere il formato dei dati durante la traduzione Profile Service Richieste PATCH durante l’acquisizione. In base agli input forniti, Data Prep consente di inviare un singolo payload API e tradurre i dati in entrambi Profile Service PATCH e Identity Service Creare le richieste.

Questo documento fornisce informazioni su come eseguire lo streaming degli upsert in Data Prep.

Introduzione

Questa panoramica richiede una buona conoscenza dei seguenti componenti di Adobe Experience Platform:

• Data Prep: Data Prep consente ai data engineer di mappare, trasformare e convalidare i dati da e verso Experience Data Model (XDM).
• Identity Service: ottieni una visione migliore dei singoli clienti e del loro comportamento collegando le identità tra dispositivi e sistemi.
• Profilo cliente in tempo reale: fornisce un profilo cliente unificato in tempo reale basato su dati aggregati provenienti da più origini.
• Sorgenti: un Experience Platform consente di acquisire dati da varie origini, consentendoti allo stesso tempo di strutturare, etichettare e migliorare i dati in arrivo tramite i servizi di Platform.

Utilizzare gli aggiornamenti in streaming in Data Prep

Flussi di lavoro di alto livello per l'upsert dello streaming

Upsert in streaming Data Prep funziona come segue:

• Devi innanzitutto creare e abilitare un set di dati per Profile consumo. Consulta la guida su abilitazione di un set di dati per Profile per ulteriori informazioni;
• Se devi collegare nuove identità, devi anche creare un set di dati aggiuntivo con lo stesso schema come Profile serie di dati;
• Una volta preparati i set di dati, devi creare un flusso di dati per mappare la richiesta in ingresso su Profile serie di dati;
• Successivamente, devi aggiornare la richiesta in ingresso per includere le intestazioni necessarie. Queste intestazioni definiscono:
  • L’operazione sui dati da eseguire con Profile: create, merge, e delete;
  • Operazione di identità facoltativa da eseguire con Identity Service: create.

Configurare il set di dati di identità

Se è necessario collegare nuove identità, devi creare e trasmettere un set di dati aggiuntivo nel payload in ingresso. Quando crei un set di dati di identità, devi assicurarti che siano soddisfatti i seguenti requisiti:

• Il set di dati di identità deve avere lo schema associato come Profile set di dati. Una mancata corrispondenza degli schemi può portare a un comportamento incoerente del sistema;
• Tuttavia, devi assicurarti che il set di dati di identità sia diverso da Profile set di dati. Se i set di dati sono gli stessi, i dati verranno sovrascritti anziché aggiornati;
• Mentre il set di dati iniziale deve essere abilitato per Profile, il set di dati di identità non deve essere abilitato per Profile. In caso contrario, anche i dati verranno sovrascritti anziché aggiornati.

Campi obbligatori negli schemi associati al set di dati di identità

Se lo schema contiene campi obbligatori, la convalida del set di dati deve essere eliminata per abilitare Identity Service per ricevere solo le identità. È possibile sopprimere la convalida applicando la disabled valore per acp_validationContext parametro. Vedi l’esempio seguente:

curl -X POST 'https://platform.adobe.io/data/foundation/catalog/dataSets/62257bef7a75461948ebcaaa' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'Content-Type: application/json' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {IMS_ORG}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -d '{
    "tags":{
        "acp_validationContext": ["disabled"]
        }
}'

Struttura del payload in ingresso

Di seguito è riportato un esempio di struttura di payload in ingresso che stabilisce nuovi collegamenti di identità.

Payload con configurazione identità

{
  "header": {
    "flowId": "923e2ac3-3869-46ec-9e6f-7012c4e23f69",
    "imsOrgId": "{ORG_ID}",
    "datasetId": "621fc19ab33d941949af16c8",
    "operations": {
        "data": "create" (default)/"merge"/"delete",
        "identity": "create",
        "identityDatasetId": "621fc19ab33d941949af16d9"
    }
  }
... //The raw data attributes are included here as the key/value pairs of the "body" property.
}

Operazioni supportate

Le seguenti operazioni sono supportate da Profile Service:

Le seguenti operazioni sono supportate da Identity Service:

Payload senza configurazione identità

Se non è necessario collegare nuove identità, puoi omettere identity e identityDatasetId parametri nelle operazioni. In questo modo i dati vengono inviati solo a Profile Service e salta la Identity Service. Per un esempio, consulta il payload seguente:

{
  "header": {
    "flowId": "923e2ac3-3869-46ec-9e6f-7012c4e23f69",
    "imsOrgId": "{ORG_ID}",
    "datasetId": "621fc19ab33d941949af16c8",
    "operations": {
        "data": "create"/"merge"/"delete",
    }
  }
... //The raw data attributes are included here as the key/value pairs of the "body" property.
}

Passaggio dinamico delle identità primarie

Per gli aggiornamenti XDM, lo schema deve essere abilitato per Profile e contengono un’identità primaria. Puoi specificare l’identità primaria di uno schema XDM in due modi:

• Designa un campo statico come identità primaria nello schema XDM;
• Designa uno dei campi di identità come identità principale tramite il gruppo di campi della mappa di identità nello schema XDM.

Designare un campo statico come campo di identità principale nello schema XDM

Nell’esempio seguente, state, homePhone.number e gli altri attributi vengono inseriti con i rispettivi valori specificati nel Profile con l’identità primaria di sampleEmail@gmail.com. Il messaggio di aggiornamento di un’entità XDM viene quindi generato dal flusso Data Prep componente. Profile Service quindi conferma che il messaggio di aggiornamento XDM esegue l’upsert del record del profilo.

curl -X POST 'https://dcs.adobedc.net/collection/9aba816d350a69c4abbd283eb5818ec3583275ffce4880ffc482be5a9d810c4b' \
  -H 'Content-Type: application/json' \
  -H 'x-adobe-flow-id: d5262d48-0f47-4949-be6d-795f06933527' \
  -d '{
    "header": {
        "flowId" : "d5262d48-0f47-4949-be6d-795f06933527",
        "imsOrgId": "{ORG_ID}",
        "datasetId": "62259f817f62d71947929a7b",
        "operations": {
         "data": "create"
     }
    },
    {
        "body": {
        "homeAddress": {
            "country": "US",
            "state": "GA",
            "region": "va7"
        },
        "homePhone": {
            "number": "123.456.799"
        },
        "identityMap": {
            "Email": [{
                "id": "sampleEmail@gmail.com",
                "primary": true
            }]
        },
      "personalEmail": {
            "address": "sampleEmail@gmail.com",
            "primary": true
       },
      "personID": "346576345",
      "_id": "346576345",
      "timestamp": "2021-05-05T17:51:45.1880+02",
      "workEmail": "sampleWorkEmail@gmail.com"
  }
}'

Designa uno dei campi di identità come identità principale tramite il gruppo di campi della mappa di identità nello schema XDM

In questo esempio, l’intestazione contiene operations attributo con identity e identityDatasetId proprietà. Questo consente di unire i dati con Profile Service e anche per le identità da trasmettere a Identity Service.

curl -X POST 'https://dcs.adobedc.net/collection/9aba816d350a69c4abbd283eb5818ec3583275ffce4880ffc482be5a9d810c4b' \
  -H 'Content-Type: application/json' \
  -H 'x-adobe-flow-id: d5262d48-0f47-4949-be6d-795f06933527' \
  -d '{
    "header": {
        "flowId" : "d5262d48-0f47-4949-be6d-795f06933527",
        "imsOrgId": "{ORG_ID}",
        "datasetId": "62259f817f62d71947929a7b",
        "operations": {
            "data": "merge",
            "identity": "create",
            "identityDatasetId": "6254a93b851ecd194b64af9e"
      }
    },
    {
       "body": {
        "homeAddress": {
            "country": "US",
            "state": "GA",
            "region": "va7"
        },
        "homePhone": {
            "number": "123.456.799"
        },
        "identityMap": {
            "Email": [{
                "id": "sampleEmail@gmail.com",
                "primary": true
            }]
        },
      "personalEmail": {
            "address": "sampleEmail@gmail.com",
            "primary": true
       },
      "personID": "346576345",
      "_id": "346576345",
      "timestamp": "2021-05-05T17:51:45.1880+02",
      "workEmail": "sampleWorkEmail@gmail.com"
  }
 }'

Limitazioni note e considerazioni chiave

Di seguito è riportato un elenco delle limitazioni note da considerare quando si esegue lo streaming degli aggiornamenti con Data Prep:

• Il metodo di streaming upserts deve essere utilizzato solo quando si inviano aggiornamenti parziali delle righe a Profile Service. Gli aggiornamenti parziali delle righe sono non consumato dal data lake.
• Il metodo degli aggiornamenti in streaming non supporta l’aggiornamento, la sostituzione e la rimozione di identità. Se non esistono, vengono create nuove identità. Da qui la identity L'operazione deve essere sempre impostata su create. Se esiste già un’identità, l’operazione è no-op.
• Il metodo di streaming upserts attualmente non supporta Adobe Experience Platform Web SDK e SDK di Adobe Experience Platform Mobile.

Passaggi successivi

Una volta letto questo documento, sarai in grado di eseguire lo streaming degli upsert in Data Prep per inviare aggiornamenti di riga parziali al Profile Service e di creare e collegare le identità con una singola richiesta API. Per ulteriori informazioni su altri Data Prep , leggi le Data Prep panoramica. Per informazioni su come utilizzare i set di mappatura all'interno di Data Prep API, leggi le Data Prep guida per sviluppatori.

Risorse Business.Adobe.com