#airflow #mysql-python #directed-acyclic-graphs
Вопрос:
Кажется, я не могу импортировать Mysql. как и при попытке импорта с помощью этого from airflow.operators.mysql_operator import MySqlOperator , я получаю эту ошибку «Не удается найти ссылку ‘MySqlOperator’ в ‘mysql_operator.py »
Ответ №1:
Предполагая, что вы используете версию 2.0.0 или выше, импорт будет:
from airflow.providers.mysql.operators.mysql import MySqlOperator
Не забудьте сначала установить пакет поставщиков MySQL:
pip install 'apache-airflow-providers-mysql'
Вот пример из документов.
Комментарии:
1. И если вы не используете Airflow 2 , лучше обновитесь ПРЯМО СЕЙЧАС. Срок службы Airflow 1.10 истек 17 июня 2021 года, и он больше не будет получать даже критические исправления безопасности. Вы можете посмотреть дискуссионную панель «Защитите свой воздушный поток» от «просто работающего» саммита Airflow 2021 crowdcast.io/e/airflowsummit2021/3 где мы подробно обсудили это.