MySQL データベース CDC をソースとして Real-Time ハブに追加する

この記事では、Fabric Real-Time ハブで MySQL データベース変更データ キャプチャ (CDC) をイベント ソースとして追加する方法について説明します。

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

Prerequisites

• 共同作成者以上のアクセス許可を持つ、Fabric 容量ライセンス モード (または試用版ライセンス モード) のワークスペースへのアクセス。
• Azure Database for MySQL - フレキシブル サーバーのインスタンスを作成しました。

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

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

binlog を有効にする

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

1. Azure portal で、Azure MySQL データベースに移動します。

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

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

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

   

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

Azure MySQL データベース CDC から Real-Time ハブにイベントを取得するには、次のいずれかの方法があります。

• [データ ソース] ページの使用
• [Microsoft ソース] ページの使用

データ ソース ページ

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

2. ページの左下に Power BI が表示される場合は、Power BI を選択し、その後、Fabricを選択して、Fabric ワークロードに切り替えます。

   

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

   

4. [リアルタイム ハブ] ページで、左側のナビゲーション メニューの [接続先] の下にある [+ データ ソース] を選択します。

   

   右上隅にある [+ データの追加] ボタンを選択して、Real-Time ハブ ページから [データソース] ページにアクセスすることもできます。

   

4. [データ ソース] ページで、上部にある [データベース CDC] カテゴリを選択し、[MySQL DB (CDC)] タイルで [接続] を選択します。

   

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

[Microsoft ソース] ページ

1. Real-Time ハブで、 Microsoft ソースを選択します。

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

3. サブスクリプションの場合は、Azure MySQL Database アカウントを持つリソース グループを持つ Azure サブスクリプションを選択します。

4. [リソース グループ] では、データベースを含むリソース グループを選択します。

5. [リージョン] では、データベースが存在する場所を選択します。

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

   

   接続情報を構成するには、「 ソースとして Azure MySQL DB CDC を追加 する」セクションの手順を使用します。

ソースとして Azure MySQL データベース CDC を追加する

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

   

2. 接続設定 セクションで、次の手順を実行してください。

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

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

      

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

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

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

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

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

   5. 「を選択し、に接続します。」

      

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

   1. テーブル名を入力します。
   2. サーバー ID を入力します。
   3. ポート番号を入力するか、既定値のままにします。

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

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

   2. イベントストリームの名前を入力します。

   3. Real-Time ハブ内のストリームの名前が自動的に作成されます。

      

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

7. [ 確認と接続] で設定を確認し、[ ソースの作成] を選択します。

   

8. [ 接続 ] ページで、[ リソースに移動 ] を選択して Azure PostgreSQL データベースに移動します。 [概要] ページでサーバー名を書き留めます。 これは次の形式です: mysqlserver.mysql.database.azure.com。

   

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

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

   

2. Real-Time ハブで、[ マイ データ ストリーム] を選択します。 新しいデータ ストリームを表示するには、ページを更新します。

   

   詳細な手順については、「Fabric リアルタイム ハブでのデータ ストリームの詳細の表示」を参照してください。

関連コンテンツ

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

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