Я создаю облачный композитор на GCP и добавляю на него пометку. Но веб-сервер показывает это No...
Я использую Cloud Build для загрузки группы доступности базы данных в папку data в хранилище среды...
У меня есть скрипт на python, который динамически создает задачу (оператор воздушного потока) и DAG...
Я пытаюсь запустить простой KubernetesPodOperator в моей среде Composer согласно документации,...
При доступе к Airflow через страницу Среды Google Composer в консоли GCP я получаю сообщение об...
Ниже приведен код DAG воздушного потока.Он отлично работает как при локальном размещении воздушного...
Я настраиваю среду Airflow в Google Cloud Composer для тестирования.Я добавил некоторые секреты в...
Я использую Airflow для запуска заданий Spark в Google Cloud Composer.Мне нужно Создать кластер...
Я получаю сообщение об ошибке при попытке запустить DAG из облачного композитора с помощью...
Я получаю сообщение об ошибке при попытке получить доступ к корзине с помощью облачного...
Есть ли в Cloud Composer / Airflow параметр, который может по умолчанию отключать новые группы...
У меня есть DAG AirFlow, которая копирует данные из моей базы данных Google BigQuery в другой набор...
Я использую sendgrid для оповещения людей о сбое задачи в облачном компоновщике.Но электронная...
Обзор Я только что развернул среду Cloud Composer, используя все значения по умолчанию.Затем я...
Я создаю динамически даг из списка и хотел бы добавить on_failure_callback к одной из задач.Я...
Когда я впервые создал экземпляр в GC Composer, он был настроен на воздушный поток 1.9.0.С тех пор...
У меня есть конвейер Airflow, который создает 12 промежуточных таблиц из файлов Google Cloud...
Есть ли способ переопределить путь по умолчанию для групп DAG Airflow.При создании и выполнении...
Я использую оператор MLEngine в contrib (не смог найти ни одного в contrib).Проблема из журналов...
Я попытался установить boto3 на Composer, но через некоторое время я получил следующую ошибку: Есть...
Я хотел бы настроить региональные кластеры в кластере kubernetes, лежащие в основе сред Cloud...
Что такое соглашение для правильного импорта модуля в Airflow?Я хотел бы импортировать этот...
Я написал плагин воздушного потока, который просто содержит один пользовательский оператор (для...
Я пытаюсь использовать Airflow SFTPHook , передав ssh_conn_id и получаю сообщение об ошибке: No...
Мне нужно использовать контейнер с gcsfuse в Google Cloud Composer, насколько я знаю, --privileged...