В настоящее время я использую Airflow в Kubernetes в Google Cloud GCP.Я основал свой проект на...
Я работаю с воздушным потоком в течение некоторого времени, и регулярно мне нужно перезапускать...
У меня есть кластер Spark и Airflow, я хочу отправить искру из контейнера Airflow в контейнер Spark
У меня есть работающий конвейер потока данных, который в первый раз запускает setup.py для...
Я использую Airflow для планирования отправки JAR-файлов (соответствующих упаковке приложений...
В настоящее время я использую экземпляр airflow (1.9.0) на python 3.6.5. У меня есть ручной рабочий...
Я использую автономный Apache Airflow для отправки заданий Spark с помощью SSHExecutorOperator для...
Я разрабатываю DAG на Cloud Composer; мой код разделен на основной файл Python и один пакет с...
Я уже некоторое время пользуюсь Google Composer (composer-0.5.2-airflow-1.9.0), и у меня возникли...
Я пытаюсь сгруппировать свои настройки Airflow, и я использую эту статью для этого.Я только что...
Я только что установил RabbitMQ на экземпляр AWS EC2 (CentOS), используя следующее, sudo yum...
Мне нравится идея воздушного потока, но я застрял в основах.Со вчерашнего дня у меня работает...
Я пытаюсь, чтобы Airflow отправлял мне электронное письмо с использованием AWS SES всякий раз,...
Я только что прошел процесс настройки моей установки Airflow для параллельной обработки, следуя...
Я думал, что смогу использовать команду: g beta composer environments run <env>...
Я пытаюсь выполнить скрипт Airflow, который состоит из пары функций Python.Эти функции в основном...
Я создаю почасовую задачу в Airflow, которая планирует задание потока данных, однако ловушка,...
Мы хотели бы использовать Apache Airflow для организации работы в глобальных центрах обработки...
Я бы хотел добавить суффикс даты макросов к моему финальному столу. Я использую приведенный ниже...
Я пытаюсь выполнить файл Python потока данных, который читает текстовый файл из корзины GCS через...