データベースノード - DataWorks - Alibaba Cloud ドキュメントセンター

DataWorks では、SQL タスク開発、定期スケジュール、および他のジョブとの統合のために、複数のタイプのデータベースノードを作成できます。

前提条件

使用する RAM ユーザーがワークスペースに追加されていること。
RAM ユーザーを使用してタスクを開発する場合、RAM ユーザーをメンバーとしてワークスペースに追加し、[開発] ロールまたは [ワークスペース管理者] ロールを RAM ユーザーに割り当てる必要があります。ワークスペース管理者ロールには、必要以上の権限があります。ワークスペース管理者ロールを割り当てる場合は注意してください。メンバーを追加してロールを割り当てる方法の詳細については、「ワークスペースメンバーを追加してロールを割り当てる」をご参照ください。
データソースがワークスペースに追加されていること。
- データソースが サーバーレスリソースグループ に接続されていること。詳細については、「ネットワーク接続ソリューション」をご参照ください。
- データソースが 接続文字列モード でワークスペースに追加されていること。詳細については、「データソースを追加および管理する」をご参照ください。
- データソースを使用してデータベースノードを作成できること。詳細については、「サポートされているデータソース」をご参照ください。
データベースノードを使用してタスクを開発する前に、データベースノードに対応するデータソースのノードが作成されていること。詳細については、「タスクノードを作成する」をご参照ください。

手順 1: データベースノードを使用してタスクを開発する

データベースノードを作成した後、データベースノードに基づいてタスクを開発できます。
1. データソースを選択します。
  [データソースの選択] ドロップダウンリストから、タスクの開発に使用するデータソースを選択します。使用するデータソースがドロップダウンリストに見つからない場合は、[データソースの追加] をクリックして、[データソース] ページでデータソースを追加します。
  説明
  - 標準モードのワークスペースでは、本番環境と開発環境の両方で構成されているデータソースのみが [データソースの選択] ドロップダウンリストに表示されます。
  - データベースノードを使用してタスクを開発できるのは、本番環境で 接続文字列モードで追加されたデータソース のみです。
2. SQL 文を記述します。
  SQL エディターで SQL 文を記述して、タスクを作成します。この例では、単純な SQL クエリ文を使用しています。
```
SELECT * FROM you_table_name;  -- テーブルをクエリします。
SELECT '${var}'; -- スケジューリングパラメータを構成します。
```
  説明
  ビジネス要件とデータソースでサポートされている構文に基づいて、実行する SQL 文を記述できます。
3. デバッグ用のリソースグループを選択します。
  ノードの構成タブの右側ナビゲーションウィンドウで、[デバッグ構成] をクリックします。 [デバッグ構成] タブで、[dataworks 構成] をクリックします。次に、[リソースグループ] ドロップダウンリストから、接続テストに合格した既存のサーバーレスリソースグループを選択します。
  説明
  インターネットまたは VPC (Virtual Private Cloud) 経由でデータソースにアクセスする場合は、データソースに接続されているスケジューリング用のリソースグループを使用する必要があります。詳細については、「ネットワーク接続ソリューション」をご参照ください。
4. デバッグパラメータを構成します。
  ノードの構成タブの右側ナビゲーションウィンドウで、[デバッグ構成] をクリックします。 [デバッグ構成] タブで、[スクリプトパラメータ] をクリックします。次に、ノードコードで変数を定義し、変数に値を割り当てます。
5. デバッグ構成が完了したら、アイコンをクリックして SQL ノードを保存します。次に、アイコンをクリックして SQL スクリプトを実行し、SQL スクリプトが期待どおりに動作するかどうかを確認します。
SQL スクリプトのデバッグが完了したら、SQL エディターの右側にある [プロパティ] をクリックして、タスクスケジューリングプロパティを構成します。

手順 2: データベースノードをデプロイし、O&M 操作を実行する

ノードコードとスケジューリング設定を構成した後、ノードを本番環境にデプロイできます。
デプロイが完了したら、[オペレーションセンター] の [自動トリガーノード] ページに移動して、デプロイされた自動トリガータスクを表示し、タスクで O&M 操作を実行します。ノードは、構成したスケジューリング設定に基づいて、想定どおりに定期的に実行されます。詳細については、「オペレーションセンターの概要」をご参照ください。

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

DataWorks では、さまざまなデータソースタイプのデータベースノードを作成できます。次の表に、データベースノードをサポートするデータソースのタイプを示します。

説明

データベースノードの作成に使用されるデータソースは、接続文字列モード でワークスペースに追加する必要があります。
特定のデータベースはストアドプロシージャ機能をサポートしています。ただし、ストアドプロシージャ機能は DataWorks Data Studio では使用できません。

データベースノードをサポートするデータソースのタイプ

データソース	説明
MySQL	MySQL は、データの格納と処理に使用される一般的なリレーショナルデータベース管理システム (RDBMS) です。小型、高速、低コストという利点があります。詳細については、「MySQL」をご参照ください。
SQL Server	SQL Server は、データの格納と処理に使用される RDBMS です。信頼性が高く、効率的で安全なデータ管理および分析サービスを提供します。詳細については、「SQL Server」をご参照ください。
Oracle	Oracle は、データの格納と処理に使用される RDBMS です。信頼性が高く、効率的で安全なデータ管理および分析サービスを提供します。詳細については、「Oracle」をご参照ください。
PostgreSQL	PostgreSQL は、強力で柔軟なオープンソース RDBMS です。スケーラビリティと安定性に優れており、強力なデータモデルとさまざまなコア機能を提供します。詳細については、「PostgreSQL」をご参照ください。
StarRocks	StarRocks は、Massively Parallel Processing (MPP) フレームワークに基づいて構築された、次世代の高速データ分析エンジンです。より簡単かつ効率的にデータを分析できます。詳細については、「StarRocks」をご参照ください。
DRDS	PolarDB for Xscale (PolarDB-X) (旧称 DRDS) は、分散データベースサービスです。スケールアウト操作を実行して、リレーショナルデータベースを大量のデータの格納とアクセスをサポートする分散システムにアップグレードできます。 PolarDB-X は、MySQL などのリレーショナルデータベースの元の機能を維持します。詳細については、「概要」をご参照ください。
PolarDB for MySQL	PolarDB for MySQL は、Alibaba Cloud によって開発された次世代のクラウドネイティブデータベースサービスです。このサービスは、コンピューティングとストレージを分離し、統合されたソフトウェアとハードウェアを使用します。 PolarDB for MySQL は、高スケーラビリティ、高パフォーマンス、およびマスストレージを特長とする、安全で信頼性の高いデータベースサービスです。 PolarDB for MySQL は MySQL と PostgreSQL のエコシステムと 100% 互換性があり、Oracle と高度に互換性があります。詳細については、「PolarDB for MySQL Enterprise Edition とは」をご参照ください。
PolarDB for PostgreSQL	PolarDB for PostgreSQL は、Alibaba Cloud によって開発されたクラウドネイティブのリレーショナルデータベースサービスです。 PolarDB for PostgreSQL は PostgreSQL と 100% 互換性があり、Oracle と高度に互換性があります。 PolarDB for PostgreSQL は、迅速なスケーラビリティ、高パフォーマンス、マスストレージ、および高いセキュリティと信頼性を特長としています。また、Alibaba Cloud によって開発された多次元、マルチモデル、時空間情報エンジン Ganos と、オープンソースの地理情報エンジン PostGIS もサポートしています。詳細については、「PolarDB for PostgreSQL Enterprise Edition とは」をご参照ください。
Apache Doris	Apache Doris は、レポート分析、アドホッククエリ、データレイクをまたがるフェデレーテッドクエリなどのシナリオで使用できる、高パフォーマンスのリアルタイム分析データベースです。詳細については、「Introduction to Apache Doris」をご参照ください。
MariaDB	MariaDB は、MySQL と高度に互換性のあるオープンソースのリレーショナルデータベース管理システム (RDBMS) です。シームレスに MySQL を置き換えることができます。 MySQL をアンインストールした後、アプリケーションコードを変更せずに、MySQL と同じ場所に MariaDB をインストールできます。詳細については、「MariaDB Server Documentation」をご参照ください。
SelectDB	SelectDB は、Apache Doris に基づく次世代のリアルタイムデータウェアハウスサービスです。企業のリアルタイムビッグデータ分析要件を満たす、費用対効果が高く使いやすいデータ分析サービスを提供します。詳細については、「SelectDB」をご参照ください。
Amazon Redshift	Amazon Redshift は、クラウド内のフルマネージドのペタバイトスケールのデータウェアハウスサービスです。 Amazon Redshift Serverless を使用すると、プリセットデータウェアハウスで構成操作を実行せずに、データにアクセスして分析できます。詳細については、「Amazon Redshift とは」をご参照ください。
SAP HANA	SAP HANA は、データベース、データ処理、およびアプリケーションプラットフォームの機能を組み合わせた、高パフォーマンスのインメモリデータベースおよびアプリケーションプラットフォームであり、エンタープライズレベルのインメモリコンピューティング機能を提供します。詳細については、「SAP HANA Platform」をご参照ください。
Vertica	Vertica は、大規模なデータセットとデータウェアハウスの複雑なクエリとトランザクションを高スループットで処理できる、高パフォーマンスの列指向データベース管理システム (DBMS) です。 Vertica は、主にビッグデータ分析とリアルタイムクエリに使用されます。詳細については、Vertica 公式 Web サイトをご覧ください。
DM	DM は、業務システムに統合されたオンライントランザクション処理 (OLTP) データベースです。分散型エラスティックコンピューティングとクラウドコンピューティングの利点を組み合わせ、高い柔軟性、信頼性、セキュリティ、使いやすさを特長としています。詳細については、DM 公式 Web サイトをご覧ください。
KingbaseES	KingbaseES は、大規模なリレーショナルデータベース管理システム (RDBMS) です。 SQL 標準をサポートし、大量のデータが処理され、高い同時実行性と高可用性が要求されるエンタープライズレベルのシナリオに適しています。詳細については、KingbaseES 公式 Web サイトをご覧ください。
OceanBase	OceanBase は、Ant Group と Alibaba Cloud によって開発された分散リレーショナルデータベースです。 OceanBase は、強力なデータ整合性、高可用性、高パフォーマンス、オンラインスケーラビリティ、低コストを特長としており、SQL 標準および主流のリレーショナルデータベースと高度に互換性があります。詳細については、「OceanBase データベースとは」をご参照ください。
Db2	Db2 は、データの格納、取得、および管理に使用されるリレーショナルデータベース管理システム (RDBMS) です。 Db2 を使用すると、大規模なデータセットとデータウェアハウスの複雑なクエリとトランザクションを高スループットで処理できます。詳細については、Db2 公式 Web サイトをご覧ください。
GBase 8a	GBase 8a は、大量のデータの格納と高同時実行データの読み取りと書き込みをサポートするリレーショナルデータベース管理システム (RDBMS) です。 GBase 8a は、公共サービス、金融、電気通信、エネルギーなどの分野で一般的に使用されています。 GBase 8a は SQL 標準をサポートし、データパーティション、負荷分散、ディザスタリカバリとバックアップなど、さまざまなエンタープライズレベルの機能を提供します。詳細については、GBase 8a 公式 Web サイトをご覧ください。