すべてのプロダクト
Search

このプロダクト

    DataWorks:単一テーブルのリアルタイム同期機能

    ドキュメントセンター

    DataWorks:単一テーブルのリアルタイム同期機能

    最終更新日:Aug 18, 2026

    DataWorks のリアルタイム同期は、単一テーブルまたはデータベース全体からデータ変更を継続的に複製することで、宛先データベースをソースデータベースと同期した状態に保ちます。

    コア機能

    以下の機能を利用できます。

    image

    機能

    説明

    さまざまなデータソース間のデータ同期

    リアルタイム同期は、さまざまなデータソースをサポートしています。異なるソースと宛先のデータソースを組み合わせて、同期パイプラインを作成できます。詳細については、「サポートされているデータソースと同期ソリューション」をご参照ください。

    複雑なネットワーク環境でのデータ同期

    リアルタイム同期は、Alibaba Cloud データベース、オンプレミスデータセンター、ECS インスタンス上の自己管理データベース、および Alibaba Cloud 外のデータベースからのデータ転送をサポートします。開始する前に、リソースグループと、ソースおよび宛先の両方との間に ネットワーク接続 が存在することを確認してください。設定の詳細については、「ネットワーク接続ソリューション」をご参照ください。

    同期シナリオ

    リアルタイム同期は、単一テーブルを宛先テーブルに同期したり、シャーディングされたデータベースやテーブルからの増分データを1つの宛先テーブルに統合したりすることもできます。

    • Data Integration & Data Studio (新バージョン)：単一テーブルから単一テーブルへの ETL 同期を、ウィザード形式で設定できます。豊富なデータ処理機能に加えて、データサンプリング、ドライラン、高度なパラメーターなどの高度な機能もサポートします。

    • Data Studio (旧バージョン)：単一テーブルから単一テーブルへの ETL 同期を、ドラッグアンドドロップで設定できます。データフィルタリング、文字列置換、データマスキングなどのデータ処理機能をサポートします。

    リアルタイム同期タスクの設定

    リアルタイム同期タスクを設定する際に、以下の機能を利用できます。コードを記述することなく、簡単なタスク設定で単一テーブルの ETL リアルタイムデータを収集できます。詳細については、「単一テーブルのリアルタイム同期タスクの設定」をご参照ください。

    単一テーブルのリアルタイム同期：

    • 設定方法：グラフィカルなドラッグアンドドロップ 操作、またはウィザードベースのローコード 開発に対応しています。コーディングは不要で、初心者でも簡単に始めることができます。

    • フィールドマッピング：同名マッピングと同行マッピング、およびカスタムフィールドリレーションシップをサポートします。ソースフィールドに対応するフィールドが宛先テーブルにない場合、動的なフィールド処理ポリシーを指定して、列の追加、無視、またはエラーを報告できます。同期タスクは、宛先フィールドへの 定数、変数、関数 の動的な割り当ても提供します。

    • データ処理: データフィルタリング、文字列の置き換え、データマスキング、および JSON 解析 を使用してソースデータを処理し、処理後のデータを宛先データベースに出力します。

    • コードのデバッグ: ソースデータソースからデータをサンプリングし、各データ処理ステップで中間結果を出力できます。 模擬実行 を使用して、最終的なデータ出力をシミュレートできます。 模擬実行 中に出力されたデータは宛先テーブルに書き込まれないため、デバッグが実際のデータに与える影響について心配する必要はありません。

    リアルタイム同期タスクの運用保守

    同期タスクの監視アラートを設定できます。

    • ブレークポイントからの再開 に対応しています。予期せぬ変動によりタスクが中断されたりデータが失われたりした場合、適切なチェックポイントを指定してデータ整合性を確保できます。

    • ビジネスレイテンシー、フェールオーバー、DDL ポリシー、ハートビート検出に対する監視アラートの設定が可能です。詳細については、「リアルタイム同期タスクの監視アラートの設定」をご参照ください。

    • アラート通知は、Eメール、SMSメッセージ、電話、DingTalkメッセージを介してアラート受信者に送信されるため、タスクの例外をタイムリーに検出して対処できます。

    • アラート疲れを制御できます。短時間に大量のアラートが生成されるのを防ぐため、DataWorksでは、指定した時間間隔内に1つのアラートのみを送信するルールを設定できます。

    • ハートビート検出をサポートしており、タスクの開始または停止時にハートビートアラートを自動的に有効または無効にします。手動でこの機能を無効にした場合、無効のままになります。

    DI Agent

    DI Agent を使用して、対話形式で単一テーブルのリアルタイム同期タスクを作成および管理できます。設定フォームにフィールドごとに入力する代わりに、同期要件を自然言語で記述すると、DI Agent がデータソースの識別、フィールドマッピング、リソースグループの割り当て、スケジューリングポリシーの設定を自動的に処理します。また、インテリジェント診断や定期検査などの運用保守機能も提供します。DI Agent の詳細については、「DI Agent の概要」をご参照ください。

    説明

    • リアルタイム同期は、DataStudio インターフェースでのタスク実行をサポートしていません。まずリアルタイム同期ノードを保存してデプロイし、その後、本番環境のオペレーションセンターでノードを実行する必要があります。

    • リアルタイム同期タスクはビューの同期をサポートしていません。

    • リアルタイム同期タスクはグラフィカル (ウィザード) モードでの設定のみに対応しており、スクリプトモードに変換することはできません。スクリプトモードはバッチ同期 タスクでのみ利用可能です。

    サポートされているデータソース

    ソース：Kafka、Hologres、Oracle、LogHub、DataHub。

    宛先：ApsaraDB for OceanBase、Data Lake Formation (DLF)、Doris、Hologres、Kafka、MaxCompute、OSS、OSS-HDFS、StarRocks、Tablestore、Lindorm。

    データ処理：データフィルタリング、文字列置換、データマスキング、JSON 解析、フィールドの編集と割り当て。

    使用開始

    単一テーブルのリアルタイム同期タスクを作成するには、「単一テーブルのリアルタイム同期タスクの設定」をご参照ください。

    DI Agent を使用して単一テーブルのリアルタイム同期タスクを作成するには、「DI Agent の概要」をご参照ください。

    運用保守とチューニング

    単一テーブルのリアルタイム同期タスクを作成した後、日常の運用保守、トラブルシューティング、およびパフォーマンスチューニングを実行する必要がある場合があります。詳細な手順については、「単一テーブルのリアルタイム同期：運用保守とチューニング」をご参照ください。

    説明

    データベース全体のリアルタイム同期タスクを使用している場合は、「データベース全体のリアルタイム同期：運用とチューニング」の運用保守ドキュメントをご参照ください。

    よくある質問

    リアルタイム同期タスクに関するよくある質問については、「リアルタイム同期に関する FAQ」をご参照ください。