Воздушные соединения и кратковременные пароли

Одна из проблем, с которой мы сталкиваемся при реализации воздушного потока, заключается в том, что большинство наших подключений, кажется, является проблемой для него.

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

Есть идеи, как мне решить эту проблему?

1 ответ

Решение

Вы можете вызвать свой внутренний инструмент через командную строку, чтобы получить пароль и сохранить его в переменной Airflow. Поместите эту задачу в начало DAG, где она вам понадобится. Если пароль требуется нескольким дагам, создайте выделенную группу обеспечения доступности баз данных, чтобы обновить пароль и запускать его, например, каждые 30 минут.

Вы можете сохранить пароль в одной задаче, используя PythonOperator.

Другие вопросы по тегам