リアルタイム ハブでソースとして MySQL データベース CDC を追加する (プレビュー)

この記事では、Azure Cosmos DB Change Data Capture (CDC) を Fabric Real-Time ハブのイベント ソースとして追加する方法について説明します。

Azure MySQL Database Change Data Capture (CDC) コネクタを使用すると、Azure MySQL データベース内の現在のデータのスナップショットをキャプチャできます。 監視対象のテーブルを指定し、後続の行レベルがテーブルに変更されたときにアラートを受け取ります。 ストリームに変更がキャプチャされると、この CDC データをリアルタイムで処理し、Fabric 内のさまざまな宛先に送信して、さらに処理または分析することができます。

Note

リアルタイム ハブは現在プレビュー段階です。

前提条件

• 寄稿者以上のアクセス許可を使用して、Premiumワークスペースにアクセスします。
• Azure Database for MySQL フレキシブル サーバーのインスタンスを作成する

SQL データベースを設定する

Azure MySQL データベース コネクタは、Debezium MySQL コネクタを使用して、MySQL データベースの変更をキャプチャします。 コネクタが監視するすべてのデータベースに対するアクセス許可を持つ MySQL ユーザーを定義する必要があります。 詳細な手順については、「MySQL DB の設定」を参照してください。

binlog を有効にする

MySQL レプリケーションのバイナリ ログを有効にする必要があります。 バイナリ ログには、変更を反映するためのレプリケーション ツールのトランザクションの更新が記録されます。 Azure Database for MySQL シンク スクリプトの例

1. Azure portal で、お使いの Azure Database for MySQL に移動します。

2. 左側のメニューで、[サーバー パラメーター] を選択します。

3. 次のプロパティを使用して MySQL サーバーを構成します。

   • binlog_row_image: 値を full に設定します。
   • binlog_expire_logs_seconds: binlog ファイルの自動削除の秒数。 環境のニーズに合わせて値を設定します。 (例: 86400)。

   

Azure MySQL Database (CDC) からイベントを取得する

次のいずれかの方法で、Azure MySQL データベース CDC からリアルタイム ハブにイベントを取得できます。

• ソースの追加エクスペリエンスの使用
• Microsoft ソース ページの使用

起動ソース エクスペリエンスの追加

1. Microsoft Fabric にサインインします。

2. 左側のナビゲーション バーで[リアルタイム ハブ]を選択します。

3. [リアルタイム ハブ] ページで、ページの右上隅にある [+ ソースの追加] を選択します。

   

「ソースとして Azure MySQL データベース CDC を追加する」セクションの手順を使用します。

Microsoft ソース ページ

1. リアルタイム ハブで、Microsoft ソースを選択 します。

2. [ソース] ドロップダウン リストで、[Azure MySQL DB (CDC)] を選択します。

3. [サブスクリプション] で、お使いの Cosmos DB アカウントを持つリソース グループを含む Azure サブスクリプションを選択します。

4. [リソース グループ] では、お使いの IoT ハブのあるリソース グループを選択します。

5. [リージョン] では、IoT ハブのある場所を選択します。

6. 次に、データベースの一覧でリアルタイム ハブに接続する Azure MySQL DB CDC ソースの名前の上にマウスを移動し、[接続] ボタンを選択するか、[...(省略記号) をクリックし、[接続] ボタンを選択します。

   

   接続情報を構成するには、「ソースとして Azure MySQL DB CDC を追加する」セクションの手順を使用します。 ソースの追加ウィザードで、ソースの種類として Azure MySQL DB CDC を選択する最初の手順をスキップします。

ソースとしての Azure Database for MySQL

1. [データ ソースの選択] 画面で、MySQL DB (CDC) を選択します。

   

2. [接続] ページで、 [リソースに移動] を選択してAzure PostgreSQL データベースに移動します。 [概要] ペインで、[サーバー名] の値を記録しておきます。 または という形式で指定しますmysqlserver.mysql.database.azure.com。

   

3. データ 接続ページで、新しい接続を選択します。

   

4. [設定] セクションで、[接続文字列] を選択します。

   1. [サーバー] に、Azure MySQL サーバーの URI を入力します。

   2. [databasename] で、データベースの名前を入力します。

      

5. [接続資格情報] セクションで、次の手順を実行します。

   1. [接続] で、MySQL データベースへの既存の接続があるかどうかを選択します。 そうでない場合は、既定値のままにします。 新しい接続を作成します。

   2. [認証の種類] で、[Basic] を選択します。 現在サポートされているのは [基本認証] のみです。

   3. ユーザー名とパスワードの値を入力します。

   4. 暗号化された接続を使用するかどうかを指定します。

   5. [接続] を選択します。

      

6. [接続] ページに戻り、次の手順を実行します。

   1. [規則名] を入力します。
   2. エラー ID を入力してください
   3. ポート番号を入力するか、既定値のままにします。

7. 右側のウィンドウの [ストリームの詳細] セクションで、次の手順を実行します。

   1. この接続とウィザードによって作成されるイベントストリームを保存する Fabric ワークスペースを選択します。

   2. イベント ハウスの名前を入力します。

   3. リアルタイム ハブ内のストリームの名前が自動的に作成されます。

      

8. ページの下部にある [次へ] を選択します。

9. [確認と作成]ページで、設定を確認し、[ソースの作成]を選択します。

   

データ ストリームの詳細を表示する

1. [確認と作成] ページで[イベントストリームを開く]を選択すると、ウィザードによって、選択した Azure MySQL DB CDC をソースとして使用して作成されたイベントストリームが開きます。 ウィザードを閉じるには、ページの右上隅にある [閉じる] または [X]* を選択します。

   

2. リアルタイム ハブで、[すべてのデータ ストリーム] を選択 します。 新しいデータ ストリームを表示するには、[すべてのデータ ストリーム] ページを更新します。 詳細な手順については、「Fabric リアルタイム ハブでのデータ ストリームの詳細の表示」を参照してください。

関連するコンテンツ

データ ストリームの使用について詳しくは、次の記事を参照してください。

• データ ストリームの処理
• データ ストリームを分析する
• データ ストリームにアラートを設定する