Enviar atualizações parciais de linha para Real-Time Customer Profile usando Data Prep

A transmissão de sobreposições em Data Prep permite enviar atualizações de linhas parciais para dados de Real-Time Customer Profile, além de criar e estabelecer novos links de identidade com uma única solicitação de API.

Ao fazer a transmissão de upserts, você pode reter o formato dos dados enquanto traduz esses dados para Real-Time Customer Profile solicitações de PATCH durante a assimilação. Com base nas entradas que você fornece, o Data Prep permite enviar uma única carga de API e traduzir os dados para Real-Time Customer Profile PATCH e Identity Service solicitações CREATE.

Este documento fornece informações sobre como fazer streaming de upserts no Data Prep.

Introdução

Esta visão geral requer uma compreensão funcional dos seguintes componentes do Adobe Experience Platform:

Usar upserts de streaming em Data Prep streaming-upserts-in-data-prep

Streaming substitui o fluxo de trabalho de alto nível

Os upserts de streaming em Data Prep funcionam da seguinte forma:

Configurar o conjunto de dados de identidade

Se novas identidades precisarem ser vinculadas, você deverá criar e transmitir um conjunto de dados adicional na carga recebida. Ao criar um conjunto de dados de identidade, você deve garantir que os seguintes requisitos sejam atendidos:

Campos obrigatórios nos esquemas associados ao conjunto de dados de identidade identity-dataset-required-fileds

Se o esquema contiver campos obrigatórios, a validação do conjunto de dados deverá ser suprimida para permitir que Identity Service receba apenas as identidades. Você pode suprimir a validação aplicando o valor disabled ao parâmetro acp_validationContext. Consulte o exemplo abaixo:

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

Estrutura de carga de entrada

A seguir é mostrado um exemplo de uma estrutura de payload de entrada que estabelece novos links de identidade.

Carga com configuração de identidade

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

Operações suportadas

As seguintes operações são suportadas por Real-Time Customer Profile:

As seguintes operações são suportadas por Identity Service:

Carga sem configuração de identidade

Se novas identidades não precisarem ser vinculadas, você poderá omitir os parâmetros identity e identityDatasetId nas operações. Isso envia dados somente para Real-Time Customer Profile e ignora o Identity Service. Consulte a carga abaixo para obter um exemplo:

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

Transmitir dinamicamente as identidades principais

Para atualizações XDM, o esquema deve ser habilitado para Profile e conter uma identidade primária. Você pode especificar a identidade principal de um esquema XDM de duas maneiras:

Designar um campo estático como o campo de identidade principal no esquema XDM

No exemplo abaixo, state, homePhone.number e outros atributos são substituídos por seus respectivos valores fornecidos na Profile com a identidade primária de sampleEmail@gmail.com. Uma mensagem de atualização de entidade XDM é gerada pelo componente de streaming Data Prep. Real-Time Customer Profile então confirma que a mensagem de atualização do XDM deve substituir o registro do perfil.

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

Designar um dos campos de identidade como a identidade primária por meio do grupo de campos do mapa de identidade no esquema XDM

Neste exemplo, o cabeçalho contém o atributo operations com as propriedades identity e identityDatasetId. Isso permite que os dados sejam mesclados com Real-Time Customer Profile e também que as identidades sejam passadas para 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"
  }
 }'

Limitações conhecidas e principais considerações

A seguir, uma lista de limitações conhecidas a serem consideradas ao transmitir upserts com Data Prep:

Próximas etapas

Após a leitura deste documento, você deve entender como fazer streaming de upserts no Data Prep para enviar atualizações parciais de linhas aos seus dados do Real-Time Customer Profile, além de criar e vincular identidades com uma única solicitação de API. Para obter mais informações sobre outros recursos do Data Prep, leia a Data Prep visão geral. Para saber como usar conjuntos de mapeamento na API Data Prep, leia o Data Prep guia do desenvolvedor.