DataWorks データマップは、Metadata Collection機能を提供しており、さまざまな DataWorks データソースからメタデータを一元的に統合・管理できます。Data マップでは、すべてのソースから集約されたメタデータを確認できます。本トピックでは、さまざまなデータソースからメタデータを収集・統合し、DataWorks に取り込むクローラーの作成方法について説明します。
概要
メタデータ収集は、エンタープライズグレードの Data マップを構築し、データ資産を一元管理するための中核となる機能です。クローラーは、同一リージョン内の異なるワークスペースに分散している DataWorks データソース(MaxCompute、Hologres、MySQL、CDH Hive など)から、技術的メタデータ(データベース、テーブル、カラムなど)、データリネージ、パーティション情報を自動的に抽出し、DataWorks データマップに統合して、統一的なデータビューを構築します。
メタデータ収集により、以下のことが可能になります。
統一的なデータビューの構築:複数の異種ソースからのメタデータを一元管理することで、データサイロを解消します。
データの検索と発見の実現:データコンシューマーが迅速かつ正確に必要なデータを見つけられるようにします。
エンドツーエンドのデータリネージ分析の実現:データの出所と流れを明確にトレースし、影響分析やトラブルシューティングを容易にします。
データガバナンスの強化:包括的なメタデータに基づき、データ分類、アクセス制御、品質モニタリング、ライフサイクル管理を実施します。
課金
デフォルトでは、各収集タスクは 0.25 CU × タスク実行時間 を消費し、計算ユニット料金が発生します。各成功した収集タスクに対してスケジューリングインスタンスが生成され、スケジューリング料金が発生します。
制限事項
データソースがアクセス制御用の許可リストを使用している場合、事前に設定が必要です。詳細については、「メタデータ収集の許可リスト」をご参照ください。
DataWorks のデプロイメントとデータソースは、同じリージョン内にある必要があります。リージョンをまたいでメタデータを収集する必要がある場合は、データソース作成時にパブリックエンドポイントを使用してください。詳細については、「データソースの作成」をご参照ください。
SSL が有効になっている AnalyticDB for MySQL データソースでは、メタデータ収集はサポートされていません。
エントリーポイント
DataWorks コンソールにログインします。DataWorks コンソールで、対象のリージョンの左側のナビゲーションウィンドウで をクリックします。表示されたページで、入力 データマップ をクリックします。
左側のナビゲーションウィンドウで、
をクリックしてメタデータ収集ページに移動します。
ビルトインクローラー
ビルトインクローラーは、DataWorks プラットフォームによって事前設定され、自動的に実行(ニアリアルタイム)されます。DataWorks と深く統合されたコアメタデータを収集するために使用されます。ユーザーがこれらを作成する必要はありません。収集範囲の管理のみを行います。
Data マップで目的のテーブルが見つからない場合は、 に移動し、関連するテーブルを手動で同期してください。
MaxCompute デフォルトクローラー
このクローラーは、ご利用のアカウント配下の MaxCompute プロジェクトからメタデータを収集します。「詳細」ページで Modify Data Scope をクリックして収集対象のプロジェクトを選択し、Permission Configurations をクリックしてテナント内でのメタデータの可視性を設定できます。
メタデータ収集ページの Built-in セクションで、MaxCompute Default Crawler カードを見つけ、Details をクリックします。
MaxCompute デフォルトクローラーの詳細ページには、次の 2 つのタブがあります。Basic Information および Data Scope。
Basic Information:収集タイプや収集方法などのクローラーの基本プロパティを表示します。この情報は読み取り専用です。
Data Scope:このクローラーがどの MaxCompute プロジェクトからメタデータを収集するかを管理します。
収集範囲の変更:
Data Scope タブに切り替え、Modify Data Scope ボタンをクリックします。
表示されたダイアログで、メタデータを収集する MaxCompute プロジェクトを選択または選択解除します。
重要デフォルトでは、現在のリージョン内でご利用のテナント配下のワークスペースに関連付けられているすべての MaxCompute プロジェクトが範囲に含まれます。データ範囲を変更すると、Data マップで収集されるメタデータオブジェクトは、現在のデータ範囲と一致します。選択解除されたプロジェクトのメタデータは表示されなくなります。
OK をクリックして変更を保存します。
メタデータの可視性設定:
Data Scope リストで対象のプロジェクトを見つけ、Actions 列の Permission Configurations をクリックします。
データガバナンス要件に基づいて、可視性ポリシーを選択します。
Public Within Tenant: テナント内のすべてのメンバーが、このプロジェクトのメタデータを検索および表示できます。
Only members in the associated workspace can search and view.: 特定のワークスペースのメンバーのみがこのプロジェクトのメタデータにアクセスでき、データの隔離を確保します。
DLF デフォルトクローラー
DLF メタデータのリアルタイム収集を有効にするには、DLF コンソールでサービスリンクロール AliyunServiceRoleForDataworksOnEmr にデータリーダー権限を付与する必要があります。
DLF デフォルトクローラーは、ご利用のアカウント配下の Data Lake Formation (DLF) からメタデータを収集します。
メタデータ収集ページの Built-in セクションで、DLF Default Crawler カードを見つけ、Details をクリックして基本情報を表示します。
Data Scope タブに切り替えて、収集範囲に含まれる DLF カタログの一覧とそのテーブル数を確認します。
デフォルトでは、アクセス可能なすべてのカタログ(DLF および DLF-Legacy を含む)が収集されます。
カスタムクローラー
カスタムクローラーを使用すると、環境やエンジン間でメタデータを一元管理できます。
通常のデータソースの場合
Hologres、StarRocks、MySQL、Oracle、CDH Hive などの従来型の構造化または半構造化データソースに対してカスタムクローラーを作成できます。収集タスクを設定することで、システムはソースの物理的なデータベースおよびテーブル構造を深く解析し、カラム属性、インデックス、パーティションなどのメタデータを自動的に抽出・同期します。
メタデータ型データソース(カタログ)の場合
Paimon Catalog など、DLF で管理されていない自己宣言型のネイティブレイクフォーマットメタデータのようなメタデータ型データソースに対しても、クローラーを作成して直接収集できます。
Create Custom Crawler
メタデータ収集ページのカスタムクローラーリストセクションで、[Create Metadata Crawler] をクリックします。
収集タイプの選択:タイプ選択ページで、収集対象のデータソースタイプ(例:Hologres または StarRocks)を選択します。
基本設定とリソースグループの設定:
Basic Configurations:
ワークスペースの選択:データソースを含むワークスペースを選択します。
Select Data Source:ドロップダウンリストから、事前に作成済みの対象データソースを選択します。選択後、システムが自動的にデータソースの詳細を表示します。
Name:後で識別しやすいようにクローラーに名前を付けます。デフォルトでは、データソース名と同じになります。
Resource Group Configuration:
Resource Group:収集タスクを実行するリソースグループを選択します。
Test Network Connectivity:このステップは重要です。Test Network Connectivity をクリックして、リソースグループがデータソースにアクセスできることを確認します。
重要データソースで許可リスト制限が有効になっているかどうかを確認してください。許可リストベースのアクセス制御を使用しているデータソースからメタデータを収集する必要がある場合は、「リソースグループの IP アドレスを許可リストに追加」および「データソースの許可リストの設定」を参照して、許可リスト権限を設定してください。
データソースで許可リスト制限が有効になっていない場合は、「データソースのネットワーク接続の設定」を参照して、データソースのネットワーク接続を確立してください。
接続テストでエラー
Backend service call failed: test connectivity failed.not support data typeが返された場合は、テクニカルサポートに連絡してリソースグループをスペックアップしてください。
メタデータ収集の設定:
Collection Scope:収集するデータベース(database/schema)を定義します。データソースがデータベース単位の場合、デフォルトで対応するデータベースが選択されます。データソース以外のデータベースも追加選択できます。
重要各データベースは 1 つのクローラーでのみ設定できます。データベースがグレーアウトしている場合は、すでに別のクローラーで収集されています。
収集範囲を縮小すると、範囲外のメタデータは Data マップで検索できなくなります。
インテリジェント強化と収集プランの設定:
インテリジェント強化(ベータ版):
AI による説明文の生成:有効にすると、メタデータ収集後に大規模言語モデルの機能を使用して、テーブルおよびカラムのビジネス説明文を自動生成します。これにより、メタデータの可読性と使いやすさが大幅に向上します。収集完了後、Data マップのテーブルオブジェクト詳細ページで AI が生成した情報(テーブル説明やカラム説明など)を確認できます。
Collection Plan:
Trigger Mode: 手動または定期的に選択します。
手動:クローラーは手動でトリガーした場合にのみ実行されます。ワンタイムまたはオンデマンド収集に適しています。
定期:スケジュールタスク(月次、日次、週次、時間単位など)を設定すると、システムが定期的にメタデータを自動更新します。
分単位のスケジュールタスクを設定するには、時間単位の収集サイクルを選択し、すべての分単位粒度を選択して、5 分ごとに実行されるスケジュールタスクを実装します。
重要本番環境のデータソースのみが定期収集をサポートしています。
設定の保存:Save または Save and Run をクリックして、クローラーの作成を完了します。
カスタムクローラーの管理
クローラーを作成すると、カスタムクローラーリストに表示されます。以下の管理操作を実行できます。
リスト操作:リストで直接 Run、Stop、または Delete を実行できます。上部の Filter および Search 機能を使用して、目的のクローラーを素早く検索できます。
重要メタデータクローラーを削除すると、Data マップでこのクローラーによって収集されたメタデータオブジェクトは無効になります。このクローラーからのオブジェクトおよびその詳細情報は、検索・閲覧できなくなります。慎重に操作してください。
バッチ操作:クローラーリストで複数のクローラーを選択し、リスト下部の Batch Run または Batch Stop を使用して、複数の収集タスクを一度にトリガーまたは終了し、管理効率を向上させます。
クローラーのステータス:クローラーリストには、各クローラーの現在のステータスが表示されます。一般的なステータスには、Not Run、Waiting、Running、Successful、Failed、および Manually Terminated があります。
説明クローラーに関連付けられたデータソースが関連付け解除された、または無効になった場合、クローラーは frozen 状態になります。フローズン状態のクローラーは実行できず、削除のみ可能です。
詳細とログの表示:対象のクローラー名をクリックして、詳細ページに移動します。
Basic Information:クローラーのすべての設定項目を表示します。
Data Scope: 表示またはModify Data Scope。
収集がまだ実行されていない場合、テーブル数と最終更新時刻は空になります。
EMR Hive、CDH Hive、Lindorm、ElasticSearch、OTS、MongoDB、および AnalyticDB MySQL の AnalyticDB for Spark は、範囲の変更をサポートしていません。
Run Logs:各収集タスクの実行履歴を追跡します。各タスクの開始時刻、持続時間、ステータス、収集されたデータ量を確認できます。タスクが失敗した場合は、View Logs をクリックすることが、問題の特定と解決のための重要なエントリーポイントとなります。
手動での収集トリガー:詳細ページの右上隅で、Collect Metadata ボタンをクリックして、すぐに収集タスクをトリガーできます。Data マップで新しく作成したテーブルをすぐに確認したい場合に便利です。
次のステップ
メタデータの収集が成功すると、Data マップのさまざまな機能をフル活用できます。
Data マップで収集済みのテーブルを検索し、詳細、カラム情報、パーティション、データプレビューを確認します。詳細については、「テーブルの詳細の表示」をご参照ください。
テーブルの上流および下流のリネージを分析して、エンドツーエンドのデータ処理フローを把握します。詳細については、「データリネージ」をご参照ください。
データ収集にアセットを追加して、ビジネス視点からデータを整理・管理します。詳細については、「データ収集の作成」をご参照ください。
よくある質問
Q:MySQL または他のデータベース型ソースの収集がタイムアウトまたは失敗するのはなぜですか?
A:リソースグループの vSwitch CIDR ブロックを許可リストに追加済みかどうかを確認してください。リソースグループの ネットワークセグメントの切り替え を確認します。
付録:収集範囲と適時性
データソース
Data Source Type | Collection Mode | 収集粒度 | メタデータ更新の適時性 | ||
テーブル/カラム | Partition | リネージ | |||
MaxCompute | デフォルトでシステムが自動収集 | インスタンス | 通常プロジェクト:リアルタイム 外部プロジェクト:T+1 | 中国本土リージョン:リアルタイム 国際リージョン:T+1 | リアルタイム |
Data Lake Formation (DLF) | インスタンス | リアルタイム 重要 リアルタイム収集を有効にするには、DLF コンソールでサービスリンクロール | リアルタイム | リネージは、Serverless Spark、Serverless StarRocks、Serverless Flink、および EMR Impala エンジンの DLF メタデータに対してサポートされています。他のエンジンはサポートされていません。 | |
Hologres | クローラーを手動で作成 | データベース | 収集サイクルに依存 | リアルタイム | |
EMR Hive | インスタンス | 収集サイクルに依存 | 収集サイクルに依存 | リアルタイム | |
CDH Hive | インスタンス | 収集サイクルに依存 | リアルタイム | リアルタイム | |
StarRocks | データベース |
| リアルタイム 重要 インスタンスモード のみがリネージ収集をサポートします。接続文字列モード はリネージ収集をサポートしません。 | ||
AnalyticDB for MySQL | データベース | 収集サイクルに依存 | リアルタイム 説明 AnalyticDB for MySQL インスタンスでデータリネージ機能を有効にするには、チケットを送信してください。 | ||
AnalyticDB for Spark | インスタンス | リアルタイム | リアルタイム | ||
AnalyticDB for PostgreSQL | データベース | 収集サイクルに依存 | リアルタイム | ||
Lindorm | インスタンス | 収集サイクルに依存 | リアルタイム | ||
OTS | インスタンス | 収集サイクルに依存 | |||
MongoDB | インスタンス | 収集サイクルに依存 | |||
ElasticSearch | インスタンス | 収集サイクルに依存 | T+1 更新 | ||
Paimon Catalog | カタログ | 収集サイクルに依存 | 収集サイクルに依存 | ||
その他のデータソースタイプ(MySQL、PostgreSQL、SQL Server、Oracle、ClickHouse、SelectDB、OceanBase など) | データベース | 収集サイクルに依存 | |||
表中の「収集サイクルに依存」とは、設定したクローラーの収集プラン(月次、日次、週次、時間単位など)に基づいて、メタデータが定期的に更新されることを意味します。
AnalyticDB for Spark と AnalyticDB for MySQL は、メタデータ収集のエントリーポイントを共有しています。
タスクコード
Data マップは、タスクコードの検索とクイックナビゲーションをサポートしています。以下に、検索可能なコードの範囲を示します。
コードソース | 収集範囲 | 収集トリガー方法 |
Data Studio | Data Studio - ノードを作成してコードを編集 | 自動収集 |
Legacy Data Studio | Legacy Data Studio - ノードを作成してコードを編集 | |
Data Analysis | Data Analysis - SQL クエリを作成してコードを編集 | |
Data Service | Data Service - API データプッシュサービスを作成 |
API アセット
Data マップは、Data Service API のメタデータの表示をサポートしています。以下にその内容を示します。
API Type | 収集範囲 | 収集トリガー方法 |
API 生成(ウィザードモード) | Data Service - ウィザードモードで API を作成 | 自動収集 |
API 生成(スクリプトモード) | Data Service - スクリプトモードで API を作成 | |
API 登録 | Data Service - API を登録 | |
API オーケストレーション | Data Service - API オーケストレーションを作成 |
AI アセット
Data マップは、AI アセットの表示と管理をサポートし、データおよびモデルの出所、使用状況、進化を追跡するための AI アセットリネージを提供します。以下に、各 AI アセットタイプのサポート内容を示します。
アセットタイプ | 収集範囲 | 収集トリガー方法 |
データセット |
| 自動収集 |
AI モデル | PAI - モデルトレーニングタスク/モデルの登録/モデルサービスのデプロイ | |
アルゴリズムタスク | PAI - トレーニングタスク/ワークフロータスク/分散トレーニングタスク | |
モデルサービス | PAI - モデルサービスのデプロイ(EAS デプロイ) |
Workspace
Data マップは、ワークスペースメタデータの表示をサポートしています。以下にその内容を示します。
プロジェクト | Collection Mode | 収集トリガー方法 |
ワークスペース | DataWorks - ワークスペースの作成 | 自動収集 |