このトピックでは、サーバーレス同期タスクを構成して、MySQL データベースのすべてのデータをリアルタイムで MaxCompute に同期する方法について説明します。
前提条件
MySQL データソースと MaxCompute データソースが DataWorks に追加されていること。 詳細については、「Data Integration でデータソースを追加および管理する」をご参照ください。
ApsaraDB RDS for MySQL インスタンスと MaxCompute プロジェクトに IP アドレスホワイトリストが構成されている場合は、必要な IP アドレスが IP アドレスホワイトリストに追加されていることを確認してください。 インスタンスとプロジェクトに IP アドレスホワイトリストが構成されていない場合、接続テストは自動的に合格します。 追加する必要がある IP アドレスについては、「ネットワーク接続を構成する」をご参照ください。
制限事項
ソースデータを MaxCompute 外部テーブルに同期することはサポートされていません。
サーバーレス同期タスクを作成する
サーバーレス同期タスクは、従量課金制で課金されるフルマネージドのデータ同期サービスです。 基盤となるリソースグループを管理したり、ネットワーク構成を作成したりする必要はありません。 ビジネスロジックのみに焦点を当ててデータ同期を実装できます。
ステップ 1：サーバーレス同期タスクを作成する
Data Integration ページに移動します。
DataWorks コンソールにログオンします。 上部のナビゲーションバーで、目的のリージョンを選択します。 左側のナビゲーションウィンドウで、 を選択します。 表示されるページで、ドロップダウンリストから目的のワークスペースを選択し、[Data Integration に移動] をクリックします。
左側のナビゲーションウィンドウで、[サーバーレス同期タスク] をクリックします。
サーバーレス同期タスク ページの上部で、[ソース] ドロップダウンリストから MySQL を、[宛先] ドロップダウンリストから MaxCompute を選択し、[サーバーレス同期タスクの作成] をクリックします。
ステップ 2：サーバーレス同期タスクの基本情報を構成する
選択した ソース と デスティネーション は、事前に Data Integration または管理センターに追加する必要はありません。 ソースまたはデスティネーションに関する情報を直接構成できます。
既存のデータソースを使用する場合は、[既存のデータソースを使用] をクリックして、既存のデータソースを選択できます。 データソースに関する情報は自動的に取得されます。
ソースとデスティネーションに関する情報を構成した後、[テスト] をクリックします。 ApsaraDB RDS for MySQL インスタンスと MaxCompute プロジェクトに IP アドレスホワイトリストが構成されていない場合、接続テストは自動的に合格します。 インスタンスとプロジェクトに IP アドレスホワイトリストが構成されている場合は、必要な IP アドレスを IP アドレスホワイトリストに追加する必要があります。 追加する必要がある IP アドレスについては、「ネットワーク接続を構成する」をご参照ください。
ステップ 3：サーバーレス同期タスクの詳細情報を構成する
1. データを同期するテーブルを選択する
ソースが接続テストに合格すると、サーバーレス同期タスクはソースからテーブルを自動的にプルします。 現在のサーバーレス同期タスクは、次のテーブル選択方法をサポートしています：[指定されたデータベースとテーブルを選択] および [正規表現を使用 (実行中の正規表現に基づくテーブルの追加と削除をサポート)]。
[ソーステーブル] リストからテーブルを選択した後、
アイコンをクリックしてテーブルを [選択済みテーブル] リストに移動します。
2. テーブルマッピングを構成する
目的のソーステーブルが表示されている行を見つけ、[アクション] 列の [更新] をクリックします。 次に、[宛先テーブル名のマッピングルールのカスタマイズ] や [宛先スキーマ名のマッピングルールのカスタマイズ] などのパラメーターを設定し、ソースフィールドと宛先フィールドのデータ型間のマッピングを変更します。
3. アラートルールと詳細パラメータを構成する
構成ページの右上隅にある [アラートルールを構成]、[詳細パラメータを構成]、または [DDL 機能を構成] をクリックし、プロンプトに従ってパラメータを構成します。
ステップ 4：構成を完了する
上記の構成が完了したら、[完了] をクリックします。
[完了] を初めてクリックすると、サーバーレス同期タスクで 構成チェック が自動的に実行されます。 構成チェック は構成の完了をブロックせず、事前チェックにすぎないことに注意してください。
サーバーレス同期タスクを開始する
サーバーレス同期タスクを開始すると、別の構成チェックがトリガーされます。 サーバーレス同期タスクは、構成チェックに合格した場合にのみ正常に開始できます。
構成チェックのチェック項目は、サーバーレス同期タスクの同期タイプによって異なります。
サーバーレス同期タスクを初めて開始すると、システムはアカウントに AliyunBSSOrderAccess ポリシーと AliyunDataWorksFullAccess ポリシーがアタッチされているかどうかを確認します。 権限は、従量課金制のサーバーレスリソースグループを購入するために必要な権限と同じです。
サーバーレス同期タスクページの [タスク] セクションで、作成したサーバーレス同期タスクを見つけ、[アクション] 列の [開始] をクリックします。
サーバーレス同期タスクを開始すると、タスクは 環境準備 ステージに入ります。これは、バックエンドがタスク専用のランニングリソースを準備していることを示します。 このステージは数分で完了すると推定されます。
サーバーレス同期タスクが開始されると、タスクのステータスは [実行中] に変わります。
サーバーレス同期タスクで O&M 操作を実行する
サーバーレス同期タスクの詳細を表示する
[タスク] セクションでサーバーレス同期タスクを見つけ、[名前/ID] 列のタスク名または ID をクリックするか、[実行概要] 列のステージをクリックして、タスク詳細ページに移動します。 タスク詳細ページで、サーバーレス同期タスクに関する次の情報を表示します。
基本情報：サーバーレス同期タスクのデータソース情報、注文 ID、および同期タイプが含まれます。
実行情報：各ステージの実行ステータスが含まれます。 また、サーバーレス同期タスクの操作ログ、フェールオーバーレコード、およびリソース使用率を表示することもできます。
詳細：スキーママイグレーション、フルデータ初期化、およびリアルタイム同期の詳細が含まれます。
サーバーレス同期タスクを変更する
[タスク] セクションでサーバーレス同期タスクを見つけ、[操作] 列の [その他] をクリックし、[編集] を選択してタスク構成ページに移動します。
タスク構成ページで、サーバーレス同期タスクにテーブルを追加、テーブルを削除、またはその他の構成を変更します。 次に、[完了] をクリックします。
[タスク] セクションで、サーバーレス同期タスクの [操作] 列の [更新の適用] をクリックします。
[更新を適用] をクリックすると、システムはサーバーレス同期タスクの構成を自動的にチェックします。サーバーレス同期タスクがチェックに失敗した場合、変更は反映されません。
[更新を適用] をクリックした際のチェック項目は、サーバーレス同期タスクの初回起動時よりも少なくなります。これは、初回起動ではリソース準備が必要ですが、サーバーレス同期タスクに更新を適用する際にはリソース初期化が完了しているためです。