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

Upsert in streaming Data Prep consente di inviare aggiornamenti di riga parziali a Real-Time Customer Profile 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 Real-Time Customer Profile 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 Real-Time Customer Profile 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:

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

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

Upsert in streaming Data Prep funziona 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, 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"
        ],
        "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 seguenti operazioni sono supportate da Real-Time Customer Profile:

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 Real-Time Customer Profile 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:

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. Real-Time Customer Profile 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 Real-Time Customer Profile 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:

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 Real-Time Customer Profile 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.