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

DataWorks:基本:住宅購入者セグメントの分析

最終更新日:May 27, 2026

DataWorks と MaxCompute を使用して CSV データセットをアップロードし、SQL で住宅購入レコードをフィルタリングし、住宅ローンを利用している独身購入者の学歴分布を可視化します。

ケーススタディ

ローカルの住宅購入データを MaxCompute の bank_data テーブルにアップロードし、MaxCompute SQL タスクノードを実行して result_table を生成し、result_table を可視化して購入者セグメントをプロファイリングします。

説明

このケーススタディではサンプルデータを使用します。実際のシナリオでは、お客様の特定のビジネスデータに合わせてプロセスを調整する必要があります。

結果は、ローンを利用している独身の住宅購入者の学歴が主に university.degree または high.school であることを示しています。

image

前提条件

DataWorks のアクティベート

このチュートリアルでは、中国 (上海) リージョンを使用します。DataWorks コンソールにログインし、中国 (上海) リージョンに切り替えて、DataWorks がアクティベートされていることを確認します。

説明

このチュートリアルでは、中国 (上海) を例として使用します。実際の使用では、ビジネスデータの所在地に基づいてリージョンを選択してください:

  • ビジネスデータが他の Alibaba Cloud サービスに保存されている場合は、それらのサービスと同じリージョンを選択します。

  • ビジネスがオンプレミスにあり、パブリックネットワークアクセスが必要な場合は、地理的に最も近いリージョンを選択してレイテンシーを削減します。

新規ユーザー

DataWorks を初めて使用する新規ユーザーの場合、次のコンテンツが表示され、現在のリージョンで DataWorks がアクティベートされていないことを示します。$0コンビネーション購入 をクリックします。

image

  1. セット購入ページでパラメーターを構成します。

    パラメーター

    説明

    リージョン

    DataWorks をアクティベートするリージョンを選択します。

    中国 (上海)

    DataWorksのバージョン

    購入する DataWorks のエディションを選択します。

    説明

    このチュートリアルでは Basic Edition を例として使用します。すべてのエディションがこのチュートリアルで説明する機能をサポートしています。「エディションの比較」をご参照のうえ、ビジネス要件に応じて適切な DataWorks エディションを選択できます。

    Basic Edition

  2. 注文を確認して支払う をクリックし、支払いを完了します。

以前にアクティベートしたが期限切れの場合

中国 (上海) リージョンで以前に DataWorks をアクティベートしたが、DataWorks エディションの有効期限が切れている場合は、次のプロンプトが表示されます。購入バージョン をクリックします。

image

  1. 購入ページでパラメーターを構成します。

    パラメーター

    説明

    Version

    購入する DataWorks のエディションを選択します。

    説明

    このチュートリアルでは Basic Edition を例として使用します。すべてのエディションがこのチュートリアルで説明する機能をサポートしています。「エディションの比較」をご参照のうえ、ビジネス要件に応じて適切な DataWorks エディションを選択できます。

    Basic Edition

    リージョン

    DataWorks をアクティベートするリージョンを選択します。

    中国 (上海)

  2. Buy Now をクリックし、支払いを完了します。

重要

購入後に DataWorks エディションが表示されない場合:

  • 数分待ってからページをリフレッシュしてください。

  • 現在のリージョンが DataWorks を購入したリージョンと一致していることを確認してください。

すでにアクティベート済みの場合

すでに 中国 (上海) リージョンで DataWorks をアクティベートしている場合は、DataWorks の概要ページが表示され、次のステップに進むことができます。

ワークスペースの作成

  1. DataWorks ワークスペースリストページに移動し、中国 (上海) リージョンに切り替えて、Create a workspace をクリックします。

  2. Create a workspace ページで、カスタムの Workspace Name を指定し、新しいバージョンのData Development (Data Studio) を使用する をオンにしてから、Create a workspace をクリックします。

    説明

    2025年2月18日以降、Alibaba Cloud アカウントが初めて DataWorks をアクティベートし、中国 (上海) リージョンでワークスペースを作成する場合、Data Studio の新バージョンがデフォルトで有効になり、新しいバージョンのData Development (Data Studio) を使用する パラメーターは表示されません。

リソースグループの作成とワークスペースへの関連付け

  1. DataWorks リソースグループリストページに移動し、中国 (上海) リージョンに切り替えて、新しいリソースグループ をクリックします。

  2. リソースグループ購入ページで、次のパラメーターを構成します。

    パラメーター

    説明

    リソースグループ名

    カスタム。

    VPCvSwitch

    既存の VPC と vSwitch を選択します。現在のリージョンに存在しない場合は、パラメーターの説明にある対応するコンソールリンクをクリックして作成します。

    サービスアソシエーションの役割

    画面の指示に従って、サービスリンクロールを作成します。

  3. Buy Now をクリックし、支払いを完了します。

  4. DataWorks リソースグループリストページに移動し、中国 (上海) リージョンに切り替え、作成したリソースグループを見つけて、Operation 列の ホームスペースの変更 をクリックします。

  5. ホームスペースの変更 ページで、作成した DataWorks ワークスペースを見つけ、Operation 列の バインド をクリックします。

MaxCompute 計算リソースの作成と関連付け

MaxCompute プロジェクトを作成し、データインジェストと分析のために DataWorks 計算リソースとして関連付けます。

  1. DataWorks ワークスペースリストページに移動し、中国 (上海) リージョンに切り替え、作成したワークスペースを見つけてワークスペース名をクリックし、ワークスペースの詳細 ページに移動します。

  2. 左側のナビゲーションウィンドウで Computing Resources をクリックして計算リソースページに移動します。コンピューティングリソースのバインド をクリックし、MaxCompute タイプを選択します。次の主要なパラメーターを構成して MaxCompute プロジェクトを作成し、DataWorks 計算リソースとして関連付けます。

    説明

    表に記載されていないパラメーターについては、デフォルト値を保持してください。

    パラメーター

    説明

    MaxCompute Project

    ドロップダウンリストで Create をクリックし、次のパラメーターを構成します。

    • プロジェクト名:カスタム。グローバルで一意である必要があります。

    • コンピューティングリソース支払いタイプPay-as-you-go を選択します。

      説明

      Pay-as-you-go が利用できない場合は、Pay-as-you-go の横にある 開く をクリックして MaxCompute サービスを有効化します。

    • デフォルトクォータ:ドロップダウンリストからデフォルトのクォータを選択します。

    Default Access Identity

    Alibaba Cloud アカウント を選択します。

    Computeリソースインスタンス名

    インスタンス名でタスクの計算リソースを選択します。MaxCompute_Source のように、認識しやすい名前を使用します。

  3. Confirm をクリックします。

手順

サンプルデータを MaxCompute プロジェクトにアップロードし、DataStudio ワークフローを作成してデータをクリーンアップし、デバッグパスを実行して、SQL クエリで結果を確認します。

1. テーブルの作成

DataWorks のデータマップを使用して、サンプルデータをアップロードする前に MaxCompute プロジェクトに bank_data テーブルを作成します。

  1. DataWorks コンソールにログインします。ターゲットリージョンに切り替えた後、左側のナビゲーションウィンドウで データ開発と О&М > DataStudio をクリックします。ドロップダウンリストからワークスペースを選択し、[DataStudio に入る] をクリックします。

  2. DataStudio ページで、左側のナビゲーションウィンドウの image アイコンをクリックして Data Catalog ページに移動します。

  3. (任意) MaxCompute プロジェクトがデータマップに追加されていない場合は、MaxCompute ディレクトリの横にある image アイコンをクリックします。DataWorks Data Sources タブで、すでに計算リソースまたはデータソースとして構成されている MaxCompute プロジェクトを MaxCompute ディレクトリに追加します。

  4. MaxCompute ディレクトリを展開し、目的のプロジェクトを選択してから、Table フォルダに MaxCompute テーブルを作成します。

    説明
    • MaxCompute プロジェクトでスキーマが有効になっている場合は、プロジェクトを展開し、ターゲットスキーマを開いてから、Table フォルダに MaxCompute テーブルを作成します。

    • このチュートリアルでは標準モードのワークスペースを使用し、開発環境でのデバッグ実行のみを含みます。したがって、開発環境に対応する MaxCompute プロジェクトに bank_data テーブルを作成するだけで済みます。基本モードのワークスペースを使用する場合は、本番環境に対応する MaxCompute プロジェクトに bank_data テーブルを作成するだけで済みます。

  5. テーブルディレクトリの右側にある image アイコンをクリックしてテーブルを追加し、テーブルエディターを開きます。

    エディターの右側にある DDL セクションに、次の SQL コードを入力します。すると、システムが自動的にテーブル情報を入力します。

    CREATE TABLE IF NOT EXISTS bank_data (
        age             BIGINT   COMMENT '年齢',
        job             STRING   COMMENT '職種',
        marital         STRING   COMMENT '婚姻状況',
        education       STRING   COMMENT '学歴',
        `default`       STRING   COMMENT 'クレジットカードの有無',
        housing         STRING   COMMENT '住宅ローン',
        loan            STRING   COMMENT '個人ローン',
        contact         STRING   COMMENT '連絡方法',
        month           STRING   COMMENT '月',
        day_of_week     STRING   COMMENT '曜日',
        duration        STRING   COMMENT '持続時間',
        campaign        BIGINT   COMMENT 'このキャンペーン中の連絡回数',
        pdays           DOUBLE   COMMENT '前回の連絡からの日数',
        previous        DOUBLE   COMMENT 'クライアントとの以前の連絡回数',
        poutcome        STRING   COMMENT '前回のマーケティングキャンペーンの結果',
        emp_var_rate    DOUBLE   COMMENT '雇用変動率',
        cons_price_idx  DOUBLE   COMMENT '消費者物価指数',
        cons_conf_idx   DOUBLE   COMMENT '消費者信頼感指数',
        euribor3m       DOUBLE   COMMENT 'ユーロ圏 3 ヶ月物金利',
        nr_employed     DOUBLE   COMMENT '従業員数',
        y               BIGINT   COMMENT '定期預金の有無'
    );
  6. エディターで Publish をクリックして、開発環境の MaxCompute プロジェクトに bank_data テーブルを作成します。

  7. bank_data テーブルが作成されたら、データマップでその名前をクリックして詳細を表示します。

2. データのアップロード

banking.csv ファイルをローカルコンピューターにダウンロードし、DataWorks のデータアップロード機能を使用して MaxCompute プロジェクトの bank_data テーブルにアップロードします。制限については「使用制限」をご確認ください。

重要

アップロードする前に、スケジューリングリソースグループData Integration リソースグループをデータアップロード機能に割り当てます。「使用制限」をご参照ください。

  1. 左上隅の image アイコンをクリックします。表示されるペインで、Data Integration > Upload and Download を選択して、アップロード/ダウンロードページに移動します。

  2. Recent Upload Records セクションで、Upload Data をクリックしてデータアップロード構成ページに移動します。次の表の説明に従ってパラメーターを構成します。

    パラメーター

    説明

    Data Source

    ローカルファイル。

    Specify Data to Be Uploaded

    Select File

    ローカルコンピューターにダウンロードした banking.csv ファイルをアップロードします。

    Configure Destination Table

    Compute Engine Type

    MaxCompute

    MaxCompute プロジェクト名

    bank_data テーブルがある MaxCompute プロジェクトを選択します。

    Select Destination Table

    ターゲットテーブルとして bank_data テーブルを選択します。

    Preview Data of Uploaded File

    [順序でマッピング] をクリックして、ファイルデータを bank_data テーブルのフィールドにマッピングします。

    説明
    • ローカルファイルは .csv.xls.xlsx.json 形式でアップロードできます。

    • スプレッドシートの場合、DataWorks はデフォルトで最初のシートのみをアップロードします。

    • .csv ファイルの最大サイズは 5 GB です。他のファイルタイプの最大サイズは 100 MB です。

  3. Upload Data をクリックして、CSV ファイルのデータを MaxCompute 計算リソースの bank_data テーブルにアップロードします。

  4. データが正常にアップロードされたことを確認します。

    SQL クエリ (レガシー) を使用して、データが bank_data テーブルに書き込まれたことを確認します。

    1. 左上隅の image アイコンをクリックし、[すべての製品] > データ分析 > SQLクエリ を選択します。

    2. マイファイルの横にある image > Create File をクリックします。カスタムの File Name を指定し、Determine をクリックします。

    3. SQL クエリページで、次の SQL ステートメントを入力します。

      SELECT * FROM bank_data limit 10;
      SELECT * FROM bank_data limit 10;
    4. 右上隅で、bank_data テーブルのワークスペースと MaxCompute データソースを選択し、Determine をクリックします。

      説明

      このチュートリアルでは標準モードのワークスペースを使用し、bank_data テーブルは開発環境でのみ作成されます。データソースを選択する際は、開発環境の MaxCompute データソースを選択する必要があります。基本モードのワークスペースを使用する場合は、本番環境の MaxCompute データソースを選択できます。

    5. ページ上部の Run をクリックします。Estimate Costs ページで Run をクリックします。クエリが正常に実行されると、ページの下部に bank_data テーブルの最初の 10 レコードが表示されます。これは、ローカルデータを bank_data テーブルに正常にアップロードしたことを示します。

      bank_data テーブルには、agejobmaritaleducationdefaulthousingloancontactmonthday_of_weekdurationcampaignpdays などのフィールドが含まれています。

3. データ処理

MaxCompute SQL ノードで bank_data テーブルをフィルタリングして、住宅ローンを利用している独身者の学歴分布を取得し、結果を新しい result_table に書き込みます。

データ処理ワークフローの構築

  1. 左上隅の icon アイコンをクリックし、データ開発と О&М > DataStudio (データ開発) を選択して DataStudio ページに移動します。

  2. ページの上部で、このチュートリアル用に作成したワークスペースに切り替えます。左側のナビゲーションウィンドウで image をクリックして DataStudio に移動します。

  3. Project Directory セクションで image をクリックし、Create Workflow を選択します。ワークフロー名を dw_basic_case に設定し、Confirm をクリックしてワークフローを保存し、ワークフローオーケストレーションキャンバスに移動します。

  4. キャンバスの左側から Zero-Load Node 1 つと MaxCompute SQL 2 つをキャンバスにドラッグし、各ノードに名前を設定します。

    次の表に、このチュートリアルで使用するノードとその目的を示します。

    Node Type

    Node Name

    目的

    image 仮想ノード

    workshop_start

    ワークフローの開始をアンカーします。これはコードを必要としない Dry-run Task です。

    image MaxCompute SQL ノード

    ddl_result_table

    bank_data からクリーンアップされたデータを保存するために result_table を作成します。

    image MaxCompute SQL ノード

    insert_result_table

    bank_data をフィルタリングし、結果を result_table に書き込みます。

  5. image

    説明

    上流と下流の依存関係は、ノード間に線を描画して手動で定義するか、子ノードのコードを解析してシステムに検出させることができます。このチュートリアルでは手動での配線を使用します。「依存関係の自動解析」をご参照ください。

  6. ノードツールバーで Save をクリックします。

データ処理ノードの構成

Ddl_result_table ノード

insert_result_table ノードからの学歴分布出力を保存するために、result_table テーブルを作成します。

  1. ワークフローキャンバスで、ddl_result_table ノードにカーソルを合わせ、Open Node をクリックします。このノードは insert_result_table ノードのターゲットテーブルを定義します。

  2. 次のコードをノードエディターに貼り付けます。

    CREATE TABLE IF NOT EXISTS result_table(
      education STRING COMMENT'学歴',
      num       BIGINT COMMENT'カウント'
    );
  3. デバッグパラメーターを構成します。

    MaxCompute SQL ノードエディターの右側のペインで、Run Configuration をクリックします:

    • Computing Resources パラメーターには、「前提条件」セクションで関連付けた MaxCompute 計算リソースとそれに対応するコンピュートクォータを選択します。

    • Resource Group パラメーターには、「前提条件」セクションで購入したサーバーレスリソースグループを選択します。

  4. ノードツールバーで Save をクリックします。

Insert_result_table ノード

bank_data を住宅ローンを利用している独身者でフィルタリングし、学歴でグループ化して、そのカウントを result_table に書き込みます。

  1. ワークフローキャンバスで、insert_result_table ノードにカーソルを合わせ、Open Node をクリックします。

  2. 次のコードをノードエディターに貼り付けます。

    INSERT OVERWRITE TABLE result_table -- result_table テーブルにデータを挿入します。
    SELECT
      education,
      COUNT(marital) AS num
    FROM bank_data
    WHERE 
      housing = 'yes'
      AND marital = 'single'
    GROUP BY
    education;
  3. デバッグパラメーターを構成します。

    MaxCompute SQL ノードエディターの右側のペインで、Run Configuration をクリックします:

    • Computing Resources パラメーターには、「前提条件」セクションで関連付けた MaxCompute 計算リソースとそれに対応するコンピュートクォータを選択します。

    • Resource Group パラメーターには、「前提条件」セクションで購入したサーバーレスリソースグループを選択します。

  4. ノードツールバーで Save をクリックします。

4. デバッグと実行

dw_basic_case オーケストレーションキャンバスで、image アイコンをクリックしてワークフロー全体をデバッグモードで実行します。実行が失敗した場合は、デバッグログを確認してください。

実行が成功すると、workshop_startddl_result_tableinsert_result_table に緑色のチェックマークが表示されます。

5. データのクエリと可視化

SQL クエリ (レガシー)result_table データをクエリして分析します。

  1. 左上隅の image アイコンをクリックし、[すべての製品] > データ分析 > SQLクエリ を選択します。

  2. マイファイルの横にある image > Create File をクリックします。カスタムの File Name を指定し、Determine をクリックします。

  3. SQL クエリページで、次の SQL ステートメントを入力します。

    SELECT * FROM result_table;
    SELECT * FROM result_table;
  4. 右上隅で、result_table テーブルの ワークスペースMaxCompute データソース を選択し、Determine をクリックします。

    説明

    このチュートリアルでは標準モードのワークスペースを使用し、result_table テーブルは開発環境で作成されますが、本番環境にはデプロイされません。したがって、開発環境の MaxCompute データソースを選択する必要があります。基本モードのワークスペースを使用する場合は、本番環境の MaxCompute データソースを選択できます。

  5. ページ上部の Run をクリックします。Estimate Costs ページで Run をクリックします。

  6. クエリ結果で image をクリックして可視化チャートを表示します。チャートの右上隅にある image をクリックして、チャートのスタイルをカスタマイズできます。

  7. また、チャートの右上隅にある Save をクリックしてカードとして保存し、左側のナビゲーションウィンドウで Card (image) をクリックして表示することもできます。

    image

次のステップ

リソースのクリーンアップ

不要な料金を避けるために、このチュートリアルで作成したリソースを解放します。

  1. 定期タスクを停止します。

    1. DataWorks コンソールにログインします。ターゲットリージョンで、左側のナビゲーションウィンドウの データ開発と О&М > 操作とメンテナンスセンター をクリックします。ドロップダウンリストからワークスペースを選択し、入力 操作とメンテナンスセンター をクリックします。

    2. Auto Triggered Task O&M > Auto Triggered Task で、以前に作成したすべての定期タスクを選択し (ワークスペースのルートノードはアンデプロイする必要はありません)、下部にある Operation > Undeploy をクリックします。

  2. データ開発ワークフローを削除し、MaxCompute 計算リソースの関連付けを解除します。

    1. DataWorks コンソールの [ワークスペース] ページに移動します。上部のナビゲーションバーで、目的のリージョンを選択します。目的のワークスペースを見つけ、[アクション] 列の [ショートカット] > [Data Studio] を選択します。

    2. Data Studio の左側のナビゲーションウィンドウで image をクリックしてデータ開発ページに移動します。Project Directory セクションで、作成したワークフローを見つけ、右クリックして Delete をクリックします。

    3. 左側のナビゲーションウィンドウで image > [計算リソース管理] をクリックします。関連付けられた MaxCompute 計算リソースを見つけ、解绑 をクリックします。確認ダイアログで、オプションを選択し、指示に従って関連付けの解除を完了します。

  3. MaxCompute プロジェクトを削除します。

    MaxCompute プロジェクト管理ページに移動し、作成した MaxCompute プロジェクトを見つけて、Operation 列の Delete をクリックします。指示に従って削除を完了します。

  4. DataWorks ワークスペースを削除します。

    1. DataWorks コンソールにログインします。ターゲットリージョンに切り替え、左側のナビゲーションウィンドウで [ワークスペース] をクリックします。ワークスペースリストで、削除したい DataWorks ワークスペースを見つけ、[アクション] 列の image アイコンをクリックし、[ワークスペースの削除] を選択します。

    2. ワークスペースの削除 ダイアログボックスで、Confirm をクリックしてワークスペースを削除します。