Invia aggiornamenti riga parziali a Real-Time Customer Profile tramite Data Prep

Gli upsert di streaming in Data Prep consentono di inviare aggiornamenti di riga parziali ai dati Real-Time Customer Profile, creando e stabilendo nuovi collegamenti di identità con una singola richiesta API.

Con gli aggiornamenti in streaming, è possibile mantenere il formato dei dati durante la traduzione in Real-Time Customer Profile richieste PATCH durante l'acquisizione. In base agli input forniti, Data Prep ti consente di inviare un singolo payload API e tradurre i dati sia alle richieste Real-Time Customer Profile PATCH che a quelle Identity Service CREATE.

In questo documento vengono fornite 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:

Usa gli aggiornamenti in streaming in Data Prep streaming-upserts-in-data-prep

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

Gli upsert di streaming in Data Prep funzionano come segue:

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:

Campi obbligatori negli schemi associati al set di dati di identità identity-dataset-required-fileds

Se lo schema contiene campi obbligatori, è necessario eliminare la convalida del set di dati per consentire a Identity Service di ricevere solo le identità. È possibile eliminare la convalida applicando il valore disabled al parametro acp_validationContext. 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"
        ],
        "unifiedProfile": [
            "enabled:false"
        ],
        "unifiedIdentity": [
            "enabled:true"
        ]
    }
}'

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 operazioni seguenti sono supportate da Real-Time Customer Profile:

Le operazioni seguenti sono supportate da Identity Service:

Payload senza configurazione identità

Se non è necessario collegare nuove identità, è possibile omettere i parametri identity e identityDatasetId nelle operazioni. In questo modo i dati vengono inviati solo a Real-Time Customer Profile e il Identity Service viene ignorato. 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 contenere un'identità primaria. Puoi specificare l’identità primaria di uno schema XDM in due modi:

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

Nell'esempio seguente, state, homePhone.number e altri attributi vengono inseriti con i rispettivi valori specificati in Profile con l'identità primaria di sampleEmail@gmail.com. Un messaggio di aggiornamento dell'entità XDM viene quindi generato dal componente di streaming Data Prep. Real-Time Customer Profile conferma quindi 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 l'attributo operations con le proprietà identity e identityDatasetId. Ciò consente l'unione dei dati con Real-Time Customer Profile e la trasmissione delle identità 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 l'upsert dello streaming con Data Prep:

Passaggi successivi

Dopo aver letto questo documento, sarai in grado di eseguire il flusso degli aggiornamenti a monte in Data Prep per inviare aggiornamenti di riga parziali ai tuoi dati di Real-Time Customer Profile, nonché di creare e collegare identità con una singola richiesta API. Per ulteriori informazioni sulle altre funzionalità di Data Prep, leggere la Data Prep panoramica. Per informazioni su come utilizzare i set di mappatura nell'API Data Prep, leggere la Data Prep guida per gli sviluppatori.