У меня есть многофайловое Python Apache Beam, которое я хочу запустить в облаке Dataflow через...

Я пытаюсь запустить Airflow dag, который создает кластер EMR, добавляет несколько шагов, проверяет...

Моя цель - запланировать задания с EmrCreateJobFlowOperator и EmrAddStepsOperator.А именно, я хочу...

Я пытаюсь установить airflow в моей среде python на сервере linux и в оболочке zsh. Я смог успешно...

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

Я прошу прощения за этот наивный вопрос, но я хотел бы получить некоторые разъяснения о том,...

Я уже видел это и это вопросы по SO и внес изменения соответственно. Тем не менее, мой зависимый...

Я использую некоторые скрипты Python для загрузки файлов с ftp-сервера, и я создал DAG для этого....

Как я могу непрерывно копировать Дагс, написанный командой разработчиков, на сервер airflow...

Я бы хотел приостановить работу групп доступности базы данных, которые являются бездействующими и...

Я только что установил Cloud Composer Environment в Python 3 и версии образа Composer composer-1.4

Для запуска исторического импорта каждый день в декабре 2018 года требуется Dag, который догоняет...

Есть ли способ получить текущее состояние самого последнего запуска DAG через API Airflow?Я...

Мы рассматриваем возможность использования воздушного потока для замены нашего в настоящее время...

Я хочу отобразить более 365 дагрунов на диаграмме продолжительности задачи Airflow.Я нашел, где...

Я знаю, что, например, если у нас есть несколько файлов sql в папке данных, мы можем установить...

Я обнаружил, что есть много способов сохранить его в виде переменных, хуков и других способов с...

Я пытался перезапустить весь даг и задачи, даже если они были успешными. Я сделал даг и запустил...

В настоящее время я работаю над развертыванием Apache Airflow 1.10.0 в кластер Kubernetes.Я...

У меня есть приложение на Python, созданное с использованием Flask.Я использую алхимию sql и моя...

У меня огромное количество DAGS (>> 100.000), которые должны запускаться каждый раз в день.Чтобы в...

Мой план: Переместить всю обработку данных в Spark (желательно PySpark), чтобы окончательный вывод...

Моя группа доступности базы данных выглядит следующим образом: задача1 >> задача2 >> задача3 и...

Я использую Google dataproc для отправки заданий на спарк и Google Cloud Composer для их...

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