---
title: "パイプラインバッチ実行"
slug: "run-pipeline-batch-176484"
abstract: "xDBデータ移行ツールを使ってMongoDBからxConnectへの連絡先データの移行を実行する方法。"
---
# パイプラインバッチ実行

現在、パイプラインのバッチ処理で**MongoDB ContactsからxConnectへの移行**を実行できます。必要なデータがMongoDBに存在すれば、xConnectの連絡先に新しい連絡先識別子**Loyalty.Program**が作成されます。

パイプラインのバッチを実行した後、連絡先識別子が正しく作成されているかを確認する方法は複数あります。

## xConnectコレクションデータベース

xConnectコレクションデータベースで新しいファセットを表すレコードを確認できます。

1.  コレクションデータベースのシャードのいずれかにConnectしてください。
2.  以下のクエリを使ってください:

SELECT ContactId, Source, CONVERT(VARCHAR(MAX), Identifier) AS Identifier
 FROM xdb\_collection.ContactIdentifiers
 WHERE Source = 'Loyalty.Program'

ロイヤルティプログラムのデータが付いている各MongoDBの連絡先ごとに行が表示されるはずです。

連絡先ID

出典

識別子

########-####-####-####-############

Loyalty.Program

######

## xConnectクライアント

xConnectクライアントAPIを使って、ロイヤルティプログラムのメンバーシップIDを使って連絡先を探すアプリケーションを作成できます。

var model = new XdbRuntimeModel(CustomMigrationModel.Model);
Uri uri = ... //your xConnect server location goes here
var config = new XConnectClientConfiguration(model, uri);
await config.InitializeAsync();
using (var client = new XConnectClient(config))
{
 var identifierSource = "Loyalty.Program";
 var membershipId = "######"; //the membership id for the contact you want to get goes here
 var identifier = new IdentifiedContactReference(identifierSource, membershipId);
 var expandOptions = new ExpandOptions(LoyaltyProgramInfo.DefaultFacetKey);
 var contact = await client.GetContactAsync(identifier, expandOptions);
}