Airflow报错No module named 'airflow.sensors.python_sensor'，无法导入PythonSensor求助

正确导入路径（按Airflow版本区分） #

• Airflow 2.x 版本：PythonSensor的导入路径已变更，正确语句为：

from airflow.sensors.python import PythonSensor

• Airflow 1.x 版本：原路径from airflow.sensors.python_sensor import PythonSensor是有效的，若仍报错，需检查Airflow安装是否完整。

其他排查与解决方法 #

• 确认Airflow版本：在终端执行airflow version查看版本，匹配对应的导入路径。
• 重装Airflow包：若模块缺失，执行pip install apache-airflow（指定版本可加==x.x.x），确保传感器模块被正确安装。
• 检查Python环境：确保运行DAG的Python环境和安装Airflow的环境一致，避免虚拟环境隔离导致模块找不到。
• 替代实现方案：如果导入问题无法快速解决，可使用PythonOperator结合重试机制模拟传感器逻辑：

from airflow.operators.python import PythonOperator
from airflow.utils.retries import retry

@retry(exponential_backoff=True, max_retries=10, retry_delay=300)
def fetch_stg_qa_status():
    # 这里写原有的STG状态检查逻辑
    stg_status = get_stg_qa_status()  # 替换为你的实际状态获取函数
    if stg_status != "completed":
        raise Exception("STG任务未完成，触发重试")

wait_for_stg_completion = PythonOperator(
    task_id='wait_for_stg_completion',
    python_callable=fetch_stg_qa_status
)

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