Требование: запускать SQL-запрос для каждой даты, используя цикл while. Например: дата начала...

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

Я новичок в Google Cloud Composer и столкнулся с тем, что кажется странной проблемой в созданной...

Мы находимся в процессе оптимизации наших конвейеров сборки / развертывания для кодовой базы...

Если я использую BigQueryOperator с шаблоном SQL, как я могу передать аргумент в SQL? Файл : .sql /...

Меня смущает то, что делает воздушный поток, если дагрун выходит из строя. Поведение, которого я...

Я работаю с сервисом воздушного потока. Служба не может подключиться к sqs Планировщик может...

Нужно ли выполнять какие-либо дополнительные настройки, чтобы apache-airflow мог отправлять мне...

Я хотел бы передать список строк, содержащих имена файлов в хранилище Google, в XCom. Позже будет...

В настройках Airflow DataprocClusterCreateOperator: У нас есть возможность установить тип основного...

Я только что обновил Airflow 1.10, следуя инструкциям здесь: https://medium

У нас есть длительное (3 часа) учебное задание на модели, которое выполняется каждые 3 дня, и...

Как я могу контролировать веб-сервер Airflow при использовании Google Cloud Composer? Если...

версия воздушного потока - 1.9.0 Я установил apache airflow и после конфигурации я могу запустить...

Может кто-нибудь дать мне пошаговое руководство по подключению Apache Airflow к рабочему...

У меня есть следующая структура папок в папке Airflow dag. /opt/airflow/dags --my_module/ --my_dag

Я пытаюсь настроить поток воздуха с двумя интервалами с интервалом «каждые 30 минут». Первый знак (...

Я пытаюсь изменить формат ведения журнала для одного DAG в Airflow. Опция доступна: обновить...

Я не смог найти учебник по облачному двигателю ML + потоку воздуха, кто-то, пожалуйста, помогите...

Я пытаюсь выяснить, как лучше всего работать с Airflow и Spark / Hadoop.У меня уже есть кластер...

Воздушный поток позволяет передавать параметры в даг через командную строку или через...

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

Я определил соединение SSH через интерфейс администратора Airflow. Однако я определяю только...

Попытка публикации в Slack с помощью on_failure_callback. У меня есть эта процедура ниже, и мои...

Я пытаюсь запланировать задания потока данных с помощью airflow DataflowPythonOperator. Вот мой...