ドキュメントExperience Platformソースコネクタガイド

CRMからExperience Platformにデータを取り込むデータフローを作成する

最終更新日： 2025年10月14日

作成対象：

  • Developer

このガイドでは、Flow Service APIを使用してデータフローを作成し、Adobe Experience Platformにデータを取り込む方法について説明します。

基本を学ぶ

このガイドは、Adobe Experience Platform の次のコンポーネントを実際に利用および理解しているユーザーを対象としています。

Experience Platform APIの使用

Experience Platform APIを正常に呼び出す方法について詳しくは、Experience Platform APIの概要に関するガイドを参照してください。

ベース接続の作成 base

ソースのデータフローを作成するには、完全に認証されたソースアカウントとそれに対応するベース接続IDが必要です。 このIDがない場合は、​ ソースカタログ ​にアクセスして、ベース接続を作成できるソースのリストを見つけます。

ターゲット XDM スキーマの作成 target-schema

Experience Data Model （XDM）スキーマは、Experience Platform内の顧客体験データを整理および記述するための標準化された方法を提供します。 ソースデータをExperience Platformに取り込むには、まず、取り込むデータの構造とタイプを定義するターゲット XDM スキーマを作成する必要があります。 このスキーマは、取り込んだデータが格納されるExperience Platform データセットの設計図として機能します。

Schema Registry API に POST リクエストを実行することで、ターゲット XDM スキーマを作成できます。 ターゲット XDM スキーマの作成方法について詳しくは、次のガイドを参照してください。

  • APIを使用してスキーマを作成します。
  • UIを使用してスキーマを作成します。

作成したターゲット XDM スキーマ $idは、後でターゲットデータセットとマッピングに必要になります。

ターゲットデータセットの作成 target-dataset

データセットは、データのコレクションのための保存および管理構造体です。通常、列（スキーマ）と行（フィールド）を持つテーブルのように構造化されます。 Experience Platform に正常に取り込まれたデータは、データレイク内にデータセットとして保存されます。 この手順では、新しいデータセットを作成するか、既存のデータセットを使用できます。

ペイロード内でターゲットスキーマのIDを指定しながら、​ カタログサービス APIにPOST リクエストを行うことで、ターゲットデータセットを作成できます。 ターゲットデータセットの作成方法について詳しくは、APIを使用したデータセットの作成に関するガイドを参照してください。

TIP
データをリアルタイム顧客プロファイルに取り込む場合は、ターゲット XDM スキーマとターゲットデータセットの両方がプロファイルに対して有効になっていることを確認する必要があります。
選択してサンプルを表示

API 形式

code language-http 
POST /dataSets

リクエスト

次の例は、リアルタイム顧客プロファイルの取り込みが有効なターゲットデータセットを作成する方法を示しています。 このリクエストでは、unifiedProfile プロパティがtrueに設定され（tags オブジェクトの下）、Experience Platformに対して、データセットをReal-Time Customer Profileに含めるように指示します。

code language-shell 
curl -X POST \
  'https://platform.adobe.io/data/foundation/catalog/dataSets' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
    "name": "ACME Target Dataset",
    "schemaRef": {
      "id": "https://ns.adobe.com/{TENANT_ID}/schemas/719c4e19184402c27595e65b931a142b",
      "contentType": "application/vnd.adobe.xed+json;version=1"
    },
    "tags": {
      "unifiedProfile": [
        "enabled: true"
      ]
    }
  }'
table 0-row-2 1-row-2 2-row-2 3-row-2
プロパティ 説明
name ターゲットデータセットのわかりやすい名前。 明確で一意の名前を付けることで、今後の運用でデータセットを容易に特定および管理できます。
schemaRef.id ターゲット XDM スキーマのID。
tags.unifiedProfile データをReal-Time Customer Profileに取り込む必要があるかどうかをExperience Platformに通知するブール値。

応答

応答が成功すると、ターゲットデータセットのIDが返されます。 このIDは、後でターゲット接続を作成するために必要です。

code language-json 
[
    "@/dataSets/6889f4f89b982b2b90bc1207"
]

ソース接続の作成 source

ソース接続は、外部ソースからExperience Platformにデータを取り込む方法を定義します。 ソースシステムと受信データの形式の両方を指定し、認証の詳細を含むベース接続を参照します。 各ソース接続は、組織に固有です。

  • ファイルベースのソース（クラウドストレージなど）の場合、ソース接続には、列区切り、エンコーディングタイプ、圧縮タイプ、ファイル選択用の正規表現、ファイルを再帰的に取り込むかどうかなどの設定を含めることができます。
  • テーブルベースのソース（データベース、CRM、マーケティングオートメーションプロバイダーなど）の場合、ソース接続はテーブル名や列マッピングなどの詳細を指定できます。

ソース接続を作成するには、Flow Service APIの/sourceConnections エンドポイントにPOST リクエストを行い、ベース接続ID、接続仕様ID、およびソースデータファイルへのパスを指定します。

API 形式

POST /sourceConnections

リクエスト

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
    "name": "ACME source connection",
    "description": "A source connection for ACME contact data",
    "baseConnectionId": "6990abad-977d-41b9-a85d-17ea8cf1c0e4",
    "data": {
      "format": "tabular"
    },
    "params": {
      "tableName": "Contact",
      "columns": [
        {
          "name": "TestID",
          "type": "string",
          "xdm": {
            "type": "string"
          }
        },
        {
          "name": "Name",
          "type": "string",
          "xdm": {
            "type": "string"
          }
        },
        {
          "name": "Datefield",
          "type": "string",
          "meta:xdmType": "date-time",
          "xdm": {
            "type": "string",
            "format": "date-time"
          }
        }
      ]
    },
    "connectionSpec": {
      "id": "cfc0fee1-7dc0-40ef-b73e-d8b134c436f5",
      "version": "1.0"
    }
  }'
プロパティ
説明
name
ソース接続のわかりやすい名前。 明確で一意の名前を使用することで、今後の運用における接続の識別と管理が容易になります。
description
ソース接続の追加情報を提供するために追加できるオプションの説明。
baseConnectionId
ベース接続のid。 このIDは、Flow Service APIを使用してExperience Platformに対するソースを認証することで取得できます。
data.format
データの形式。 テーブルベースのソース（データベース、CRM、マーケティングオートメーションプロバイダーなど）に対しては、この値をtabularに設定します。
params.tableName
Experience Platformに取り込むソースアカウント内のテーブルの名前。
params.columns
Experience Platformに取り込むデータの特定のテーブル列。
connectionSpec.id
使用しているソースの接続仕様ID。

応答

応答が成功すると、ソース接続のIDが返されます。 このIDは、データフローを作成し、データを取り込むために必要です。

{
    "id": "b7581b59-c603-4df1-a689-d23d7ac440f3",
    "etag": "\"ef05d265-0000-0200-0000-6019e0080000\""
}

ターゲット接続の作成 target

ターゲット接続は、取り込まれたデータが取り込まれる宛先への接続を表します。 ターゲット接続を作成するには、データレイクに関連付けられた固定接続仕様IDを指定する必要があります。 この接続仕様IDはc604ff05-7f1a-43c0-8e18-33bf874cb11cです。

API 形式

POST /targetConnections

リクエスト

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/targetConnections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "ACME target connection",
      "description": "ACME target connection",
      "data": {
          "schema": {
              "id": "https://ns.adobe.com/{TENANT_ID}/schemas/52b59140414aa6a370ef5e21155fd7a686744b8739ecc168",
              "version": "application/vnd.adobe.xed-full+json;version=1"
          }
      },
      "params": {
          "dataSetId": "6889f4f89b982b2b90bc1207"
      },
      "connectionSpec": {
          "id": "c604ff05-7f1a-43c0-8e18-33bf874cb11c",
          "version": "1.0"
      }
    }'
プロパティ
説明
name
ターゲット接続のわかりやすい名前。 明確で一意の名前を使用することで、今後の運用における接続の識別と管理が容易になります。
description
ターゲット接続に追加情報を提供するために追加できるオプションの説明。
data.schema.id
ターゲット XDM スキーマのID。
params.dataSetId
ターゲットデータセットのID。
connectionSpec.id
データレイクの接続仕様ID。 このIDは修正されています：c604ff05-7f1a-43c0-8e18-33bf874cb11c。

マッピング mapping

次に、ソースデータを、ターゲットデータセットが準拠するターゲットスキーマにマッピングします。 マッピングを作成するには、Data Prep APIのmappingSets エンドポイントにPOST リクエストを行います。 ターゲット XDM スキーマ IDと、作成するマッピングセットの詳細を含めます。

API 形式

POST /mappingSets

リクエスト

curl -X POST \
  'https://platform.adobe.io/data/foundation/conversion/mappingSets' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "version": 0,
      "xdmSchema": "https://ns.adobe.com/{TENANT_ID}/schemas/52b59140414aa6a370ef5e21155fd7a686744b8739ecc168",
      "xdmVersion": "1.0",
      "id": null,
      "mappings": [
          {
              "destinationXdmPath": "_id",
              "sourceAttribute": "TestID",
              "identity": false,
              "identityGroup": null,
              "namespaceCode": null,
              "version": 0
          },
          {
              "destinationXdmPath": "person.name.fullName",
              "sourceAttribute": "Name",
              "identity": false,
              "identityGroup": null,
              "namespaceCode": null,
              "version": 0
          },
          {
              "destinationXdmPath": "person.birthDate",
              "sourceAttribute": "Datefield",
              "identity": false,
              "identityGroup": null,
              "namespaceCode": null,
              "version": 0
          }
      ]
  }'
プロパティ
説明
xdmSchema
ターゲット XDM スキーマの $id。

応答

応答が成功すると、一意の ID（id）など、新しく作成されたマッピングの詳細が返されます。 この ID は、後の手順でデータフローを作成する際に必要になります。

{
    "id": "93ddfa69c4864d978832b1e5ef6ec3b9",
    "version": 0,
    "createdDate": 1612309018666,
    "modifiedDate": 1612309018666,
    "createdBy": "{CREATED_BY}",
    "modifiedBy": "{MODIFIED_BY}"
}

データフロー仕様の取得 flow-specs

データフローを作成する前に、まずソースに対応するデータフローの仕様を取得する必要があります。 この情報を取得するには、Flow Service APIの/flowSpecs エンドポイントにGET リクエストを行います。

API 形式

GET /flowSpecs?property=name=="{NAME}"
クエリパラメーター
説明
property=name=="{NAME}"

データフロー仕様の名前。

  • ファイルベースのソース（クラウドストレージなど）の場合は、この値をCloudStorageToAEPに設定します。
  • テーブルベースのソース（データベース、CRM、マーケティングオートメーションプロバイダーなど）の場合は、この値をCRMToAEPに設定します。

リクエスト

curl -X GET \
  'https://platform.adobe.io/data/foundation/flowservice/flowSpecs?property=name=="CRMToAEP"' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}'

応答

応答が成功すると、ソースからExperience Platformにデータを取り込むデータフロー仕様の詳細が返されます。 応答には、新しいデータフローを作成するために必要な、一意のフロー仕様 id が含まれます。

正しいデータフロー仕様を使用していることを確認するには、応答のitems.sourceConnectionSpecIds配列を確認します。 ソースの接続仕様IDがこのリストに含まれていることを確認します。

選択して表示
code language-json 
{
    "items": [
        {
            "id": "14518937-270c-4525-bdec-c2ba7cce3860",
            "name": "CRMToAEP",
            "providerId": "0ed90a81-07f4-4586-8190-b40eccef1c5a",
            "version": "1.0",
            "sourceConnectionSpecIds": [
                "3416976c-a9ca-4bba-901a-1f08f66978ff",
                "38ad80fe-8b06-4938-94f4-d4ee80266b07",
                "d771e9c1-4f26-40dc-8617-ce58c4b53702",
                "3c9b37f8-13a6-43d8-bad3-b863b941fedd",
                "cc6a4487-9e91-433e-a3a3-9cf6626c1806",
                "3000eb99-cd47-43f3-827c-43caf170f015",
                "26d738e0-8963-47ea-aadf-c60de735468a",
                "74a1c565-4e59-48d7-9d67-7c03b8a13137",
                "cfc0fee1-7dc0-40ef-b73e-d8b134c436f5",
                "4f63aa36-bd48-4e33-bb83-49fbcd11c708",
                "cb66ab34-8619-49cb-96d1-39b37ede86ea",
                "eb13cb25-47ab-407f-ba89-c0125281c563",
                "1f372ff9-38a4-4492-96f5-b9a4e4bd00ec",
                "37b6bf40-d318-4655-90be-5cd6f65d334b",
                "a49bcc7d-8038-43af-b1e4-5a7a089a7d79",
                "a8b6a1a4-5735-42b4-952c-85dce0ac38b5",
                "6a8d82bc-1caf-45d1-908d-cadabc9d63a6",
                "aac9bbd4-6c01-46ce-b47e-51c6f0f6db3f",
                "8e6b41a8-d998-4545-ad7d-c6a9fff406c3",
                "ecde33f2-c56f-46cc-bdea-ad151c16cd69",
                "09182899-b429-40c9-a15a-bf3ddbc8ced7",
                "0479cc14-7651-4354-b233-7480606c2ac3",
                "d6b52d86-f0f8-475f-89d4-ce54c8527328",
                "a8f4d393-1a6b-43f3-931f-91a16ed857f4",
                "fcad62f3-09b0-41d3-be11-449d5a621b69",
                "ea1c2a08-b722-11eb-8529-0242ac130003",
                "35d6c4d8-c9a9-11eb-b8bc-0242ac130003",
                "b2e08744-4f1a-40ce-af30-7abac3e23cf3",
                "2acf109f-9b66-4d5e-bc18-ebb2adcff8d5",
                "2fa8af9c-2d1a-43ea-a253-f00a00c74412",
                "e9d7ec6b-0873-4e57-ad21-b3a7c65e310b"
            ],
            "targetConnectionSpecIds": [
                "c604ff05-7f1a-43c0-8e18-33bf874cb11c"
            ],
            "optionSpec": {
                "name": "OptionSpec",
                "spec": {
                    "$schema": "http://json-schema.org/draft-07/schema#",
                    "type": "object",
                    "properties": {
                        "errorDiagnosticsEnabled": {
                            "title": "Error diagnostics.",
                            "description": "Flag to enable detailed and sample error diagnostics summary.",
                            "type": "boolean",
                            "default": false
                        },
                        "partialIngestionPercent": {
                            "title": "Partial ingestion threshold.",
                            "description": "Percentage which defines the threshold of errors allowed before the run is marked as failed.",
                            "type": "number",
                            "exclusiveMinimum": 0
                        }
                    }
                }
            },
            "transformationSpecs": [
                {
                    "name": "Copy",
                    "spec": {
                        "$schema": "http://json-schema.org/draft-07/schema#",
                        "type": "object",
                        "properties": {
                            "deltaColumn": {
                                "type": "object",
                                "properties": {
                                    "name": {
                                        "type": "string"
                                    },
                                    "dateFormat": {
                                        "type": "string"
                                    },
                                    "timezone": {
                                        "type": "string"
                                    }
                                },
                                "required": [
                                    "name"
                                ]
                            }
                        },
                        "required": [
                            "deltaColumn"
                        ]
                    }
                },
                {
                    "name": "Mapping",
                    "spec": {
                        "$schema": "http://json-schema.org/draft-07/schema#",
                        "type": "object",
                        "description": "defines various params required for different mapping from source to target",
                        "properties": {
                            "mappingId": {
                                "type": "string"
                            },
                            "mappingVersion": {
                                "type": "string"
                            }
                        }
                    }
                }
            ],
            "scheduleSpec": {
                "name": "PeriodicSchedule",
                "type": "Periodic",
                "spec": {
                    "$schema": "http://json-schema.org/draft-07/schema#",
                    "type": "object",
                    "properties": {
                        "startTime": {
                            "description": "epoch time",
                            "type": "integer"
                        },
                        "frequency": {
                            "type": "string",
                            "enum": [
                                "once",
                                "minute",
                                "hour",
                                "day",
                                "week"
                            ]
                        },
                        "interval": {
                            "type": "integer"
                        },
                        "backfill": {
                            "type": "boolean",
                            "default": true
                        }
                    },
                    "required": [
                        "startTime",
                        "frequency"
                    ],
                    "if": {
                        "properties": {
                            "frequency": {
                                "const": "once"
                            }
                        }
                    },
                    "then": {
                        "allOf": [
                            {
                                "not": {
                                    "required": [
                                        "interval"
                                    ]
                                }
                            },
                            {
                                "not": {
                                    "required": [
                                        "backfill"
                                    ]
                                }
                            }
                        ]
                    },
                    "else": {
                        "required": [
                            "interval"
                        ],
                        "if": {
                            "properties": {
                                "frequency": {
                                    "const": "minute"
                                }
                            }
                        },
                        "then": {
                            "properties": {
                                "interval": {
                                    "minimum": 15
                                }
                            }
                        },
                        "else": {
                            "properties": {
                                "interval": {
                                    "minimum": 1
                                }
                            }
                        }
                    }
                }
            },
            "runSpec": {
                "name": "ProviderParams",
                "spec": {
                    "$schema": "http://json-schema.org/draft-07/schema#",
                    "type": "object",
                    "description": "defines various params required for creating flow run.",
                    "properties": {
                        "startTime": {
                            "type": "integer",
                            "description": "An integer that defines the start time of the run. The value is represented in Unix epoch time."
                        },
                        "windowStartTime": {
                            "type": "integer",
                            "description": "An integer that defines the start time of the window against which data is to be pulled. The value is represented in Unix epoch time."
                        },
                        "windowEndTime": {
                            "type": "integer",
                            "description": "An integer that defines the end time of the window against which data is to be pulled. The value is represented in Unix epoch time."
                        },
                        "deltaColumn": {
                            "type": "object",
                            "description": "The delta column is required to partition the data and separate newly ingested data from historic data.",
                            "properties": {
                                "name": {
                                    "type": "string"
                                },
                                "dateFormat": {
                                    "type": "string"
                                },
                                "timezone": {
                                    "type": "string"
                                }
                            },
                            "required": [
                                "name"
                            ]
                        }
                    },
                    "required": [
                        "startTime",
                        "windowStartTime",
                        "windowEndTime",
                        "deltaColumn"
                    ]
                }
            },
            "attributes": {
                "recordTypeEnabled": true,
                "defaultRecordType": "profile",
                "isSourceFlow": true,
                "flacValidationSupported": true,
                "isDraftModeSupported": true,
                "frequency": "batch",
                "notification": {
                    "category": "sources",
                    "flowRun": {
                        "enabled": true
                    }
                }
            },
            "permissionsInfo": {
                "manage": [
                    {
                        "@type": "lowLevel",
                        "name": "EnterpriseSource",
                        "permissions": [
                            "write"
                        ]
                    }
                ],
                "view": [
                    {
                        "@type": "lowLevel",
                        "name": "EnterpriseSource",
                        "permissions": [
                            "read"
                        ]
                    }
                ]
            }
        }
    ]
}

データフローの作成 dataflow

データフローとは、Experience Platform サービス間でデータを転送するように設定されたパイプラインです。 データベース、クラウドストレージ、APIなどの外部ソースからデータを取り込み、処理し、ターゲットデータセットにルーティングする方法を定義します。 これらのデータセットは、ID サービス、リアルタイム顧客プロファイル、宛先などのサービスで活用され、アクティベーションや分析に利用されます。

データフローを作成するには、次の項目の値を指定する必要があります。

この手順では、scheduleParamsで次のパラメーターを使用して、データフローの取り込みスケジュールを設定できます。

スケジューリングパラメーター
説明
startTime
データフローを開始するエポック時間（秒単位）。
frequency

取り込む頻度。 データフローを実行する頻度を指定する頻度を設定します。 頻度は次のように設定できます。

  • once: 1回限りの取り込みを作成するには、頻度をonceに設定します。 インターバルとバックフィルの設定は、1回限りの取り込みジョブでは使用できません。 デフォルトでは、スケジュール頻度は1回に設定されます。
  • minute:1分ごとにデータフローを取り込むようにスケジュールする頻度をminuteに設定します。
  • hour:1時間ごとにデータフローを取り込むようにスケジュールする頻度をhourに設定します。
  • day: 1日ごとにデータフローを取り込むようにスケジュールする頻度をdayに設定します。
  • week：週ごとにデータフローを取り込むようにスケジュールする頻度をweekに設定します。
interval

連続した取り込みの間隔（onceを除くすべての周波数に必要）。 インターバル設定を設定して、取り込みごとに時間枠を設定します。 例えば、頻度が日に設定され、間隔が15の場合、データフローは15日ごとに実行されます。 間隔を0に設定することはできません。 各周波数に対して許容される最小区間値は次のとおりです。

  • once: n/a
  • minute: 15
  • hour: 1
  • day: 1
  • week: 1
backfill
startTimeより前に履歴データを取り込むかどうかを示します。

API 形式

POST /flows

リクエスト

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/flows' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "ACME Contact Dataflow",
      "description": "A dataflow for ACME contact data",
      "flowSpec": {
          "id": "14518937-270c-4525-bdec-c2ba7cce3860",
          "version": "1.0"
      },
      "sourceConnectionIds": [
          "b7581b59-c603-4df1-a689-d23d7ac440f3"
      ],
      "targetConnectionIds": [
          "320f119a-5ac1-4ab1-88ea-eb19e674ea2e"
      ],
      "transformations": [
          {
              "name": "Copy",
              "params": {
                  "deltaColumn": {
                      "name": "Datefield",
                      "dateFormat": "YYYY-MM-DD",
                      "timezone": "UTC"
                  }
              }
          },
          {
              "name": "Mapping",
              "params": {
                  "mappingId": "93ddfa69c4864d978832b1e5ef6ec3b9",
                  "mappingVersion": 0
              }
          }
      ],
      "scheduleParams": {
          "startTime": "1612310466",
          "frequency":"minute",
          "interval":"15",
          "backfill": "true"
      }
  }'
プロパティ
説明
name
データフローのわかりやすい名前。 明確で一意の名前を使用することで、今後の運用でデータフローを容易に特定および管理できます。
description
データフローに追加情報を提供するために追加できるオプションの説明。
flowSpec.id
ソースに対応するフロー仕様のID。
sourceConnectionIds
前の手順で生成されたソース接続ID。
targetConnectionIds
前の手順で生成されたターゲット接続ID。
transformations.params.deltaColum
新しいデータと既存のデータを区別するために使用する、指定の列。 増分データは、選択した列のタイムスタンプに基づいて取り込まれます。 deltaColumn でサポートされている形式は yyyy-MM-dd HH:mm:ss です。 Microsoft Dynamicsの場合、deltaColumnでサポートされている形式はyyyy-MM-ddTHH:mm:ssZです。
transformations.params.deltaColumn.dateFormat
デルタ列の日付形式。
transformations.params.deltaColumn.timeZone
差分列の値を解釈する際に使用するタイムゾーン。
transformations.params.mappingId
前の手順で生成されたマッピング ID。
scheduleParams.startTime
データフローの開始時間（エポック時間（Unix エポックからの秒数）。 データフローの最初の実行を開始するタイミングを指定します。
scheduleParams.frequency
データフローが実行される頻度。 指定できる値は、once、minute、hour、day、week です。
scheduleParams.interval
選択した頻度に基づいて、連続したデータフロー実行の間隔。 0以外の整数にする必要があります。 例えば、頻度が分に設定され、間隔が15の場合、データフローは15分ごとに実行されます。
scheduleParams.backfill
データフローが最初に作成されたときに履歴データ （バックフィル）を取り込むかどうかを決定するブール値（trueまたはfalse）。

応答

リクエストが成功した場合は、新しく作成したデータフローの ID（id）が返されます。

{
    "id": "ae0a9777-b322-4ac1-b0ed-48ae9e497c7e",
    "etag": "\"770029f8-0000-0200-0000-6019e7d40000\""
}

UIを使用してAPI ワークフローを検証する validate-in-ui

Experience Platform ユーザーインターフェイスを使用して、データフローの作成を検証できます。 Experience Platform UIの​ソース カタログに移動し、ヘッダータブから「データフロー」を選択します。 次に、​ データフロー名列を使用し、Flow Service APIを使用して作成したデータフローを見つけます。

Experience Platform UI のソースワークスペースのデータフローインターフェイス

​ データフローアクティビティ ​ インターフェイスを使用して、データフローをさらに検証できます。 右側のパネルを使用して、データフローのAPI使用状況情報を表示します。 このセクションには、Flow Serviceのデータフロー作成プロセス中に生成された同じデータフローID、データセット ID、およびマッピング IDが表示されます。

​ ソースワークスペースのデータフロー表示ページ。

次の手順

このチュートリアルでは、Flow Service APIを使用してExperience Platformでデータフローを作成するプロセスについて説明しました。 ターゲット XDM スキーマ、データセット、ソース接続、ターゲット接続、データフロー自体など、必要なコンポーネントを作成および設定する方法を学習しました。 次の手順に従うことで、外部ソースからExperience Platformへのデータの取り込みを自動化でき、Real-Time Customer ProfileやDestinationsなどのダウンストリームサービスを利用して、取り込んだデータを高度なユースケースに活用できるようになります。

データフローの監視

データフローを作成したら、Experience Platform UIでそのパフォーマンスを直接監視できます。 これには、取り込み率、成功指標、発生したエラーの追跡が含まれます。 データフローの監視方法について詳しくは、​ アカウントとデータフローの監視に関するチュートリアルを参照してください。

データフローの更新

データフローのスケジュール、マッピング、または一般的な情報の設定を更新するには、​ ソースデータフローの更新に関するチュートリアルを参照してください。

データフローの削除

データフロー ワークスペースで使用できる​ 削除 ​関数を使用して、不要になった、または誤って作成されたデータフローを削除できます。 データフローの削除方法について詳しくは、​ データフローの削除に関するチュートリアルを参照してください。

recommendation-more-help
experience-platform-help-sources