Airflow 3.1与ETL脚本集成连接故障：API Server替代WebServer后日志URL异常

一、日志读取报错（No host supplied）解决 #

报错核心是生成的日志URL缺失主机地址，由Airflow日志服务配置不完整导致：

• 检查airflow.cfg配置文件，找到base_log_url参数，确保设置为包含主机地址的完整URL，例如：

  base_log_url = http://your-api-server-ip:8793/log
  

• 若使用环境变量配置，确认AIRFLOW__WEBSERVER__BASE_LOG_URL（Airflow 3.1中对应API Server的日志地址）已正确赋值，避免遗漏主机部分
• 配置修改后，重启Airflow调度器和API Server服务，确保配置生效

二、MySQL连接功能异常排查 #

针对ETL脚本无法连接MySQL的问题，按以下步骤逐一验证：

• 基础连接配置检查：
  • 通过Airflow CLI或API查看MySQL连接的配置项，确认主机地址、端口、用户名、密码、目标数据库名全部正确，注意连接类型需匹配对应MySQL驱动（如MySQL或MySQL (Python)）
  • 在Airflow工作节点上执行命令直接测试MySQL连通性：

    mysql -h <mysql-host> -P <mysql-port> -u <username> -p <database-name>
    

    验证网络是否通畅、账号权限是否正常
• 任务脚本连接引用检查：
  • 确认ETL脚本中使用的连接ID与Airflow中配置的连接ID完全一致（Airflow连接ID区分大小写）
  • 若使用MySqlHook，检查初始化代码是否正确传入连接ID，示例：

    from airflow.providers.mysql.hooks.mysql import MySqlHook
    db_hook = MySqlHook(mysql_conn_id='your_mysql_connection_id')
    

• 依赖与权限验证：
  • 确保Airflow工作节点已安装对应依赖：使用mysqlclient驱动需安装mysqlclient包，使用pymysql需安装pymysql包
  • 检查MySQL数据库的防火墙、安全组规则，确认Airflow工作节点的IP地址被允许访问

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