すべてのプロダクト
Search

このプロダクト

    DataWorks:リアルタイム単一テーブル同期：Oracle から Tablestore へ

    ドキュメントセンター

    DataWorks:リアルタイム単一テーブル同期：Oracle から Tablestore へ

    最終更新日:Oct 30, 2026

    このトピックでは、Data Integration を使用して、単一の Oracle テーブルから Tablestore にデータをリアルタイムで同期する方法について説明します。

    前提条件

    操作手順

    ステップ 1：同期タスクタイプの選択

    1. DataWorks コンソールにログインします。 ターゲットリージョンで、左側のナビゲーションウィンドウからData Integration > Data Integrationの順にクリックします。 ドロップダウンリストからワークスペースを選択し、移動 Data Integrationをクリックします。

    2. 左側のナビゲーションウィンドウで、同期タスク をクリックします。ページ上部で 同期タスクの作成 をクリックします。以下の基本情報を設定します。

      • [ソースと送信先]： Oracle→Tablestore

      • 新規タスク名： 同期タスクのカスタム名を入力します。

      • 同期タイプ： single-table real-time。

    ステップ 2：ネットワークとリソースの構成

    1. ネットワークとリソース構成 セクションで、同期タスクの リソースグループ を選択します。タスクのリソース使用量 に計算ユニット (CU) を割り当てることができます。

    2. ソースデータソース で、ご利用の Oracle データソースを選択します。宛先データソース で、ご利用の Tablestore データソースを選択します。次に、接続性のテスト をクリックします。

    3. ソースと送信先の両方のデータソースが接続性テストに合格したら、次へ をクリックします。

    ステップ 3：同期リンクの構成

    1. Oracle ソースの構成

    ページ上部で Oracle データソースをクリックして、Oracle ソース情報 を編集します。

    image

    1. Oracle ソース情報 セクションで、読み取る Oracle テーブルを含むスキーマを選択し、次にソーステーブルを選択します。

    2. 右上隅にある データサンプリング をクリックします。

      データ出力プレビュー ダイアログボックスで、サンプリング数 にレコード数を指定し、収集開始 をクリックします。これにより、指定した Oracle テーブルからデータをサンプリングしてプレビューでき、後続のビジュアル設定ステップの入力として使用できます。

    2. データ処理ノードの編集

    image アイコンをクリックして、データ処理メソッドを追加します。利用可能なデータ処理メソッドは、データマスキング、文字列置換、データフィルタリング、JSON 解析、フィールドの編集と割り当ての 5 つです。これらのメソッドは任意の順序で配置できます。タスク実行時、データは設定された順序で順次処理されます。

    各データ処理ノードを設定した後、右上隅にある データ出力プレビュー ボタンをクリックします。表示されるダイアログボックスで 上流出力の再取得 をクリックすると、現在のノードがサンプリングデータをどのように処理するかをプレビューできます。

    [データ出力のプレビュー] ダイアログボックスには、[入力データ] と [プレビュー結果] の 2 つのセクションがあります。[入力データ] セクションでは、[先祖ノードの出力を再取得] をクリックするか、[+ 手動でデータを構築] オプションを使用してテストデータを手動で追加できます。[プレビュー結果] セクションで [プレビュー] をクリックすると、処理された出力と検出されたダーティデータの数が表示されます。このプレビューは参考用であり、実際のタスク実行では異なる結果になる場合があります。

    説明

    データ出力のプレビューは、Oracle ソースからの データサンプリング に大きく依存します。出力をプレビューする前に、Oracle ソースでデータサンプリングを実行する必要があります。

    3. Tablestore 送信先の構成

    ページ上部で Tablestore 送信先をクリックして、[Tablestore 送信先情報] を編集します。

    1. [Tablestore 送信先情報] セクションで、送信先の Tablestore テーブルを選択します。

      説明

      Tablestore テーブルは事前に作成しておく必要があります。

    2. データ更新パターン を選択します。2 つのモードがサポートされています：

      • replace： 更新されたデータで行全体を上書きします。

      • update： 変更された列のみを更新します。

    3. フィールドマッピングを構成します。

      フィールドマッピング セクションの右側で、ソースのすべてのフィールドをプロパティフィールドとしてバッチ追加 をクリックします。または、出力フィールド セクションで プロパティフィールドの追加 を手動でクリックし、同名マッピング、同一行マッピング、または すべてのマッピングのキャンセル を使用してマッピングを構成します。

    4. アラート

    タスクエラーによるビジネスデータの同期遅延を防ぐため、同期タスクにアラートポリシーを設定できます。

    1. ページ右上の アラーム設定 をクリックして、サブタスクのリアルタイムアラーム 設定ページを開きます。

    2. アラームの作成 をクリックして、アラートルールを構成します。

      説明

      ここで定義したアラートルールは、このタスクが生成するリアルタイム同期サブタスクに適用されます。タスクを設定した後、[リアルタイム同期タスクの実行と管理] ページでこれらのサブタスクのアラートルールを表示および変更できます。

    3. アラートルールを管理します。

      既存のアラートルールについては、トグルスイッチを使用して有効または無効にできます。また、アラートレベルに基づいて異なる受信者にアラートを送信することもできます。

    5. 詳細設定

    同期タスクには、必要に応じて変更できるいくつかのパラメーターが用意されています。

    説明

    変更を行う前に、予期せぬエラーやデータ品質の問題を防ぐため、各パラメーターの機能を十分に理解してください。

    1. ページ右上の [詳細設定] をクリックして、詳細設定ページを開きます。

    2. [詳細設定] ページで、必要に応じてパラメーター値を変更します。

    ステップ 6：DDL 機能の構成

    ソースデータソースには、さまざまな DDL 操作が含まれている場合があります。ビジネス要件に基づき、ページ右上の DDL 能力の設定 をクリックして DDL 機能構成ページに移動し、送信先に同期されるさまざまな DDL メッセージの処理ポリシーを定義できます。

    説明

    さまざまな DDL メッセージ処理ポリシーの詳細については、「DDL メッセージ処理ルール」をご参照ください。

    ステップ 7：リソースグループの構成

    右上隅の リソースグループの設定 をクリックすると、タスクの現在のリソースグループを表示および切り替えることができます。

    ステップ 8：シミュレーション実行

    タスクを設定した後、右上隅の 模擬実行 をクリックします。この機能は、少量のデータサンプルでタスク全体をシミュレートし、ターゲットテーブルでの結果をプレビューできます。設定エラー、ランタイム例外、またはダーティデータがある場合、リアルタイムでエラーメッセージが表示されます。これにより、タスクが正しく設定され、期待どおりの結果が生成されるかを迅速に確認できます。

    1. ダイアログボックスで、サンプリングパラメーターを設定します： 開始時間 と サンプリング数。

    2. 収集開始 をクリックして、サンプルデータを収集します。

    3. プレビュー をクリックして、サンプリングデータを使用してタスク処理全体をシミュレートします。

    ステップ 9：同期タスクの実行

    1. すべての設定が完了したら、ページ下部の 設定の完了 をクリックします。

    2. Data Integration > 同期タスク ページで、作成したタスクを見つけ、操作 列の 起動 をクリックします。

    3. タスク一覧 内の対応するタスクの 名前 / ID をクリックして、詳細な実行プロセスを表示します。

    タスクの管理と監視

    タスクステータスの表示

    [同期タスク] ページには、作成されたすべてのタスクとその基本情報が一覧表示されます。

    • [操作] 列では、タスクを 起動 または 停止 できます。[その他] メニューからは、編集 や 詳細 などの操作を実行できます。

    • 実行中のタスクについては、実行概要 セクションで基本的な実行ステータスを確認できます。また、詳細エリアをクリックして詳細情報を表示することもできます。

    タスク詳細ページの [基本情報] セクションには、タスク ID、データソース、同期ソリューション、同期リソースグループ、ステータス、およびタスクが占有する CU が表示されます。ページの中央には、[実行ステータス]、[実行ログ]、[フェイルオーバー] の 3 つのタブがあります。これらを切り替えて詳細を確認できます。

    Oracle から Tablestore への単一テーブルリアルタイム同期タスクには、リアルタイムデータ同期 サブタスクが含まれます。その実行情報、DDL レコード、およびアラート情報を表示できます。

    タスクの再実行

    同期されたフィールドを変更したり、ターゲットテーブル情報を調整したりする必要があるなどの特別な場合には、同期タスクの 操作 列にある 再実行 をクリックします。この操作により、調整されたフィールドやその他の変更がターゲットに同期されます。このプロセスでは、変更されておらず、以前に同期されたテーブルはスキップされます。

    • 変更なしでタスクを再度実行するには、再実行 をクリックします。

    • タスクを編集した場合は、変更を加えた後に 設定の完了 をクリックします。タスクのアクションが アプリケーションの更新 に変わります。アプリケーションの更新 をクリックすると、新しい構成でタスクが再実行されます。