行の一部更新を次に送信: Real-Time Customer Profile using Data Prep

WARNING
DCS インレットを介したプロファイル更新のための、エクスペリエンスデータモデル (XDM) のエンティティ更新メッセージ (JSONPATCH操作を使用 ) の取り込みは非推奨(廃止予定)となりました。 別の方法として、次の操作を実行できます。 DCS インレットへの生データの取り込み プロファイルの更新時にデータを XDM 準拠のメッセージに変換するために必要なデータマッピングを指定します。

でのアップサートのストリーミング Data Prep 部分行の更新を次の項目に送信できます: Real-Time Customer Profile データを作成し、単一の API リクエストで新しい id リンクを確立することもできます。

アップサートをストリーミングすることで、データをに変換しながら、データの形式を保持できます。 Real-Time Customer Profile 取り込み中のPATCHリクエスト。 指定した入力に基づいて、 Data Prep を使用すると、単一の API ペイロードを送信し、データを Real-Time Customer Profile PATCHと Identity Service CREATE リクエスト。

NOTE
アップサート機能を活用するには、データ取り込み中に XDM 互換の設定をオフにし、 データ準備マッパー.

このドキュメントでは、でアップサートをストリーミングする方法について説明します。 Data Prep.

はじめに

この概要では、Adobe Experience Platform の次のコンポーネントに関する十分な知識が必要です。

  • Data Prep: Data Prep では、データエンジニアが Experience Data Model(XDM) との間で、データのマッピング、変換、検証をおこなうことができます。
  • Identity Service:デバイスやシステム間で ID を結び付けることで、個々の顧客とその行動をより良く把握します。
  • リアルタイム顧客プロファイル:複数のソースから集約されたデータに基づいて、統合された顧客プロファイルをリアルタイムに提供します。
  • ソース:Experience Platform を使用すると、データを様々なソースから取得しながら、Platform サービスを使用して受信データの構造化、ラベル付け、拡張を行うことができます。

でのストリーミングアップサートの使用 Data Prep streaming-upserts-in-data-prep

NOTE
次のソースは、ストリーミングアップサートの使用をサポートしています。

ストリーミングアップサートの高レベルワークフロー

でのアップサートのストリーミング Data Prep は次のように機能します。

  • 最初に、のデータセットを作成して有効にする必要があります。 Profile 消費。 次のガイドを参照してください: のデータセットの有効化 Profile を参照してください。

  • 新しい ID をリンクする必要がある場合は、追加のデータセットも作成する必要があります 同じスキーマを使用 の Profile データセット。

  • データセットを準備したら、データフローを作成して、受信リクエストを Profile データセット;

  • 次に、受信リクエストを更新して、必要なヘッダーを含める必要があります。 次のヘッダーで定義されます。

    • を使用して実行する必要があるデータ操作 Profile: create, merge、および delete.
    • 実行するオプションの ID 操作 Identity Service: create.

ID データセットの設定

新しい ID をリンクする必要がある場合は、受信ペイロードで追加のデータセットを作成して渡す必要があります。 ID データセットを作成する場合は、次の要件が満たされていることを確認する必要があります。

  • ID データセットには、 Profile データセット。 スキーマが一致しないと、システムの動作に一貫性がなくなる場合があります。
  • ただし、ID データセットが Profile データセット。 データセットが同じ場合、データは更新されずに上書きされます。
  • 最初のデータセットを有効にする必要があるのは、 Profile、ID データセット は有効ではありません 対象: Profile. そうしないと、データが更新されずに上書きされます。 ただし、ID データセットは 有効にする必要がある 対象: Identity Service.

ID データセットに関連付けられたスキーマ内の必須フィールド identity-dataset-required-fileds

スキーマに必須フィールドが含まれている場合、を有効にするには、データセットの検証を抑制する必要があります Identity Service :id のみを受け取ります。 検証を無効にするには、 disabled 値を acp_validationContext パラメーター。 次の例を参照してください。

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"
        ]
    }
}'
TIP
ID データセットに関連付けられているスキーマに必須フィールドがない場合は、追加の設定をおこなう必要はありません。

受信ペイロード構造

次の例は、新しい ID リンクを確立する受信ペイロード構造の例です。

ID 設定を含むペイロード

{
  "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.
}
パラメーター
説明
flowId
データフローを識別する一意の ID。 このデータフロー ID は、 Amazon Kinesis, Azure Event Hubsまたは HTTP API. また、このデータフローには、 Profile-enabled データセットをターゲットデータセットとして使用します。 注意: Profile有効なターゲットデータセットも datasetId パラメーター。
imsOrgId
組織に対応する ID。
datasetId
の ID Profile-enabled データフローのターゲットデータセット。 注意:これは、 Profileデータフロー内で有効なターゲットデータセット ID が見つかりました。
operations
このパラメーターでは、 Data Prep は、受信リクエストに基づいて実行されます。
operations.data
で実行する必要があるアクションを定義します。 Real-Time Customer Profile.
operations.identity
データに対して許可する操作を次のように定義します。 Identity Service.
operations.identityDatasetId
(オプション)新しい ID をリンクする必要がある場合にのみ必要な ID データセットの ID。

サポートされている操作

次の操作は、 Real-Time Customer Profile:

運用
説明
create
デフォルトの操作です。 これにより、の XDM エンティティ作成メソッドが生成されます。 Real-Time Customer Profile.
merge
これにより、の XDM エンティティ更新メソッドが生成されます。 Real-Time Customer Profile.
delete
これにより、の XDM エンティティ削除メソッドが生成されます。 Real-Time Customer Profile を削除し、 Profile Store.

次の操作は、 Identity Service:

運用
説明
create
このパラメーターに対して許可される唯一の操作です。 次の場合 createoperations.identityを、 Data Prep 次の XDM エンティティ作成リクエストを生成します: Identity Service. ID が既に存在する場合、ID は無視されます。 注意: 次の場合 operations.identitycreateを、 identityDatasetId また、を指定する必要があります。 XDM エンティティは、 Data Prep このデータセット id に対してコンポーネントが生成されます。

ID 設定のないペイロード

新しい ID をリンクする必要がない場合は、 identity および identityDatasetId パラメーターを使用します。 これにより、にのみデータが送信されます。 Real-Time Customer Profile そしてスキップする Identity Service. 以下の例のペイロードを参照してください。

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

プライマリ ID の動的な引き渡し

XDM の更新の場合、スキーマを有効にする必要があります。 Profile にはプライマリ id が含まれています。 XDM スキーマのプライマリ ID は、次の 2 つの方法で指定できます。

  • 静的フィールドを XDM スキーマのプライマリ ID として指定する。
  • XDM スキーマの ID マップフィールドグループを使用して、いずれかの ID フィールドをプライマリ ID として指定します。

静的フィールドを XDM スキーマのプライマリ ID フィールドとして指定する

次の例では、 state, homePhone.number その他の属性は、それぞれの指定された値を使用して、 Profile ~の主なアイデンティティを持つ sampleEmail@gmail.com. 次に、XDM エンティティ更新メッセージがストリーミングによって生成されます Data Prep コンポーネント。 Real-Time Customer Profile 次に、XDM 更新メッセージがプロファイルレコードをアップサートすることを確認します。

NOTE
この例では、ID に対して操作が定義されていないので、ID は相互にリンクされません。
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"
  }
}'

XDM スキーマの ID マップフィールドグループを使用して、いずれかの ID フィールドをプライマリ ID として指定します

この例では、ヘッダーに operations 属性に identity および identityDatasetId プロパティ。 これにより、データを Real-Time Customer Profile また、に渡される ID 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"
  }
 }'

既知の制限事項と主な考慮事項

次に、 Data Prep:

  • ストリーミングアップサートメソッドは、部分行の更新をに送信する場合にのみ使用してください。 Real-Time Customer Profile. 行の一部の更新は、 not データレイクによって消費されます。
  • ストリーミングアップサートメソッドでは、ID の更新、置換、削除はサポートされていません。 存在しない場合は新しい ID が作成されます。 したがって、 identity 操作は常に作成するように設定する必要があります。 ID が既に存在する場合、操作は何も実行されません。
  • 現在、ストリーミングアップサートメソッドはをサポートしていません Adobe Experience Platform Web SDK および Adobe Experience Platform Mobile SDK.

次の手順

このドキュメントを読むと、でアップサートをストリーミングする方法を理解できます。 Data Prep 部分的な行の更新を Real-Time Customer Profile データを作成し、単一の API リクエストに id を作成してリンクすることもできます。 その他の情報 Data Prep 機能、お読みください Data Prep 概要. 内でマッピングセットを使用する方法を学ぶには Data Prep API( Data Prep 開発者ガイド.

recommendation-more-help
461cc884-c234-4a0c-ac75-6efbaafc1394