如何在Metabase UI中自动识别AWS Redshift的外键映射？

一、先确认Redshift外键的元数据完整性 #

Redshift的外键属于逻辑约束，Metabase依赖读取系统视图获取外键信息，先通过以下SQL确认你的外键在Redshift中已正确注册：

SELECT
    tc.table_name AS foreign_table,
    kcu.column_name AS foreign_column,
    ccu.table_name AS referenced_table,
    ccu.column_name AS referenced_column
FROM
    information_schema.table_constraints AS tc
JOIN
    information_schema.key_column_usage AS kcu
    ON tc.constraint_name = kcu.constraint_name
JOIN
    information_schema.constraint_column_usage AS ccu
    ON ccu.constraint_name = tc.constraint_name
WHERE
    tc.constraint_type = 'FOREIGN KEY';

如果查询能返回完整的外键数据，说明Redshift元数据没问题，问题出在Metabase的配置或刷新逻辑上。

二、配置Metabase正确读取Redshift外键 #

1. 检查Redshift用户权限
   • 确保Metabase连接Redshift使用的账号拥有SELECT权限访问information_schema和pg_catalog下的系统表，这是Metabase读取元数据的前提。
2. 执行Metabase深度元数据刷新
   • 不要使用普通的“刷新数据库”，而是进入数据库详情页：
     1. 点击右上角齿轮图标 → “同步数据库架构”
     2. 勾选**“重新扫描字段值”和“刷新元数据”**，执行同步
        深度刷新会强制Metabase重新拉取所有系统元数据，包括外键约束。

三、自动化批量导入外键（若自动识别失效） #

如果上述方法无效，可通过Metabase API批量创建外键关联：

1. 获取Metabase API密钥
   • 进入Metabase个人设置 → “API密钥”，生成并复制密钥。
2. 编写批量处理脚本
   核心逻辑是从Redshift导出外键数据，匹配Metabase中表和字段的ID，再调用API创建关联，示例Python代码片段：

   import requests
   import psycopg2
   
   # Metabase配置
   METABASE_URL = "http://你的Metabase地址"
   API_KEY = "你的API密钥"
   HEADERS = {"X-Metabase-Session": API_KEY}
   
   # 连接Redshift
   conn = psycopg2.connect(
       dbname="你的数据库名",
       user="Redshift账号",
       password="密码",
       host="Redshift主机地址",
       port="5439"
   )
   cursor = conn.cursor()
   
   # 查询Redshift外键
   cursor.execute("""
       SELECT tc.table_name, kcu.column_name, ccu.table_name, ccu.column_name
       FROM information_schema.table_constraints tc
       JOIN information_schema.key_column_usage kcu ON tc.constraint_name = kcu.constraint_name
       JOIN information_schema.constraint_column_usage ccu ON ccu.constraint_name = tc.constraint_name
       WHERE tc.constraint_type = 'FOREIGN KEY'
   """)
   fk_list = cursor.fetchall()
   
   # 获取Metabase数据库ID
   db_res = requests.get(f"{METABASE_URL}/api/database", headers=HEADERS)
   db_id = [db["id"] for db in db_res.json() if db["name"] == "你的Redshift数据库名"][0]
   
   # 构建字段ID映射表
   fields_res = requests.get(f"{METABASE_URL}/api/database/{db_id}/fields", headers=HEADERS)
   field_map = {}
   for field in fields_res.json():
       field_map[(field["table"]["name"], field["name"])] = field["id"]
   
   # 批量创建外键
   for fk_table, fk_col, ref_table, ref_col in fk_list:
       fk_field_id = field_map.get((fk_table, fk_col))
       ref_field_id = field_map.get((ref_table, ref_col))
       if fk_field_id and ref_field_id:
           requests.post(
               f"{METABASE_URL}/api/field/{fk_field_id}/foreign-key",
               json={"field_id": ref_field_id},
               headers=HEADERS
           )
   

   注意：需安装requests和psycopg2-binary依赖，根据Metabase版本调整API端点（旧版本路径可能不同）。

四、排查版本兼容性 #

旧版本Metabase可能存在Redshift元数据读取的bug，建议升级到最新稳定版，新版本对Redshift的元数据支持更完善。

内容的提问来源于stack exchange，提问作者Jugal Bhatt