Apache Airflow自定义插件Endpoint无法访问问题排查求助

核心结论 #

通过自定义插件注册Flask Blueprint的方式完全可以在Airflow中创建自定义Endpoint，你的问题主要出在配置细节或重启流程上，以下是具体排查步骤：

1. 确认插件目录结构正确性 #

确保目录结构严格符合要求，__init__.py必须存在（可空），插件文件直接放在plugins根目录下：

~/airflow/
├── airflow.cfg
├── dags/
└── plugins/
    ├── __init__.py
    └── test.py

若插件文件放在子目录，子目录也需添加__init__.py，否则Airflow无法识别。

2. 调整Blueprint路由配置避免冲突 #

Airflow内置API前缀为/api/v1，你的/api/custom_endpoint理论上不冲突，但建议给自定义Blueprint添加独立前缀降低冲突概率：
修改test.py中的Blueprint定义：

custom_endpoint_bp = Blueprint('custom_endpoint', __name__, url_prefix='/custom')

对应的路由改为：

@custom_endpoint_bp.route('/endpoint', methods=['GET'])

修改后访问地址为http://My_IP:PORT/custom/endpoint。

3. 正确重启Airflow独立版 #

执行airflow plugins能看到插件说明识别成功，但必须彻底重启所有组件：

airflow standalone stop
airflow standalone start

仅重启webserver可能无法重新加载插件，必须停止后再启动。

4. 理解Admin>Plugins页面的显示逻辑 #

Airflow的Admin>Plugins页面默认只展示包含operators、hooks、executors等业务组件的插件，仅注册Blueprint的插件不会在此页面显示，这是正常现象，无需担心。

5. 验证插件加载状态 #

• 查看Airflow webserver日志，搜索Loaded plugin: custom_plugin，确认插件被成功加载
• 进入Airflow Python环境执行以下代码，验证Blueprint是否注册：

  from airflow.plugins_manager import plugins
  for p in plugins:
      if p.name == 'custom_plugin':
          print(p.flask_blueprints)
  

  若输出包含你定义的custom_endpoint_bp，说明注册成功。

6. 排查权限问题（可选） #

Airflow 2.x默认启用RBAC权限，若自定义Endpoint返回403/404，可临时修改airflow.cfg关闭权限测试：

auth_backend = airflow.api.auth.backend.default

重启后再次访问，若能正常返回则需为该Endpoint添加权限配置。

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