このチュートリアルでは、ユーザープロファイリングプロジェクトを例に、中国 (上海) リージョンで DataWorks を使用したデータ同期、データ処理、品質モニタリングの完全なワークフローを説明します。このチュートリアルでは、EMR Serverless StarRocks クラスター、DataWorks ワークスペース、および必要な環境構成が必要です。
OSS 環境の準備
このチュートリアルではカスタム関数を使用するため、リソースを Object Storage Service (OSS) にアップロードする必要があります。開始する前に、OSS が有効化されていること、および OSS バケットが作成されていることを確認してください。
EMR Serverless StarRocks 環境の準備
このチュートリアルでは、データ処理に EMR Serverless StarRocks を使用します。StarRocks インスタンスがあることを確認してください。お持ちでない場合は、Alibaba Cloud 無料利用枠のページで利用資格を確認するか、インスタンスを直接購入できます。購入情報については、E-MapReduce Serverless StarRocks 製品ページをご参照ください。
-
Instance Type:コンピューティング・ストレージ一体型。
-
Region:中国 (上海)。
-
シリーズ例:Basic Edition。
重要Basic Edition は試用および機能テストのみを目的としており、サービスレベルアグリーメント (SLA) の対象外です。ビジネスニーズに応じて Standard Edition を選択できます。
-
Version:3.1。
このチュートリアルでの操作は、user_behavior_analysis データベースで実行されます。したがって、EMR Serverless StarRocks インスタンスを作成した後、user_behavior_analysis データベースを作成する必要があります。そのためには、EMR Serverless StarRocks インスタンスの [SQL エディタ] にログインし、次の SQL ステートメントを実行します。
CREATE DATABASE user_behavior_analysis;
DataWorks 環境の準備
DataWorks で開発を行う前に、DataWorks サービスを有効化する必要があります。詳細については、「事前準備」をご参照ください。
1. ワークスペースの作成
-
DataWorks コンソールにログインします。上部のナビゲーションバーで、DataWorks サービスが利用可能なリージョンに切り替えます。
-
左側のナビゲーションバーで ワークスペース をクリックします。ワークスペースリストページで、+ ワークスペースの作成 をクリックします。詳細については、「ワークスペースの作成」をご参照ください。
-
既存のワークスペースがある場合は、このステップをスキップして既存のワークスペースを使用できます。
-
このチュートリアルの MySQL および HttpFile データソースは中国 (上海) リージョンにあるため、同じリージョンのワークスペースを使用する必要もあります。
2. リソースグループの作成
-
リソースグループの購入:DataWorks で StarRocks タスクを実行するには、リソースグループが必要です。リソースグループの購入については、「サーバーレスリソースグループの使用」をご参照ください。
-
ネットワーク接続の確立:リソースグループと StarRocks インスタンス間のネットワーク接続を確保します。ネットワークソリューションの詳細については、「ネットワーク接続ソリューション」をご参照ください。
-
ご利用の StarRocks インスタンスのネットワーク環境を確認します:StarRocks インスタンスの詳細ページに移動し、VPC や vSwitch などのネットワーク構成情報を確認します。
-
DataWorks を同じ VPC にバインドします。DataWorks サーバーレスリソースグループの [VPC バインディング] タブで、ご利用の StarRocks インスタンスと同じ VPC と vSwitch を選択して、ネットワークバインディングを完了します。
-
DataWorks サーバーレスリソースグループの IP アドレスを StarRocks ホワイトリストに追加して、アクセスを許可します。
-
DataWorks サーバーレスリソースグループのアウトバウンド IP アドレスを取得します。リソースグループの [VPC バインディング] タブで、[データスケジューリング & Data Integration] セクションのテーブルを見つけ、対応する [vSwitch CIDR ブロック] の値を記録します。
-
StarRocks インスタンス名をクリックします。 Basic information ページ ([インスタンス詳細] ページ内) で、[内部ホワイトリスト] をクリックして、DataWorks Serverless リソースグループの vSwitch CIDR ブロックを追加します。 ECS コンソールの左側のナビゲーションバーで、[ネットワーク & セキュリティ] > [セキュリティグループ] を選択します。 対象のセキュリティグループをクリックして、その詳細ページに移動します。 [Inbound] ルールのリストで、[手動で追加] をクリックし、DataWorks Serverless リソースグループの Egress IP アドレスをセキュリティグループルールに追加します。
-
-
リソースグループのパブリックネットワークアクセスを設定します。
-
NAT Gateway コンソールにログインし、トップメニューバーでリージョンを中国 (上海) に切り替えます。
-
NAT Gateway の作成 をクリックします。パラメーターを設定します。
パラメーター
値
リージョン
中国 (上海)。
VPC
リソースグループに関連付けられている VPC と vSwitch を選択します。
DataWorks コンソールに移動し、リージョンを切り替えることができます。左側のナビゲーションバーで リソースグループ をクリックします。作成したリソースグループを見つけ、ネットワーク設定 列の Operation をクリックします。[データスケジューリング & Data Integration] エリアで、[バインドされた VPC] と Switch を表示できます。VPC と vSwitch の詳細については、「VPC とは」をご参照ください。
vSwitch の関連付け
Access mode
VPC フル NAT モード (SNAT)。
EIP
Elastic IP (EIP) を作成して関連付けます。
サービスリンクロールの作成
初めて NAT Gateway を作成する場合は、サービスリンクロールを作成する必要があります。サービスにリンクされたロールの作成 をクリックします。
説明表に指定されていないパラメーターについては、デフォルト値を保持できます。
-
Buy Now をクリックし、サービス利用規約を選択して、確認 をクリックして購入を完了します。
-
-
3. StarRocks データソースの作成
DataWorks コンソールで、左側のナビゲーションバーの Management Center をクリックし、ドロップダウンリストからターゲットワークスペースを選択して Management Center に移動します。Management Center で、 をクリックし、Add Connection をクリックして StarRocks を選択します。ApsaraDB for RDS を使用して、現在の DataWorks ワークスペースに StarRocks インスタンスを追加することで、StarRocks データソースを作成します。
[開発環境] と [本番環境] の両方を設定する必要があります。[Alibaba Cloud アカウント] には、[現在の Alibaba Cloud メインアカウント] を選択します。インスタンスを選択した後、[最新アドレスの取得] をクリックして、フロントエンドノードの内部エンドポイントを取得します。[FrontEnd Http ポート] を 8030 に、[FrontEnd Query ポート] を 9030 に設定します。
-
StarRocks データソースの基本情報を設定します。
EMR コンソールに移動し、ご利用の Instance Details の情報に基づいて、DataWorks の StarRocks データソースの Basic information を設定する必要があります。このステップは、後続のタスクの同期と処理に必須です。以下に設定項目の詳細を示します。
パラメーター
説明
Data Source Name
データソースの名前を入力します。このチュートリアルでは、
Doc_StarRocks_Storage_Compute_Tightly_01を使用します。Description
データソースのオプションの説明を入力します。
設定モード
ApsaraDB for RDS.Alibaba Cloudインスタンスモード
Region
中国 (上海)
Examples
ご利用の Serverless インスタンスを選択します。
Database Name
StarRocks データベース名を入力します。このチュートリアルでは、
user_behavior_analysisを使用します。すべてのデータ操作はこのデータベースで実行されます。Username
ご利用の StarRocks データベースのユーザー名。
Password
ご利用の StarRocks データベースのパスワード。
-
リソース接続のテスト:接続テストに合格したら、編集完了 をクリックして StarRocks データソースの作成を完了します。
4. MySQL データソースの作成
Management Center ページで、Data Source ページに移動し、Add Connection をクリックします。
[接続を追加] ダイアログボックスで、MySQL を検索して選択します。
[MySQL データソースを作成] ページで、パラメーターを設定します。このチュートリアルでは、開発環境と本番環境の両方でサンプル値を使用します。
パラメーター
説明
Data Source Name
データソースの名前を入力します。このチュートリアルでは、user_behavior_analysis_mysql を入力します。
Description
説明を入力します。このチュートリアル固有のデータソースは、バッチ同期タスクのテストデータを提供します。読み取り専用であり、Data Integration でのみ使用できます。
設定モード
User-created Data Store with Public IP Addresses を選択します。
Connection Address
ホスト IP アドレス:
rm-bp1z69dodhh85z9qa.mysql.rds.aliyuncs.comポート:
3306
Database Name
データベース名を入力します。このチュートリアルでは、
workshopを入力します。Username
ユーザー名を入力します。このチュートリアルでは、workshop を入力します。
Password
パスワードを入力します。このチュートリアルでは、workshop#2017 を入力します。
Authentication Method
認証なし。
ターゲットリソースグループの行にある コネクテッドステート (開発環境) と 接続ステータス (本番環境) をクリックし、テスト接続 をクリックします。接続テストが完了し、ステータスが 接続可能 と表示されるまで待ちます。
Complete Creation をクリックします。
5. HttpFile データソースの作成
ページに移動し、Add Connection をクリックして [HttpFile] を選択し、[HttpFile データソースを作成] をクリックして、現在の DataWorks ワークスペースに HttpFile データソースを追加します。
設定中に、[開発環境] と [本番環境] の両方を有効にし、両方に同じ情報を入力します。[デフォルトヘッダー] にはデフォルト値の {} を保持します。
-
HttpFile データソースの基本情報を設定します。
HttpFile データソースを作成する際の Basic information のパラメーターは次のとおりです。
パラメーター
説明
Data Source Name
ワークスペース内のパブリック HttpFile データソースの表示名を入力します。このチュートリアルでは、user_behavior_analysis_httpfile を使用します。
Description
データソースのオプションの説明を入力します。
このデータソースは DataWorks チュートリアル用に提供されています。バッチ同期タスクのテストデータへのアクセスを提供し、Data Integration シナリオでの読み取り操作のみを目的としています。他のモジュールはサポートされていません。
URL ドメイン名
入力します:
https://dataworks-workshop-2024.oss-cn-shanghai.aliyuncs.com。 -
リソース接続のテスト:接続テストに成功したら、編集完了 をクリックして HttpFile データソースの作成を完了します。
次のステップ
これで環境の準備が整いました。次のチュートリアルに進み、ユーザーの基本情報とウェブサイトのアクセスログデータを StarRocks に同期する方法を学びます。詳細については、「データの同期」をご参照ください。