すべてのプロダクト
Search
ドキュメントセンター

Dataphin:ステップ 3:リアルタイム計算テーブルを作成する

最終更新日:Feb 06, 2025

このトピックでは、リアルタイム開発の基本的なワークフローの一部として、リアルタイム計算テーブルを作成するプロセスについて概要を説明します。最初に、MySQL 注文システムの oms_order テーブルに注文の詳細が保持されます。リアルタイムタスクは、このテーブルから増分データを継続的に抽出して、商品取扱高 (GMV) を計算することです。次のステップでは、注文テーブルから増分データにアクセスできる対応するリアルタイムメタテーブルを作成します。

ステップ 1:oms_orders 注文ソースメタテーブルを作成するoms_orders

  1. Dataphin ホームページに移動し、トップメニューバーの [開発] をシングルクリックします。

  2. 以下に示す操作ガイドを使用して、[新規テーブル] ダイアログボックスにアクセスします。

    image.png

  3. [新規テーブル] ページで、関連パラメーターを次のように設定します。

    パラメーター

    説明

    テーブルの種類

    メタテーブルを選択します。

    メタテーブル名

    oms_orders と入力します。

    データソース

    以前に作成した flink_dataphin データソースを選択します。

    ソーステーブル

    oms_orders ソーステーブルを選択します。

    読み取りモード

    増分ストリーミング読み取りの場合は、CDC ソーステーブル を選択します。

    ディレクトリの選択

    デフォルトは テーブル管理 です。

    説明

    メタテーブルの簡単な説明 (注文ソーステーブル など) を入力します。

  4. メタテーブルを送信するには、[OK] をシングルクリックします。

ステップ 2:ads_gross 結果メタテーブルを作成する

  1. 以下に示す操作ガイドを使用して、[新規テーブル] ダイアログボックスにアクセスします。

    image.png

  2. [新規テーブル] ページで、関連パラメーターを次のように設定します。

    パラメーター

    説明

    テーブルの種類

    メタテーブルを選択します。

    メタテーブル名

    ads_gross と入力します。

    データソース

    以前に作成した flink_dataphin データソースを選択します。

    ソーステーブル

    ads_gross ソーステーブルを選択します。

    読み取りモード

    JDBC 読み取り/書き込みテーブル を選択して、テーブルクエリ、書き込み、ストリーム書き込み、およびバッチ読み取り/書き込み操作の JDBC サポートを有効にします。

    ディレクトリの選択

    デフォルトは テーブル管理 です。

    説明

    メタテーブルの簡単な説明 (カテゴリ売上合計結果テーブル など) を入力します。

  3. メタテーブルを送信するには、[OK] をシングルクリックします。