У меня есть оператор python для вызова функции отправки электронной почты, но я получаю сообщение...
В планировщике воздушного потока есть такие вещи, как heartbeat и max_threads. См. Как уменьшить...
На моей локальной машине я создал virtualenv и установил Airflow.Когда dag или плагину требуется...
Я пытаюсь применить файл конфигурации для создания POD из Cloud Compose с помощью BashOperator...
У меня странная проблема. Я пытаюсь динамически создавать пакеты (до 100 пакетов с несколькими...
Мне нужно получить учетные записи из веб-службы, которая может занять текущее значение по умолчанию...
У меня есть длительная задача Cloud Composer Airflow, которая запускает задание с помощью...
Я пытаюсь использовать Cloud Composer с длительным анализом функции DAG, который занимает около 5...
Как лучше всего повторить попытку оператора Airflow только для определенных сбоев / исключений?...
Я пытаюсь динамически установить зависимости и получить task_0 уже зарегистрированным. Ниже...
Я пытаюсь добавить dag для воздушного потока, динамически циклически перебирая ключи словаря и...
Я пытаюсь добавить jaydebeapi в Airflow (размещенный в Google Cloud Composer) с помощью функции...
При создании среды Airflow в GCP Composer автоматически создается группа DAG с именем...
У меня есть функция, которая получает список таблиц из набора данных BigQuery: def...
В некоторых моих установках Airflow запланированные для выполнения группы DAG или задачи не...
Я использую Google Composer.Версия изображения: composer-1.7.0-airflow-1.10.2 Python версия: 3 Мне...
Я пытаюсь создать соединение с воздушным потоком в Cloud Composer с помощью CLI gcloud. Я следую за...
Я создал Composer Environment в среде разработки GCP с учетной записью службы, которая имеет...
Мне нужен доступ к параметру, переданному BigqueryOperator в файл sql, но я получаю сообщение об...
Можно ли добавить подпапки в корзину GCS, которую Cloud Composer / Airflow использует для создания...
Я пытаюсь использовать оператор BigQueryCreateEmptyTableOperator, но он выдает ошибку импорта.
Подобный вопрос задавался ранее, но, насколько я могу судить, этот ответ не может быть объяснен,...
Мы используем Google Composer (управляемый сервис Airflow) с airflow v1.10 и Python 3.6.8. Для...
Я использую GCP Composer для управления Apache в GCP. Для нового проекта я использую новую версию...
Я использую Airflow DAG с помощью Google Cloud Composer , который имеет следующее определение: with...