Воздушные соединения и кратковременные пароли
Одна из проблем, с которой мы сталкиваемся при реализации воздушного потока, заключается в том, что большинство наших подключений, кажется, является проблемой для него.
После некоторого решения соединения через SSH я столкнулся с проблемой коротких паролей: некоторые из наших соединений требуют, чтобы пароль запрашивался другой службой. Срок действия этих паролей истекает через 1 час, и единственный способ получить новый - запросить внутренний инструмент с помощью командной строки.
Есть идеи, как мне решить эту проблему?
1 ответ
Вы можете вызвать свой внутренний инструмент через командную строку, чтобы получить пароль и сохранить его в переменной Airflow. Поместите эту задачу в начало DAG, где она вам понадобится. Если пароль требуется нескольким дагам, создайте выделенную группу обеспечения доступности баз данных, чтобы обновить пароль и запускать его, например, каждые 30 минут.
Вы можете сохранить пароль в одной задаче, используя PythonOperator.