Gedeeltelijke rijupdates verzenden naar Real-Time Customer Profile gebruiken Data Prep

Streaming upserts in Data Prep staat u toe om gedeeltelijke rijupdates te verzenden naar Real-Time Customer Profile gegevens te maken en nieuwe identiteitskoppelingen te maken met één API-aanvraag.

Door upserts te streamen, kunt u het formaat van uw gegevens behouden terwijl het omzetten van die gegevens in Real-Time Customer Profile PATCH vraagt tijdens inname. Gebaseerd op de input u verstrekt, Data Prep kunt u één API-lading verzenden en de gegevens omzetten naar beide Real-Time Customer Profile PATCH en Identity Service CREEER verzoeken.

Dit document bevat informatie over het streamen van upserts in Data Prep.

Aan de slag

Voor dit overzicht is een goed begrip van de volgende Adobe Experience Platform-componenten vereist:

Streaming updates gebruiken in Data Prep streaming-upserts-in-data-prep

Streaming zorgt voor een workflow op hoog niveau

Streaming upserts in Data Prep werkt als volgt:

De identiteitsgegevensset configureren

Als nieuwe identiteiten moeten worden verbonden, dan moet u een extra dataset in de inkomende lading creëren en overgaan. Wanneer het creëren van een identiteitsdataset, moet u ervoor zorgen dat aan de volgende vereisten wordt voldaan:

Vereiste gebieden in de schema's verbonden aan de identiteitsdataset identity-dataset-required-fileds

Als uw schema vereiste gebieden bevat, moet de bevestiging van de dataset worden onderdrukt om toe te laten Identity Service alleen de identiteiten te ontvangen. U kunt validatie onderdrukken door het toepassen van de disabled aan de acp_validationContext parameter. Zie het onderstaande voorbeeld:

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

Binnenkomende laadstructuur

In het volgende voorbeeld ziet u een voorbeeld van een inkomende ladingsstructuur die nieuwe identiteitskoppelingen tot stand brengt.

Payload met identiteitsconfiguratie

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

Ondersteunde bewerkingen

De volgende bewerkingen worden ondersteund door Real-Time Customer Profile:

De volgende bewerkingen worden ondersteund door Identity Service:

Payload zonder identiteitsconfiguratie

Als nieuwe identiteiten niet hoeven te worden gekoppeld, kunt u de eigenschap identity en identityDatasetId parameters in de bewerkingen. Hiermee verzendt u gegevens alleen naar Real-Time Customer Profile en slaat de Identity Service. Zie de lading hieronder voor een voorbeeld:

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

Primaire identiteiten dynamisch doorgeven

Voor XDM-updates moet het schema zijn ingeschakeld voor Profile en bevatten een primaire identiteit. U kunt de primaire identiteit van een XDM-schema op twee manieren specificeren:

Een statisch veld aanwijzen als primair identiteitsveld in het XDM-schema

In het onderstaande voorbeeld: state, homePhone.number en andere eigenschappen worden met de respectieve gegeven waarden opgenomen in de Profile met de primaire identiteit van sampleEmail@gmail.com. Vervolgens wordt een updatebericht voor een XDM-entiteit gegenereerd door streaming Data Prep component. Real-Time Customer Profile bevestigt dan dat XDM updatebericht om het profielverslag op te nemen.

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

Wijs één van de identiteitsgebieden als primaire identiteit door de het gebiedsgroep van het identiteitskaartgebied in het XDM schema aan

In dit voorbeeld bevat de header de operations kenmerk met de identity en identityDatasetId eigenschappen. Hierdoor kunnen gegevens worden samengevoegd met Real-Time Customer Profile en ook voor het doorgeven van identiteit aan 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"
  }
 }'

Bekende beperkingen en belangrijke overwegingen

In het volgende voorbeeld wordt een lijst met bekende beperkingen beschreven die in acht moeten worden genomen bij het streamen van updates met Data Prep:

Volgende stappen

Door dit document te lezen, moet u nu begrijpen hoe u upserts kunt streamen in Data Prep om gedeeltelijke rijupdates naar uw te verzenden Real-Time Customer Profile gegevens, maar ook identiteiten maken en koppelen met één API-aanvraag. Voor meer informatie over andere Data Prep functies, lees de Data Prep overzicht. Leer hoe u toewijzingssets kunt gebruiken in het dialoogvenster Data Prep API, lees de Data Prep ontwikkelaarsgids.