0 / 0
資料の 英語版 に戻る
データ統合チュートリアル: データの複製

データ統合チュートリアル: データの複製

このチュートリアルでは、データ・ファブリック試用のデータ統合ユース・ケースを使用して、ソース・データ・ストアとターゲット・データ・ストアの間のデータ複製をセットアップします。 目標は、 Data Replication を使用して、ソース・データベースからゴールデン・バンクの Event Streams インスタンスへの効率的なデータ・キャプチャーを使用して、ほぼリアルタイムの継続的なレプリケーション・フィードをセットアップすることで、プロバイダーの Db2 on Cloud データ・ソースからのクレジット・スコア情報を統合することです。 Event Streams は、 Apache Kafkaを使用して構築された高スループットのメッセージ・バスです。 これは、IBM Cloud へのイベントの取り込みと、ご使用のサービスとアプリケーションの間でのイベント・ストリームの配信に最適化されています。 Event Streamsについて詳しくは、「 詳細情報 」セクションを参照してください。

クイック・スタート: このチュートリアル用のサンプル・プロジェクトをまだ作成していない場合は、リソース・ハブの データ統合サンプル・プロジェクト にアクセスします。

このチュートリアルでは、ゴールデン・バンクは、適格性を満たしていないローン申請者には融資できないという新しい規制を遵守する必要があると説明しています。 ゴールデン・バンクのデータ・エンジニアは、ローン申請者の最新のクレジット・スコアへのアクセスを提供する必要があります。 これらのクレジット・スコアは、外部プロバイダーが所有する Db2 on Cloud データベースから取得され、ゴールデン・バンクの Event Streams ハブに継続的に配信されます。 Event Streams ハブ内のデータは、適格申請者のローン承認を決定するために、住宅ローン申請者のクレジット・スコアを検索するためにアプリケーションによって使用されます。

以下のアニメーション化されたイメージは、チュートリアルの終わりまでに実行する内容のクイック・プレビューを提供します。 イメージをクリックすると、より大きなイメージが表示されます。

アニメーション化されたイメージ

チュートリアルをプレビューする

このチュートリアルでは、以下のタスクを実行します:

ビデオを見る このチュートリアルのステップをプレビューするには、このビデオをご覧ください。 ビデオに表示されるユーザー・インターフェースには若干の違いがある場合があります。 このビデオは、作成されたチュートリアルと一緒に使用することを目的としています。

このビデオは、本書の概念とタスクを学習するためのビジュアル・メソッドを提供します。





このチュートリアルを完了するためのヒントこのチュートリアルを正常に完了するためのヒントを以下に示します。

ビデオ・ピクチャー・イン・ピクチャーの使用

ヒント: ビデオを開始してから、チュートリアルをスクロールすると、ビデオはピクチャー・イン・ピクチャー・モードに移行します。 ピクチャー・イン・ピクチャーを最大限に活用するには、ビデオの目次を閉じます。 ピクチャー・イン・ピクチャー・モードを使用して、このチュートリアルのタスクを完了する際にビデオをフォローすることができます。 後続の各タスクのタイム・スタンプをクリックします。

以下のアニメーション・イメージは、ビデオ・ピクチャー・イン・ピクチャーおよび目次機能の使用方法を示しています。

ピクト・イン・ピクチャーおよび章の使用法

コミュニティーでのヘルプの利用

このチュートリアルでヘルプが必要な場合は、 Cloud Pak for Data コミュニティー・ディスカッション・フォーラムで質問したり、回答を見つけたりすることができます。

ブラウザー・ウィンドウのセットアップ

このチュートリアルを最適に実行するには、1 つのブラウザー・ウィンドウで Cloud Pak for Data を開き、このチュートリアル・ページを別のブラウザー・ウィンドウで開いたままにして、2 つのアプリケーションを簡単に切り替えることができます。 2 つのブラウザー・ウィンドウを横並びに配置して、見やすくすることを検討してください。

横並びのチュートリアルと UI

ヒント: ユーザー・インターフェースでこのチュートリアルを実行しているときにガイド・ツアーが表示された場合は、 「後で行うこともあります」をクリックします。



前提条件のセットアップ

Cloud Pak for Data as a Service への登録

Cloud Pak for Data as a Service に登録し、データ統合ユース・ケースに必要なサービスをプロビジョンする必要があります。

  • 既存の Cloud Pak for Data as a Service アカウントがある場合は、このチュートリアルを開始できます。 ライト・プランのアカウントを持っている場合、このチュートリアルを実行できるのはアカウントごとに 1 人のユーザーのみです。
  • Cloud Pak for Data as a Service アカウントがまだない場合は、 データ・ファブリックのトライアルに登録してください。

ビデオを見る 以下のビデオを視聴して、 Cloud Pak for Dataのデータ・ファブリックについて確認してください。

このビデオは、本書の概念とタスクを学習するためのビジュアル・メソッドを提供します。

必要なプロビジョン済みサービスの確認

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 01:29から始まるビデオをご覧ください。

重要: Data Replication は、ダラス・リージョンでのみ使用可能です。 必要に応じて、続行する前にダラス地域に切り替えてください。

必要なサービスを検証またはプロビジョンするには、以下の手順を実行します。

  1. Cloud Pak for Dataで、ダラス・リージョンにいることを確認します。 そうでない場合は、地域ドロップダウンをクリックして、 「ダラス」を選択します。
    リージョンの変更

  2. Cloud Pak for Data のナビゲーション・メニュー ナビゲーション・メニューから、 「サービス」>「サービス・インスタンス」を選択します。

  3. 「製品」 ドロップダウン・リストを使用して、既存の Data Replication サービス・インスタンスが存在するかどうかを判別します。

  4. Data Replication サービス・インスタンスを作成する必要がある場合は、 「サービスの追加」をクリックします。

    1. Data Replicationを選択してください。

    2. 「ライト」 プランを選択します。

    3. 「作成」 をクリックします。

  5. Data Replication サービスがプロビジョンされるまでお待ちください。完了するまでに数分かかる場合があります。

  6. これらのステップを繰り返して、以下の追加サービスを確認またはプロビジョニングします:

    • Watson Studio
    • Cloud Object Storage
    • Event Streams - IBM Cloud アカウントへのログインを求めるプロンプトが表示される場合があります。

チェックポイント・アイコン 進行状況を確認してください

以下のイメージは、プロビジョンされたサービス・インスタンスを示しています。 これで、サンプル・プロジェクトを作成する準備ができました。

プロビジョンされたサービス

サンプル・プロジェクトを作成する

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 02:19から始まるビデオをご覧ください。

このチュートリアルのサンプル・プロジェクトが既にある場合は、 タスク 1にスキップします。 そうでない場合は、以下のステップに従ってください。

  1. リソース・ハブの データ統合チュートリアルのサンプル・プロジェクト にアクセスします。

  2. 「プロジェクトの作成」をクリックします。

  3. プロジェクトを Cloud Object Storage インスタンスに関連付けるように求められたら、リストから Cloud Object Storage インスタンスを選択してください。

  4. 「作成」 をクリックします。

  5. プロジェクトのインポートが完了するまで待ってから、 「新規プロジェクトの表示」 をクリックして、プロジェクトと資産が正常に作成されたことを確認します。

  6. 「資産」 タブをクリックして、接続、接続されたデータ資産、およびノートブックを表示します。

注: このユース・ケースに含まれているチュートリアルを示すガイド・ツアーが表示される場合があります。 ガイド・ツアーのリンクから、これらのチュートリアルの説明が開きます。

チェックポイント・アイコン 進行状況を確認してください

以下の画像は、サンプル・プロジェクトの「資産」タブを示しています。 これで、チュートリアルを開始する準備ができました。

サンプル・プロジェクト




タスク 1: Event Streams のセットアップ

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 03:05から始まるビデオをご覧ください。

前提条件の一部として、新しい Event Streams インスタンスをプロビジョンしました。 次に、そのサービス・インスタンスをセットアップする必要があります。 以下の手順を実行します。

  • Db2 on Cloudでソース・データから複製されたデータを保管するためのトピックを作成します。 このトピックは、 Event Streams フローの中核です。 データは、プロデュース側アプリケーションからコンシューム側アプリケーションへとトピックを介して受け渡しされます。

  • データ複製のセットアップに必要なブートストラップ・サーバー情報を含むサンプル・コードをコピーします。

  • プロジェクト内のサービスへの接続を作成するために使用する資格情報を作成します。

  1. IBM Cloud コンソール リソース・リストに戻ります。

  2. 「統合」 セクションを展開します。

  3. Event Streams インスタンスのサービス・インスタンス名をクリックして、インスタンスの詳細を表示します。

  4. 最初に、 「トピック」 ページをクリックしてトピックを作成します。

    1. 「トピックの作成」をクリックします。

    2. 「トピック名」golden-bank-mortgageと入力します。

    3. 次へ をクリックします。

    4. 「パーティション」 セクションで、デフォルト値を受け入れて、 「次へ」をクリックします。

    5. 「メッセージ保存」 セクションで、デフォルト値を受け入れて、 「トピックの作成」をクリックします。

    6. テキスト・エディターを開き、後で使用するためにトピック名 golden-bank-mortgage をテキスト・ファイルに貼り付けます。

  5. 次に、 「トピック」 ページに戻り、 「このサービスに接続」 をクリックして接続情報を取得します。

    1. 「ブートストラップ・サーバー」 フィールドの値をコピーします。 ブートストラップ・サーバーは、プロジェクト内の Event Streams インスタンスへの接続を作成するときに必要です。

    2. 後で使用するために、ブートストラップ・サーバー値を同じテキスト・ファイルに貼り付けます。

    3. 「サンプル・コード」 タブをクリックします。

    4. 「サンプル構成プロパティー」 フィールドの値をコピーします。 このスニペットのいくつかのプロパティーを使用して、サービスに安全に接続します。

    5. 後で使用するために、サンプル・コードを同じテキスト・ファイルに貼り付けます。

    6. 「X」 をクリックして、 「このサービスへの接続」 パネルを閉じます。

  6. 最後に、資格情報を作成するために、 「サービス資格情報」 ページをクリックします。

    1. 「新規資格情報」をクリックします。

    2. デフォルト名を受け入れるか、必要に応じて変更します。

    3. 「役割」で、デフォルト値の 「マネージャー」を受け入れます。

    4. 「拡張オプション」 セクションを展開します。

    5. 「サービス ID の選択」 フィールドで、 「自動生成」を選択します。

    6. 追加 をクリックします。

    7. 新しい資格情報の横にある 「クリップボードにコピー」 アイコンをクリックします。

    8. 後で使用するために、資格情報を同じテキスト・ファイルに貼り付けます。

テキスト・ファイルには、以下のすべての情報が含まれている必要があります。

TOPIC NAME: golden-bank-mortgage

BOOTSTRAP SERVER FIELD
broker-5-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-1-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-2-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-0-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-3-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-4-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093

SAMPLE CODE
bootstrap.servers=broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="token" password="<APIKEY>";
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
ssl.protocol=TLSv1.2
ssl.enabled.protocols=TLSv1.2
ssl.endpoint.identification.algorithm=HTTPS
CREDENTIALS
{
  "api_key": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
  "apikey": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
  "bootstrap_endpoints": "broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
  "iam_apikey_description": "Auto-generated for key crn:v1:bluemix:public:messagehub:us-south:a/a53b11fc95fcca4d96484d0de5f3bc3c:6b5a2cb2-74ef-432d-817f-f053873e7ed2:resource-key:96372942-5d26-4c59-8ca4-41ab6766ba91",
  "iam_apikey_name": "Service credentials-1",
  "iam_role_crn": "crn:v1:bluemix:public:iam::::serviceRole:Manager",
  "iam_serviceid_crn": "crn:v1:bluemix:public:iam-identity::a/a53b11fc95fcca4d96484d0de5f3bc3c::serviceid:ServiceId-4773bed1-f423-43ea-adff-469389dca54c",
  "instance_id": "6b5a2cb2-74ef-432d-817f-f053873e7ed2",
  "kafka_admin_url": "https://pqny71x0b9vh7nwh.svc11.us-south.eventstreams.cloud.ibm.com",
  "kafka_brokers_sasl": [
    "broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
    "broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
    "broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
    "broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
    "broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
    "broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093"
  ],
  "kafka_http_url": "https://pqny71x0b9vh7nwh.svc11.us-south.eventstreams.cloud.ibm.com",
  "password": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
  "user": "token"

チェックポイント・アイコン 進行状況を確認してください

以下の画像は、 IBM Cloud内の Event Streams インスタンスの「トピック」ページを示しています。 これで、プロジェクト内の Event Streams インスタンスへの接続を作成する準備ができました。

「トピック」ページ




タスク 2: クレジット・スコア・データの表示

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 05:06から始まるビデオをご覧ください。

サンプル・プロジェクトには、ソース・データが保管されている Db2 on Cloud インスタンスへの接続が含まれています。 接続資産およびクレジット・スコア・データを表示するには、以下の手順を実行します。

  1. Cloud Pak for Data as a Service ブラウザー・タブに戻ります。 データ統合プロジェクトが表示されます。 プロジェクトが表示されない場合は、以下の手順を実行します。

    1. Cloud Pak for Data のナビゲーション・メニュー ナビゲーション・メニューから、 「プロジェクト」>「すべてのプロジェクトを表示」を選択します。

    2. 「データ統合」 プロジェクトをクリックして開きます。

  2. 「アセット」 タブで、 「すべてのアセット」をクリックします。

  3. Data Fabric Trial- Db2 on Cloud -Source 接続資産を見つけます。

  4. CREDIT_SCORE 接続済みデータ資産を見つけます。

  5. CREDIT_SCORE 資産をクリックして、プレビューを表示します。 このデータ資産は、プロバイダーの Db2 on Cloud インスタンスの BANKING スキーマの CREDIT_SCORE テーブルにマップされます。 これには、ID、名前、住所、クレジット・スコアなど、住宅ローン申請者に関する情報が含まれます。 このデータ資産のデータ複製をセットアップする必要があります。

  6. ナビゲーション・トレールで 「データ統合」 プロジェクト名をクリックして、プロジェクトに戻ります。
    ナビゲーション・トレール

チェックポイント・アイコン 進行状況を確認してください

以下のイメージは、サンプル・プロジェクト内のクレジット・スコア・データ資産を示しています。 これで、このプロジェクトで Event Streams サービスへの接続を作成する準備ができました。

クレジット・スコア・データ資産




タスク 3: Event Streams インスタンスへの接続の作成

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 05:34から始まるビデオをご覧ください。

複製をセットアップするには、 タスク 1で収集した情報を使用して、 前提条件 の一部としてプロビジョンした新しい Event Streams インスタンスへの接続も必要です。 接続資産を作成するには、以下の手順を実行します。

  1. 「アセット」 タブで、 「新規アセット」>「データ・ソースへの接続」をクリックします。

  2. コネクターとして Apache Kafkaを選択し、 「選択」をクリックします。

  3. 名前の場合は、 Event Streamsと入力します。

  4. 「接続の詳細」セクションで、以下のフィールドに入力します。

    • Kafka サーバー・ホスト名: タスク 1で作成したテキスト・ファイルからブートストラップ・サーバー値を貼り付けます。
    • セキュア接続: 「SASL_SSL」を選択します。
    • ユーザー・プリンシパル名: サービス資格情報user 値をテキスト・ファイルに貼り付けます。 通常、この値は tokenです。
    • パスワード: サービス資格情報password 値をテキスト・ファイルに貼り付けます。
  5. 「テスト接続」をクリックします。

  6. テストが成功したら、 「作成」をクリックします。 テストが成功しない場合は、テキスト・ファイルからコピーして貼り付けた情報を確認し、再試行してください。 ロケーションと主権を設定せずに接続の作成を確認するプロンプトが出された場合は、 「作成」 を再度クリックします。

  7. 「すべての資産」 をクリックして、新規接続を表示します。

チェックポイント・アイコン 進行状況を確認してください

以下のイメージは、サンプル・プロジェクトの「アセット (Assets)」タブを示しています。このタブには、新しい Event Streams 接続アセットが表示されています。 これで、 Data Replication サービスをこのプロジェクトに関連付ける準備ができました。

EVent Streams 接続資産




タスク 4: Data Replication サービスをプロジェクトに関連付ける

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 06:32から始まるビデオをご覧ください。

プロジェクトで Data Replication サービスを使用するには、サービス・インスタンスをプロジェクトに関連付ける必要があります。 以下のステップに従って、 Event Streams サービスをデータ統合プロジェクトに関連付けます。

  1. 「データ統合」 プロジェクトで、 「管理」 タブをクリックします。

  2. 「サービスおよび統合 (Services and integrations)」 ページをクリックします。

  3. 「サービスの関連付け」をクリックします。

  4. Data Replication サービス・インスタンスの横にあるボックスにチェック・マークを付けます。

  5. 「関連付け」をクリックします。

  6. 「キャンセル」 をクリックして、 「サービス」&「統合」 ページに戻ります。

チェックポイント・アイコン 進行状況を確認してください

以下の画像は、 Data Replication サービスがリストされた 「サービスと統合 (Services and Integrations)」 ページを示しています。 これで、データ複製をセットアップする準備ができました。

サービスとプロジェクトの関連付け




タスク 5: データ複製のセットアップ

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 06:53から始まるビデオをご覧ください。

これで、 Data Replication アセットを作成して、 Db2 on Cloud ソースと Event Streams ターゲットの間で継続的なデータ複製を開始できるようになりました。 データ複製をセットアップするには、以下の手順を実行します。

  1. プロジェクトの 「資産」 タブをクリックします。

  2. 「新規資産」> Data Replicationをクリックします。

  3. 名前の場合は、 CreditScoreReplicationと入力します。

  4. 「ソース・オプション」をクリックします。

  5. 「ソース・オプション」 ページで、接続のリストから Data Fabric Trial- Db2 on Cloud -Source を選択します。

  6. 「データの選択」をクリックします。

  7. 「データの選択」 ページで、 BANKING schema> CREDIT_SCORE テーブルを選択します。

  8. ターゲット・オプションをクリックしてください。

  9. 「ターゲット・オプション」 ページで、接続のリストから 「イベント・ストリーム」 を選択します。

  10. 「デフォルト・トピック」 フィールドに、 タスク 1で作成したトピック名 golden-bank-mortgageを貼り付けます。

  11. 残りのフィールドのデフォルト値を受け入れて、 「レビュー」をクリックします。

  12. 要約を確認し、 「作成」をクリックします。

チェックポイント・アイコン 進行状況を確認してください

以下のイメージは、複製が停止した状態の ReplicateCreditScoreData 画面を示しています。 これで、データ複製を実行する準備ができました。

データ複製資産




タスク 6: データ複製の実行

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 07:54から始まるビデオをご覧ください。

Data Replication 資産を作成した後、データ複製を実行し、複製状況に関する情報を表示することができます。 データ複製を実行するには、以下の手順を実行します。

  1. CreditScore「複製」 画面で、 「実行」 アイコン 複製の実行 をクリックして複製プロセスを開始します。

    Data Replication 資産を初めて実行する場合は、API キーの指定を求めるプロンプトが表示されることがあります。 データ複製資産は、個人用の IBM Cloud API キーを使用して、中断することなく複製操作を安全に実行します。 特定の API キーを使用する場合は、 「設定」 アイコン 設定をクリックします。

    • 既存の API キーがある場合は、 「既存の API キーを使用 (Use existing API key)」をクリックし、API キーを貼り付け、 「保存」をクリックします。
    • 既存の API キーがない場合は、 「新規 API キーの生成」をクリックしてから、 「生成」をクリックします。 今後の使用のために API キーを保存し、 「閉じる」をクリックします。
  2. 「イベント・ログ」 セクションで、 「最新表示」 アイコン リフレッシュ をクリックして、新しいメッセージを表示します。

  3. 数分後に、 「イベント・ログ」 セクションに Completed initial synchronization for table "BANKING"."CREDIT_SCORE" というメッセージが表示されます。

この時点から、 Db2 on Cloud インスタンス内の BANKING.CREDIT_SCORE 表に対する変更が自動的に検出され、ターゲットに複製されます。

チェックポイント・アイコン 進行状況を確認してください

以下のイメージは、複製が実行され、イベント・ログにメッセージが記録されている「 CreditScore複製」画面を示しています。 これで、複製資産の状況、イベントおよびメトリックを監視して複製をモニターし、データが複製されていることを確認する準備ができました。

データ複製資産が実行中




タスク 7: データ複製の検証

プレビュー・チュートリアル・ビデオ このタスクをプレビューするには、 09:03から始まるビデオをご覧ください。

Python コードを使用して、クレジット・スコア・データがゴールデン・バンクの Event Streams ハブに複製されたことを確認できます。 サンプル・プロジェクトには、サンプルの Python コードを含む Jupyter ノートブックが含まれています。 ノートブックでコードを編集して実行するには、以下の手順に従います。

  1. ナビゲーション・トレールで 「データ統合」 プロジェクト名をクリックして、プロジェクトに戻ります。
    ナビゲーション・トレール

  2. 「資産」タブをクリックします。

  3. 「すべての資産」をクリックします。

  4. 「データ複製のモニター」 ノートブックの行の末尾にある 「オーバーフロー」 メニュー オーバーフロー・メニュー をクリックし、 「編集」を選択します。

  5. 最初のコード・セルを実行して、 Kafka-python ライブラリーをインストールします。

  6. タスク 1でテキスト・ファイルに保存した情報を使用して、2 番目のセルを編集します。

    • topic: トピック名を貼り付けます。 この値は golden-bank-mortgageです。

    • bootstrap_servers: テキスト・ファイルからブートストラップ・サーバー値を貼り付けます。この値は、以下のようになります。

      broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
      broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
      broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
      broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
      broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
      broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093
      
    • sasl_plain_username: サービス資格情報user 値をテキスト・ファイルに貼り付けます。 通常、この値は tokenです。

    • security_protocol: テキスト・ファイルから security.protocol 値を貼り付けます。 通常、この値は SASL_SSLです。

    • sasl_mechanism: テキスト・ファイルから sasl.mechanism 値を貼り付けます。 通常、この値は PLAINです。

    • sasl_plain_password: サービス資格情報password 値をテキスト・ファイルに貼り付けます。

  7. すべての値を入力した後、2 番目のセルのコードを実行して、 Event Streams インスタンスの接続情報を指定します。

  8. 3 番目のセルのコードを実行して、 Event Streams トピックからのレコードを取り込みます。

  9. 4 番目のセルのコードを実行して、コンシューマー・オブジェクトに取り込まれたメッセージを印刷します。

  10. Event Streams トピックへの複製によって配信されたメッセージの内容を示す出力を確認します。 それを、 タスク 2で表示した CREDIT_SCORE データ資産と比較します。

  11. 「ファイル」>「保存」 をクリックして、保管した資格情報で Jupyter ノートブックを保存します。

チェックポイント・アイコン 進行状況を確認してください

以下のイメージは、コードが正常に実行された後の 「データ複製のモニター」 ノートブックを示しています。

データ複製をモニターするための Jupyter ノートブック



ゴールデン・バンクのデータ・エンジニアは、 Db2 on Cloud ソース・データベースの CREDIT_SCORE 表と Event Streamsのトピックとの間のデータ複製を構成することで、ローン申請者の最新のクレジット・スコアへの継続的なアクセスをセットアップします。 申請者のクレジット・スコアが変更された場合、ゴールデン・バンクの住宅ローン承認者は、その変更にほぼリアルタイムでアクセスできるようになります。

クリーンアップ (オプション)

データ統合ユース・ケースのチュートリアルを再利用する場合は、以下の成果物を削除します。

成果物 削除方法
Data Replication および Event Streams サービス・インスタンス 1. ナビゲーション・メニュー ナビゲーション・メニューから、 「サービス」>「サービス・インスタンス」を選択します。
2. サービス名の横にある 「アクション」 メニューをクリックし、 「削除」を選択します。
データ統合サンプル・プロジェクト プロジェクトの削除

次のステップ

もっと見る

親トピック: ユース・ケースのチュートリアル

生成 AI の検索と回答
これらの回答は、製品資料の内容に基づいて、 watsonx.ai のラージ言語モデルによって生成されます。 詳細