Alibaba Cloud DLF Rest カタログの統合

Alibaba Cloud Data Lake Formation (DLF) は、クラウドネイティブデータレイクアーキテクチャのコアコンポーネントとして、ユーザーがクラウドネイティブデータレイクソリューションを迅速に構築できるよう支援します。DLFは、データレイク上での統一されたメタデータ管理、エンタープライズレベルの権限制御、複数のコンピュートエンジンとのシームレスな統合を提供し、データサイロを打破してビジネスインサイトを可能にします。

• 統一されたMetadataとStorage

  ビッグデータコンピュートエンジンは単一のレイクメタデータとストレージを共有し、レイク製品間でデータがシームレスに流れます。

• 統一されたPermission管理

  ビッグデータコンピュートエンジンは単一のレイクテーブル権限設定を共有し、一度の設定で全体的な効果を実現します。

• Storage最適化

  小ファイル圧縮、期限切れスナップショットクリーンアップ、パーティション再編成、廃止ファイルクリーンアップなどの最適化戦略を提供し、ストレージ効率を向上させます。

• 包括的なCloudエコシステムサポート

  Alibaba Cloud製品との深い統合により、ストリーミングおよびバッチコンピュートエンジンを含む、すぐに使える機能と向上したユーザーエクスペリエンスを提供します。

DLFはバージョン2.5からPaimon Rest カタログをサポートしています。Dorisはバージョン3.0.3/3.1.0からDLF 2.5+ Paimon Rest カタログとの統合をサポートし、DLFへのシームレスな接続を可能にしてPaimonテーブルデータにアクセスし分析できます。この記事では、Apache DorisをDLF 2.5+に接続してPaimonテーブルデータにアクセスする方法を説明します。

ヒント

この機能はDorisバージョン3.0.3/3.1.0からサポートされています。

使用ガイド

01 DLFサービスを有効化

DLF公式ドキュメントを参照してDLFサービスを有効化し、対応するカタログ、Database、tableを作成してください。

02 EMR Spark SQLを使用してDLFにアクセス

• 接続

  spark-sql --master yarn \
      --conf spark.driver.memory=5g \
      --conf spark.sql.defaultCatalog=paimon \
      --conf spark.sql.catalog.paimon=org.apache.paimon.spark.SparkCatalog \
      --conf spark.sql.catalog.paimon.metastore=rest \
      --conf spark.sql.extensions=org.apache.paimon.spark.extensions.PaimonSparkSessionExtensions \
      --conf spark.sql.catalog.paimon.uri=http://<region>-vpc.dlf.aliyuncs.com \
      --conf spark.sql.catalog.paimon.warehouse=<your-catalog-name> \
      --conf spark.sql.catalog.paimon.token.provider=dlf \
      --conf spark.sql.catalog.paimon.dlf.token-loader=ecs

対応するwarehouseとuriアドレスを置き換えてください。

• データの書き込み

  USE <your-catalog-name>;
  
  CREATE TABLE users_samples
  (
      user_id INT,             
      age_level STRING,           
      final_gender_code STRING,    
      clk BOOLEAN
  );
  
  INSERT INTO users_samples VALUES
  (1, '25-34', 'M', true),
  (2, '18-24', 'F', false);
  
  INSERT INTO users_samples VALUES
  (3, '25-34', 'M', true),
  (4, '18-24', 'F', false);
  
  INSERT INTO users_samples VALUES
  (5, '25-34', 'M', true),
  (6, '18-24', 'F', false);

以下のエラーが発生した場合は、/opt/apps/PAIMON/paimon-dlf-2.5/lib/spark3からpaimon-jindo-x.y.z.jarを削除してから、Sparkサービスを再起動して再試行してください。

```
Ambiguous FileIO classes are:
org.apache.paimon.jindo.JindoLoader
org.apache.paimon.oss.OSSLoader
```

03 Dorisを使用してDLFに接続

• Paimon カタログを作成

  CREATE CATALOG paimon_dlf_test PROPERTIES (
      'type' = 'paimon',
      'paimon.catalog.type' = 'rest',
      'uri' = 'http://<region>-vpc.dlf.aliyuncs.com',
      'warehouse' = '<your-catalog-name>',
      'paimon.rest.token.provider' = 'dlf',
      'paimon.rest.dlf.access-key-id' = '<ak>',
      'paimon.rest.dlf.access-key-secret' = '<sk>'
  );

• DorisはDLFから返される一時的な認証情報を使用してOSSオブジェクトストレージにアクセスするため、追加のOSS認証情報は不要です。

  • DLFは同一VPC内からのみアクセス可能です。正しいURIアドレスを提供することを確認してください。

• データのクエリ

  SELECT * FROM users_samples ORDER BY user_id;
  +---------+-----------+-------------------+------+
  | user_id | age_level | final_gender_code | clk  |
  +---------+-----------+-------------------+------+
  |       1 | 25-34     | M                 |    1 |
  |       2 | 18-24     | F                 |    0 |
  |       3 | 25-34     | M                 |    1 |
  |       4 | 18-24     | F                 |    0 |
  |       5 | 25-34     | M                 |    1 |
  |       6 | 18-24     | F                 |    0 |
  +---------+-----------+-------------------+------+

• システムテーブルのクエリ

  SELECT snapshot_id, commit_time, total_record_count FROM users_samples$snapshots;
  +-------------+-------------------------+--------------------+
  | snapshot_id | commit_time             | total_record_count |
  +-------------+-------------------------+--------------------+
  |           1 | 2025-08-09 05:56:02.906 |                  2 |
  |           2 | 2025-08-13 03:41:32.732 |                  4 |
  |           3 | 2025-08-13 03:41:35.218 |                  6 |
  +-------------+-------------------------+--------------------+

• インクリメンタルリーディング

  SELECT * FROM users_samples@incr('startSnapshotId'=1, 'endSnapshotId'=2) ORDER BY user_id;
  +---------+-----------+-------------------+------+
  | user_id | age_level | final_gender_code | clk  |
  +---------+-----------+-------------------+------+
  |       3 | 25-34     | M                 |    1 |
  |       4 | 18-24     | F                 |    0 |
  +---------+-----------+-------------------+------+