Я изучаю Apache Поток воздуха в настоящее время и хочу автоматически запускать несколько групп DAG для определенных событий. Эти события принимаются и обрабатываются простым Python сценарием.
Единственный способ выяснить, как запустить новую группу обеспечения доступности баз данных, - запустить веб-сервер Airflow рядом с планировщиком Airflow и вызвать этого веб-сервера. REST API . Это сработало, но выглядит как обходной путь, вызывающий веб-интерфейс из той же системы для вызова локальной программы в той же системе. Можно ли напрямую взаимодействовать с планировщиком воздушного потока?
Возможно, это потому, что я еще не полностью понимаю все концепции, но API REST также допускает только один запрос за раз. Поэтому я не могу запустить несколько групп DAG параллельно.