python - 如何向 Airflow 2.0 添加新的“Conn 类型”?
问题描述
我正在学习 Apache Airflow 2.0,我正在创建一个新的“连接”,但在“连接类型”中只有几个选项,例如我想添加一个 MySQL 连接,但没有那个选项。在这篇文章(Apache Airflow - Connection issue to MS SQL Server using pymssql + SQLAlchemy)中,您可以看到它们有很多 conn 类型,我想知道如何创建或添加新类型,现在我需要 MySQL 类型,但它是将来我可能需要更多(如 AWS、GCP 等)。我必须从 CLI 创建一个连接,但如果我从 UI 编辑它,conn 类型会丢失,所以这是一个问题......
所以他们在 conn 类型中有所有这些选项: 在此处输入图像描述
我只有这些选项: 在此处输入图像描述
解决方案
您需要通过以下方式使用 MySQL Provider 来执行此操作:
pip install -U 'apache-airflow[mysql]'
或者
pip install -U apache-airflow-providers-mysql
从 Airflow 2.0.0 开始,连接类型只会显示给已安装的提供程序。
推荐阅读
- javascript - JS如何检查对象是否具有接口中不包含的属性?
- maven - 属性 maven.compiler.target 是如何工作的
- spring-boot - spring 和 Spark Streaming 一起出现的问题
- node.js - 如何使用 nvm 设置默认 Node.js 版本?
- excel - 搜索文本并复制其后的数据
- c++ - 实施“数字战争”的最优策略
- html - Angular 8过滤器:保留文本区域输入的换行符
- python - 通过 Python 根据 if 条件添加新行
- c# - SMTP 地址没有与之关联的邮箱
- spring-boot - 带有 Keycloak SSO 身份验证的 Spring+Vue.js 应用程序:XSS 堵塞?