如何通过命令行将GCP凭据添加至Airflow？

没问题，我来帮你搞定这个——用Airflow的命令行工具添加GCP服务账户连接其实很直接，关键是要把服务账户的配置信息正确传递到conn-extra参数里。下面是具体的操作步骤和两种常用的命令示例：

方式一：通过服务账户JSON文件路径配置 #

如果你的服务账户密钥文件已经存放在Airflow服务器的某个路径下，可以直接指定文件路径：

airflow connections add 'my_gcp_connection' \
    --conn-type 'google_cloud_platform' \
    --conn-extra '{
        "extra__google_cloud_platform__project": "你的GCP项目ID",
        "extra__google_cloud_platform__key_path": "/绝对路径/gcp-service-account.json",
        "extra__google_cloud_platform__scope": "https://www.googleapis.com/auth/cloud-platform"
    }'

方式二：直接嵌入服务账户JSON内容（适合自动化场景） #

如果是用Ansible这类工具自动化部署，不想依赖服务器上的文件，可以直接把JSON密钥内容转成压缩字符串传入：

airflow connections add 'my_gcp_connection' \
    --conn-type 'google_cloud_platform' \
    --conn-extra '{
        "extra__google_cloud_platform__project": "你的GCP项目ID",
        "extra__google_cloud_platform__scope": "https://www.googleapis.com/auth/cloud-platform",
        "extra__google_cloud_platform__keyfile_dict": '"$(cat gcp-service-account.json | jq -c .)"'
    }'

关键参数说明 #

• --conn-type：必须指定为google_cloud_platform，这是Airflow识别GCP连接的专属类型
• conn-extra里的核心字段：
  • extra__google_cloud_platform__project：替换成你的GCP项目ID
  • key_path：服务账户JSON文件的绝对路径（方式一用）
  • keyfile_dict：压缩后的服务账户JSON字符串（方式二用，jq -c用来把多行JSON转成单行，避免命令行解析错误）
  • scope：指定GCP API的访问权限范围，一般用cloud-platform就能满足大部分场景需求

小提示 #

• 确保运行命令的用户有权限读取服务账户文件（如果用方式一）
• 如果是Airflow 2.x版本，确认你已经正确设置了AIRFLOW_HOME环境变量，或者命令在Airflow的虚拟环境中执行
• 可以用airflow connections get my_gcp_connection命令验证连接是否添加成功

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