Envoi de mises à jour de lignes partielles à Real-Time Customer Profile using Data Prep

Diffusion en continu des upserts dans Data Prep vous permet d’envoyer des mises à jour de ligne partielles à Real-Time Customer Profile lors de la création et de l’établissement de nouveaux liens d’identité avec une seule requête API.

En diffusant en continu des upserts, vous pouvez conserver le format de vos données tout en convertissant ces données en Real-Time Customer Profile Demandes de PATCH pendant l’ingestion. En fonction des entrées que vous fournissez, Data Prep vous permet d’envoyer une seule charge utile API et de traduire les données dans les deux Real-Time Customer Profile PATCH et Identity Service CRÉEZ des requêtes.

Ce document fournit des informations sur la diffusion en continu de upserts dans Data Prep.

Prise en main

Cette présentation d’ nécessite une compréhension professionnelle des composants suivants d’Adobe Experience Platform :

Utilisation de serveurs de diffusion en continu dans Data Prep streaming-upserts-in-data-prep

Workflow de haut niveau des upserts en flux continu

Diffusion en continu des upserts dans Data Prep fonctionne comme suit :

Configuration du jeu de données d’identité

Si de nouvelles identités doivent être liées, vous devez créer et transmettre un jeu de données supplémentaire dans la payload entrante. Lors de la création d’un jeu de données d’identité, vous devez vous assurer que les conditions suivantes sont remplies :

Champs obligatoires dans les schémas associés au jeu de données d’identité identity-dataset-required-fileds

Si votre schéma contient des champs obligatoires, la validation du jeu de données doit être supprimée pour permettre Identity Service pour ne recevoir que les identités. Vous pouvez supprimer la validation en appliquant le disabled à la valeur acp_validationContext . Voir l’exemple ci-dessous :

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"
        ]
    }
}'

Structure de payload entrante

L’exemple suivant illustre une structure de payload entrante établissant de nouveaux liens d’identité.

Payload avec configuration d’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.
}

Opérations prises en charge

Les opérations suivantes sont prises en charge par Real-Time Customer Profile:

Les opérations suivantes sont prises en charge par Identity Service:

Charge utile sans configuration d’identité

Si de nouvelles identités n’ont pas besoin d’être liées, vous pouvez omettre la variable identity et identityDatasetId dans les opérations. Ainsi, les données ne sont envoyées qu’à Real-Time Customer Profile et ignore la variable Identity Service. Voir la payload ci-dessous pour obtenir un exemple :

{
  "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.
}

Transmission dynamique des identités primaires

Pour les mises à jour XDM, le schéma doit être activé pour Profile et contiennent une identité principale. Vous pouvez spécifier l’identité principale d’un schéma XDM de deux manières :

Désigner un champ statique comme champ d’identité principal dans le schéma XDM

Dans l’exemple ci-dessous, state, homePhone.number et d’autres attributs sont mis à jour avec leurs valeurs respectives données dans la variable Profile avec l’identité principale de sampleEmail@gmail.com. Un message de mise à jour d’entité XDM est ensuite généré par la diffusion en continu. Data Prep composant. Real-Time Customer Profile confirme ensuite le message de mise à jour XDM pour insérer l’enregistrement de profil.

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"
  }
}'

Désigner l’un des champs d’identité comme identité principale par le biais du groupe de champs de carte d’identité dans le schéma XDM

Dans cet exemple, l’en-tête contient le operations avec l’attribut identity et identityDatasetId propriétés. Cela permet de fusionner les données avec Real-Time Customer Profile et également pour les identités à transmettre à 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"
  }
 }'

Limites connues et considérations clés

Vous trouverez ci-dessous une liste des limites connues à prendre en compte lors de la diffusion en continu de serveurs avec Data Prep:

Étapes suivantes

En lisant ce document, vous devez maintenant comprendre comment diffuser des upserts dans Data Prep pour envoyer des mises à jour de ligne partielles à votre Real-Time Customer Profile , tout en créant et en liant des identités à une seule requête API. Pour plus d’informations sur les autres Data Prep fonctions, veuillez lire la Data Prep aperçu. Pour savoir comment utiliser les ensembles de mappages dans la Data Prep API, veuillez lire la Data Prep guide de développement.