部分行の更新の送信先 Real-Time Customer Profile 使用 Data Prep
アップサートのストリーミング Data Prep 部分行の更新をに送信できます Real-Time Customer Profile 単一の API リクエストで新しい ID リンクを作成および確立する際にも、データを使用します。
アップサートをストリーミングすると、データをに変換する間、データの形式を保持できます Real-Time Customer Profile 取り込み中のPATCHリクエスト。 指定した入力に基づいて、 Data Prep 単一の API ペイロードを送信し、データを両方に変換できるようにします Real-Time Customer Profile PATCHと Identity Service リクエストを作成します。
このドキュメントでは、でのアップサートのストリーミング方法について説明します 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
ストリーミングアップサートの高レベルなワークフロー
アップサートのストリーミング Data Prep は次のように動作します。
-
最初に、のデータセットを作成して有効にする必要があります Profile 消費。 のガイドを参照してください データセットの有効化 Profile を参照してください。
-
新しい ID をリンクする必要がある場合は、追加のデータセットも作成する必要があります 同じスキーマを使用 as your Profile データセット。
-
データセットの準備が整ったら、受信リクエストをにマッピングするためのデータフローを作成する必要があります。 Profile データセット；
-
次に、必要なヘッダーを含めるように受信リクエストを更新する必要があります。 これらのヘッダーは、以下を定義します。
- で実行する必要があるデータ操作 Profile:
create,merge、およびdelete. - で実行するオプションの ID 操作 Identity Service:
create.
- で実行する必要があるデータ操作 Profile:
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"
]
}
}'
受信ペイロード構造
以下に、新しい 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.
}
flowIddatasetId パラメーター。imsOrgIddatasetIdoperationsoperations.dataoperations.identityoperations.identityDatasetIdサポートされる操作
次の操作は、でサポートされています。 Real-Time Customer Profile:
createmergedelete次の操作は、でサポートされています。 Identity Service:
createcreate は、の値として渡されます。 operations.identity、次に Data Prep 次の XDM エンティティ作成リクエストを生成 Identity Service. ID が既に存在する場合、その ID は無視されます。 注意： 次の場合 operations.identity はに設定されています。 createを選択し、続いて 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 として静的フィールドを指定します。
- ID フィールドの 1 つをプライマリ ID として、XDM スキーマの ID マップフィールドグループを使用して指定します。
静的フィールドを XDM スキーマのプライマリ ID フィールドとして指定します
以下の例では、 state, homePhone.number およびその他の属性は、それぞれの指定された値でにアップサートされます。 Profile ～という主体性を持つ sampleEmail@gmail.com. 次に、ストリーミングによって XDM エンティティ更新メッセージが生成されます Data Prep コンポーネント。 Real-Time Customer Profile 次に、XDM 更新メッセージがプロファイルレコードをアップサートすることを確認します。
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"
}
}'
ID フィールドの 1 つをプライマリ ID として、XDM スキーマの 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. 部分行の更新は次のとおりです ではない データレイクで使用されます。
- ストリーミングアップサートのメソッドでは、ID の更新、置換、削除はサポートされていません。 存在しない場合は、新しい ID が作成されます。 したがって、
identity操作は常に create に設定する必要があります。 ID が既に存在する場合、操作は no-op です。 - ストリーミングアップサート方法は現在サポートされていません 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 開発者ガイド.