Airflow连接Snowflake账户问题：账户信息格式困惑

核心结论：账户字段直接复制Snowflake官方提供的完整标识符 #

Snowflake的账户标识符格式分两种，取决于你的账户架构：

• 旧版无组织账户：格式为 <账户定位器>.<区域标识>，例如 ALB33048.CLBB7689
• 新版组织架构账户：格式为 <组织名>-<账户名>.<区域标识>，例如 KKTQCVP-ALB33048.CLBB7689

操作步骤 #

1. 获取正确的账户标识符
   登录Snowflake Web UI，点击右上角账户名称 → 选择「Account」→ 复制「Account identifier」字段的完整内容，直接粘贴到Airflow连接的Account输入框中即可，无需自行拼接。

2. Airflow连接配置要点
   在Airflow管理GUI的Snowflake连接页面，确保以下配置正确：

   • Conn Id：自定义连接ID（如snowflake_default）
   • Conn Type：选择「Snowflake」
   • Account：粘贴从Snowflake复制的完整标识符（不要添加https://、端口或其他额外字符）
   • Warehouse、Database、Schema：填写你需要访问的对应资源名称
   • Role：填写有权限的Snowflake角色（如ACCOUNTADMIN）
   • Login、Password：Snowflake的登录凭据

3. DAG代码示例验证
   用以下极简DAG测试连接是否正常：

   from datetime import datetime
   from airflow import DAG
   from airflow.providers.snowflake.operators.snowflake import SnowflakeOperator
   
   with DAG(
       'snowflake_connection_test',
       schedule_interval=None,
       start_date=datetime(2024, 1, 1),
       catchup=False
   ) as dag:
       test_query = SnowflakeOperator(
           task_id='test_snowflake_connection',
           snowflake_conn_id='snowflake_default',  # 对应你配置的Conn Id
           sql="SELECT CURRENT_VERSION();"
       )
   

排查失败原因 #

如果仍连接失败，检查以下几点：

• 确认Airflow服务器网络可访问Snowflake（端口443）
• 验证Snowflake角色是否有权限访问指定的仓库、数据库
• 检查密码是否正确，特殊字符无需转义，直接填写
• 账户标识符是否完全匹配，无多余空格或大小写错误（Snowflake标识符不区分大小写，但建议严格复制）

内容的提问来源于stack exchange，提问作者Sorush Omidvar