Уважаемый участник Stackoverflow,
Я пытаюсь использовать Airflow для планирования группы обеспечения доступности баз данных, которая запускает кластер, запускает несколько искровых заданий, а затем завершает свою работу. Я попытался последовать этому примеру: https://insight.io/github.com/apache/incubator-airflow/blob/master/airflow/contrib/example_dags/example_emr_job_flow_automatic_steps.py
Это дало мне ошибку: воздушный поток. exceptions.AirflowException: conn_id emr_default не определен
Мне, вероятно, нужно настроить emr_default (пожалуйста, поправьте меня, если это не так). Кто-нибудь пробовал это раньше и давал мне несколько советов о том, как его настроить? Веб-сайт Airflow не предоставляет слишком много информации о соединении emr: http://pythonhosted.org/airflow/configuration.html?highlight=connection#connections
Спасибо!
