Enviar atualizações de linhas parciais para Real-Time Customer Profile usar Data Prep

Upserts de transmissão em Data Prep permite enviar atualizações parciais de linha para Real-Time Customer Profile enquanto também cria e estabelece 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 os traduz para Real-Time Customer Profile solicitações PATCH durante a assimilação. Com base nas informações fornecidas, Data Prep permite enviar uma única carga de API e traduzir os dados para ambos Real-Time Customer Profile PATCH e Identity Service CRIAR solicitações.

Este documento fornece informações sobre como fazer stream 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 transmissão no Data Prep streaming-upserts-in-data-prep

Streaming substitui o fluxo de trabalho de alto nível

Upserts de transmissão em Data Prep funciona 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 habilitar Identity Service para receber apenas as identidades. É possível suprimir a validação aplicando o disabled para o acp_validationContext parâmetro. 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 pela Real-Time Customer Profile:

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

Carga sem configuração de identidade

Se novas identidades não precisarem ser vinculadas, você poderá omitir a variável identity e identityDatasetId nas operações. Isso envia dados somente para o 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 do XDM, o esquema deve ser ativado para Profile e contêm uma identidade principal. 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 na variável Profile com a identidade principal de sampleEmail@gmail.com. Uma mensagem de atualização de entidade XDM é gerada pela transmissão Data Prep componente. Real-Time Customer Profile em seguida, 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 a variável operations atributo com o identity e identityDatasetId propriedades. Isso permite que os dados sejam mesclados com Real-Time Customer Profile e também para 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, é apresentada 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 linha ao seu Real-Time Customer Profile ao mesmo tempo em que cria e vincula identidades com uma única solicitação de API. Para obter mais informações sobre outras Data Prep recursos, leia os Data Prep visão geral. Para saber como usar conjuntos de mapeamento na Data Prep API, leia as Data Prep guia do desenvolvedor.