Federate Lakehouse Catalog

作者 gemini-cli-extensions2df10e25bbf7Apache-2.0215 个星标收录于 2026年10月8日更新于 2026年10月8日仓库今天更新

Sets up Google Cloud Lakehouse federated catalogs to remote Iceberg REST Catalogs. Currently supported catalogs: Databricks Unity, AWS Glue. Supported clouds hosting those catalogs: GCP, AWS. The primary use case is connecting to remote data to query it from GCP engines (BigQuery, Spark). Examples of when to use this: "federate my lakehouse catalog to databricks", "query data in databricks", "query data in s3", "connect to aws glue". Do NOT use for direct remote database SQL execution (e.g., Databricks SQL) or managing remote clusters and infrastructure (e.g., Databricks clusters, AWS Glue jobs).

仅含说明DevOps & Cloud
AI 生成的概览

设置 Google Cloud Lakehouse 联合目录,以连接远程 Databricks Unity 或 AWS Glue Iceberg REST 目录。

功能
该技能引导代理创建 BigQuery BigLake 联合目录,指向远程 Iceberg REST 目录,即 Databricks Unity Catalog 或 AWS Glue Data Catalog。内容涵盖信息收集与区域选择、API 验证、在 Secret Manager 中存储凭据、AWS 的 IAM 角色与信任策略配置、目录创建与刷新配置,以及通过列出命名空间进行验证。最终产出可在 BigQuery、Spark 等 GCP 引擎中查询的可用联合目录。
适用场景
当用户希望联合湖仓目录时使用,例如从 Google Cloud 查询存放在 Databricks 或通过 AWS Glue 存放在 S3 中的数据。它不适用于直接执行远程数据库 SQL,也不用于管理远程集群和基础设施。
运行要求
需要带 alpha 组件的 gcloud CLI 和 BigLake API,Glue 流程还需要 AWS CLI。需要具有管理权限的有效 Google Cloud 项目、用于 Databricks 凭据的 Secret Manager、Databricks 工作区 URL 和 OAuth 服务主体凭据,或用于创建 IAM 角色和策略的 AWS 管理员权限。需要访问 Google Cloud 和 AWS 的网络。该技能不附带脚本,仅为操作说明。

Federate Lakehouse Catalog via Cross-cloud Lakehouse

This skill describes how to set up a federated catalog in BigQuery to query remote catalogs like Databricks Unity Catalog or AWS Glue Data Catalog data in AWS over the public internet.

Prerequisites

  • For Databricks: Databricks Workspace URL and OAuth Service Principal (Client ID and Secret) with read access.
  • For AWS Glue: AWS Administrator access to create IAM roles and permissions policies.
  • Active Google Cloud project with administrative access to create lakehouse resources, and secrets in the case of Databricks.

Procedure

Step 1: Information Gathering and Region Selection

Before running any commands, the agent MUST collect the following information from the user:

  1. Determine which catalog the user wants to federate to (e.g., Databricks Unity or AWS Glue) and verify it is supported.
  2. Determine where the remote data is located (the specific AWS region).
  3. Using the Region Pairing Best Practice in the Gotchas section, help the user pick the optimal GCP region to minimize latency.
  4. Collect the necessary configuration variables for the chosen flow (e.g., Databricks credentials or AWS Account ID).

Only proceed to the next steps once this information is confirmed.

Step 2: API Verification

Verify that the required Google Cloud APIs are enabled for the project:

bash
gcloud services check biglake.googleapis.com

If the API is not enabled, explicitly ask the user for permission to enable it. Do NOT proceed without their confirmation.

Flow A: Databricks Unity Catalog

1. Create a Regional Secret for Credentials

Store the Databricks client ID and secret in Secret Manager. Ensure the secretmanager.googleapis.com API is enabled. The secret MUST be in the same region as your Lakehouse catalog.

  1. Create a JSON file named credentials.json:
json
{  "client_id": "<CLIENT_ID>",  "client_secret": "<CLIENT_SECRET>"}
  1. Set the Secret Manager API endpoint override for the region:
bash
gcloud config set api_endpoint_overrides/secretmanager https://secretmanager.<REGION>.rep.googleapis.com/
  1. Create the secret:
bash
gcloud secrets create <SECRET_NAME> \  --location="<REGION>" \  --project="<PROJECT_ID>" \  --data-file=credentials.json
2. Create the Federated Catalog

Create a BigLake Iceberg catalog of type federated pointing to Databricks.

bash
gcloud alpha biglake iceberg catalogs create <CATALOG_NAME> \   --project="<PROJECT_ID>" \   --primary-location="<REGION>" \   --catalog-type="federated" \   --federated-catalog-type="unity" \   --secret-name="projects/<PROJECT_ID>/locations/<REGION>/secrets/<SECRET_NAME>" \   --unity-instance-name="<UNITY_INSTANCE_NAME>" \   --unity-catalog-name="<UNITY_CATALOG_NAME>" \   --refresh-interval="300s"
3. Grant Catalog Access to the Secret

Grant the service account created for the catalog access to read the secret.

  1. Get the service account email by describing the catalog:
bash
gcloud alpha biglake iceberg catalogs describe <CATALOG_NAME> \    --project="<PROJECT_ID>" \    --location="<REGION>" \    --format="value(biglake-service-account-id)"
  1. Grant access:
bash
gcloud secrets add-iam-policy-binding <SECRET_NAME> \  --project="<PROJECT_ID>" \  --location="<REGION>" \  --member="serviceAccount:<SERVICE_ACCOUNT_EMAIL>" \  --role="roles/secretmanager.secretAccessor"

Flow B: AWS Glue

1. Create the AWS IAM role with a placeholder trust policy

Lakehouse provisions a Google service account ID after catalog creation. Create the AWS IAM role with a placeholder trust policy first.

  1. Create a file named trust_policy.json:
json
{  "Version": "2012-10-17",  "Statement": [    {      "Effect": "Allow",      "Principal": {        "Federated": "accounts.google.com"      },      "Action": "sts:AssumeRoleWithWebIdentity",      "Condition": {        "StringEquals": {          "accounts.google.com:aud": ["PLACEHOLDER_VALUE"],          "accounts.google.com:sub": ["PLACEHOLDER_VALUE"]        }      }    }  ]}
  1. Run the AWS CLI command to create the role:
bash
aws iam create-role \  --role-name <AWS_ROLE_NAME> \  --assume-role-policy-document file://trust_policy.json \  --max-session-duration 43200
2. Attach a permissions policy

Attach a policy that allows Lakehouse to read from Glue and S3.

[!IMPORTANT] Safe IAM Scoping: The example below uses wildcard structures for illustration. You MUST consult with the user to scope the Resource ARNs to their specific catalog, database, and S3 buckets. Do NOT blindly apply wildcard permissions.

json
{  "Version": "2012-10-17",  "Statement": [    {      "Sid": "GlueRead",      "Effect": "Allow",      "Action": [        "glue:GetCatalog",        "glue:GetDatabase",        "glue:GetDatabases",        "glue:GetTable",        "glue:GetTables"      ],      "Resource": "arn:aws:glue:<AWS_REGION>:<AWS_ACCOUNT_ID>:catalog"    },    {      "Sid": "S3Read",      "Effect": "Allow",      "Action": [        "s3:ListBucket",        "s3:GetObject"      ],      "Resource": [        "arn:aws:s3:::<SPECIFIC_BUCKET>",        "arn:aws:s3:::<SPECIFIC_BUCKET>/*"      ]    }  ]}

Attach this permissions policy to your IAM role.

3. Create the Federated Catalog

When creating an AWS Glue federated catalog, the --glue-warehouse MUST be set to your 12-digit AWS Account ID string (not an S3 bucket URI). Best Practice: Initialize the catalog without specifying a refresh schedule to prevent premature metadata synchronization failures while AWS trust relationships are propagating.

bash
gcloud alpha biglake iceberg catalogs create <CATALOG_NAME> \  --project="<PROJECT_ID>" \  --primary-location="<REGION>" \  --catalog-type="federated" \  --federated-catalog-type="glue" \  --glue-warehouse="<AWS_ACCOUNT_ID>" \  --glue-aws-region="<AWS_REGION>" \  --glue-aws-role-arn="arn:aws:iam::<AWS_ACCOUNT_ID>:role/<AWS_ROLE_NAME>"
4. Update the trust policy

Extract the biglake-service-account-id from the created catalog, and update your AWS IAM role's trust policy to replace PLACEHOLDER_VALUE in the aud and sub conditions with this Google Service Agent ID.

5. Enable background refresh

Update the catalog to activate background refresh once the trust policy is updated.

bash
gcloud alpha biglake iceberg catalogs update <CATALOG_NAME> \  --project="<PROJECT_ID>" \  --refresh-interval="300s"

Querying the Data

Once set up, you can query the tables via BigQuery.

sql
SELECT * FROM `<PROJECT_ID>.<CATALOG_NAME>.<NAMESPACE>.<TABLE_NAME>` LIMIT 10;

Gotchas and Pitfalls

[!IMPORTANT] Regional Isolation: The Secret Manager secret and the Lakehouse catalog MUST be created in the exact same region.

[!TIP] Region Pairing Best Practice: When setting up the federated catalog, choose GCP regions with "Low Latency Dedicated" or "Partner CCI" to ensure optimal performance when federating large datasets across clouds. Examples of optimal pairings: - AWS us-east-1 (N. Virginia) pairs best with GCP us-east4 (Ashburn, VA) - AWS us-west-2 (Oregon) pairs best with GCP us-west1 (The Dalles, OR) - AWS eu-west-2 (London) pairs best with GCP europe-west2 (London) - AWS eu-central-1 (Frankfurt) pairs best with GCP europe-west3 (Frankfurt) For the exhaustive list of mappings, read the full capabilities table at: https://docs.cloud.google.com/lakehouse/docs/regions-capabilities-cross-cloud-lakehouse

[!IMPORTANT] BigQuery Query Location: When querying the federated catalog via BigQuery, you MUST ensure the query runs in the same region as the catalog (e.g., us-east4). If using the bq CLI, use the --location flag.

Step 3: Validation and Next Steps

After completing the setup, the agent MUST validate that the federation is working and propose next steps to the user.

  1. Validate the Connection:

    • Attempt to list the namespaces or tables in the newly federated catalog using the bq CLI or BigQuery API. For example:

      bash
      bq ls --location="<REGION>" <PROJECT_ID>.<CATALOG_NAME>
    • If the command returns a list of namespaces/schemas, the federation is successful.

  2. Troubleshooting:

    • If the validation fails (e.g., permission errors, empty results, timeout), the agent should consult the Cross-Cloud Lakehouse Troubleshooting documentation: https://docs.cloud.google.com/lakehouse/docs/troubleshooting.
    • For AWS Glue, verify that the trust policy correctly references the biglake-service-account-id and that the GCP and AWS regions match your configuration.
    • For Databricks, verify that the secret exists in the correct region and the service account has roles/secretmanager.secretAccessor.
  3. Explore and Propose:

    • Assuming the federation is working, browse the available namespaces and a few key tables.
    • Summarize to the user what kind of data was found (e.g., "I see you have tables related to e-commerce transactions and customer profiles").
    • Propose a business or analytical question to the user that would result in a meaningful query of their data (e.g., "Would you like me to write a query to find the top 5 purchasing customers from last month?").

来源与署名

来源:gemini-cli-extensions/data-agent-kit-starter-pack位于skills/federate-lakehouse-catalog提交2df10e2

许可证: Apache-2.0

内容归原作者所有。SourceWeft 从公开仓库中收录这些内容。

举报或申请下架

更多来自 gemini-cli-extensions/data-agent-kit-starter-pack 的技能

Schema Mapping

gemini-cli-extensions

为 ETL、ELT 或数据集成任务规划源到目标的模式映射,产出文档化的映射宣言。

Data & Analytics215今天更新

Resolving Mcp Region Configs

gemini-cli-extensions

修复区域级 Google Cloud MCP 服务器配置中未替换的区域占位符,使缺失的 MCP 工具得以注册。

DevOps & Cloud215今天更新

Notebook Guidance

gemini-cli-extensions

This skill guides the use of Jupyter notebooks for data analysis, exploration, and visualization, particularly with BigQuery. It outlines best practices for notebook execution and validation (supporting both cell-by-cell execution and full notebook generation depending on tool availability), library installation, and structuring notebooks for clarity. It also covers specific rules for data cleaning, plotting, and integrating with BigQuery SQL and machine learning workflows. Relevant when any of the following conditions are true: 1. The user request involves a data analysis, data exploration, data visualization, or data insights task that requires multiple steps, queries, or visualizations to answer. 2. The user explicitly requests a notebook (.ipynb). 3. You are creating, editing, or executing cells in a Jupyter notebook. 4. You need to query BigQuery from within a notebook. DO NOT use the Python BigQuery client library; instead, you MUST use the `%%bqsql` magics explained in this skill.

待分类215今天更新

Ml Best Practices

gemini-cli-extensions

为机器学习笔记本提供分步方案,涵盖聚类、预测、分类、回归和模型比较。

Data & Analytics215今天更新

Managing Python Dependencies

gemini-cli-extensions

指导代理检测 Python 项目的依赖管理器并正确安装依赖,而不是使用全局 pip。

Software Development215今天更新

Google Cloud Storage Fuse

gemini-cli-extensions

Mounts Cloud Storage buckets as a POSIX file system with Cloud Storage FUSE (gcsfuse). Use when you need to interact with gcsfuse — decide whether FUSE, native gs:// reads, or Filestore/Managed Lustre fits a workload, deploy tuned mounts on GKE, Compute Engine, or Cloud Run, enable and size the file, stat, and list caches, tune mount flags or config-file settings, apply workload profiles, keep ML checkpointing safe (rename atomicity, hierarchical namespace, close-time finalization, concurrent writers), or diagnose slow training, low throughput, or GCS bill spikes on existing mounts with gcsfuse metrics. Covers mount semantics, the gcsfuse CLI and config file, the GKE gcsfuse CSI driver (Workload Identity principal:// bindings, profile StorageClasses, sidecar sizing), and Cloud Run volume mounts. Don't use for bucket administration or data management without a mount (google-cloud-storage-basics) or for fully POSIX-compliant shared file systems (Filestore, Managed Lustre).

待分类215今天更新