Airflow容器部署下无法连接本地MongoDB的问题求助

开发者阿泽

2026-7-20

问题分析与解决方案

1. 容器网络访问问题（核心原因）

本地代码用mongodb://localhost:27017能连接MongoDB，是因为此时localhost指向你的宿主机；但Airflow运行在Docker容器内，容器内的localhost是容器自身，而非宿主机，导致容器里的Airflow无法通过localhost访问宿主机上的MongoDB。

解决方法：

若MongoDB运行在宿主机上：
- 在Airflow的Mongo连接配置中，将主机地址改为宿主机的局域网IP（如192.168.x.x），或在Docker Desktop环境中使用host.docker.internal。
若MongoDB也运行在Docker容器中：
- 确保Mongo容器与Airflow容器处于同一个Docker网络（社区版docker-compose.yaml默认会创建专属网络），连接地址改用Mongo容器的服务名（例如Mongo容器名为mongo，则用mongodb://mongo:27017）。

2. DAG代码中的语法错误

你的DAG代码存在一处明显错误：

task_1_0 = PythonOperator(
    task_id='test_connection_my_bd',
    python_callable=db.get_one,  # 此处的db未定义
    dag=mydag,
    op_kwargs={'c': 107332}
)

需修改为python_callable=get_one——因为get_one是当前脚本内定义的函数，无需引用未导入的db模块。

3. 调试与验证建议

先验证Airflow容器与MongoDB的网络连通性：
进入Airflow worker容器执行命令：
```
docker exec -it <airflow-worker-container-name> ping <mongo-host-ip>
```
若ping不通，说明网络问题未解决，优先排查网络连通性。

在connecter函数中添加日志，确认连接参数：

def connecter():
    hook = MongoHook(mongo_conn_id='mongo_default')
    conn = hook.get_connection(mongo_conn_id='mongo_default')
    print(f"Mongo连接参数: host={conn.host}, port={conn.port}")
    client = hook.get_conn()
    my_db = client['Immo']
    return my_db

查看Airflow任务日志，确认连接的主机地址是否正确。