---
title: "パイプラインバッチ実行"
slug: "run-pipeline-batch"
abstract: "MongoDBからXconnectへの連絡先データの移行を実行し、その結果を確認するためのガイド(xDB Data Migration Tool)。"
---
# パイプラインバッチ実行

これでパイプラインのバッチ「**MongoDB Contacts to xConnect Migration**」を実行することができます。必要なデータがMongoDBに存在すれば、xConnectの連絡先に新しい連絡先の**ファセット「LoyaltyProgram** 」が作成されます。

パイプラインバッチを実行した後、コンタクトファセットが正しく作成されているかどうかを確認する方法は複数あります。

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

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

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

SELECT ContactId, FacetKey, FacetData
 FROM xdb\_collection.ContactFacets
 WHERE FacetKey = 'LoyaltyProgram'

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

連絡先ID

FacetKey

FacetData

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

LoyaltyProgram

{"@odata.type":"#MigrationTool.Examples.Loyalty...

以下は**FacetData**の完全な数値です:

{
 "@odata.type":"#MigrationTool.Examples.Loyalty.LoyaltyProgramInfo",
 "MembershipId":100011,
 "EnrollmentDate":"1919-12-12T12:\`34:56\`.0000000Z",
 "HomeStoreId":"GARRISON01"
}
## xConnect検索

xConnectの検索APIを使って新しいファセットで連絡先を探すアプリケーションを書くことができます。

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 contacts = client.Contacts
 .Where(c => c.GetFacet<LoyaltyProgramInfo>().HomeStoreId != null)
 .GetBatchEnumeratorSync();
 while (contacts.MoveNext())
 {
 foreach (var contact in contacts.Current)
 {
 var expandOptions = new ContactExpandOptions(LoyaltyProgram.DefaultFacetKey);
 var fullContact = await client.GetAsync<Contact>(contact, expandOptions);
 var loyaltyProgramInfoFacet = fullContact.GetFacet<LoyaltyProgramInfo>();
 }
 }
}