Apache Airflow 1.9.0中Snowflake Hook插件无法被正确识别求助
Apache Airflow 1.9.0 自定义Snowflake Hook插件配置说明
嘿,这就把我们当前的Airflow自定义Snowflake Hook插件相关信息整理好啦:
基础环境信息
- 正在使用的Apache Airflow版本:1.9.0
- 自定义插件类型:Snowflake Hook(插件文件名为
snowflake_hook2.py)
插件目录结构
我们将自定义插件放置在Airflow默认的插件目录$AIRFLOW_HOME/plugins下,具体目录结构如下:
$AIRFLOW_HOME +--plugins +--snowflake_hook2.py
插件代码片段(snowflake_hook2.py)
# 插件基类 from airflow.plugins_manager import AirflowPlugin # 用于在Web界面暴露插件 from flask import Blueprint from flask_admin import BaseView, expose from flask_admin.base import MenuLink # 用于连接数据的基础Hook...
内容的提问来源于stack exchange,提问作者JMoney
相关产品推荐
相关产品推荐

