Я использовал это руководство для установки на свой локальный Mac Mac с докером: http://www
Я пытаюсь выяснить, есть ли полезный способ в потоке воздуха, чтобы передать дату выполнения в виде...
Итак, это быстрый взгляд на мой DAG с воздушным потоком. По сути, я делаю некоторые zip-файлы (2...
Недавно я обновил свой airflow.cfg, чтобы включить метрики, по мнению Statsd. Я ввел эти настройки...
Я использую веб-сервер Airflow для DAG.Когда DAG выполняется, я хочу видеть журналы в...
Я использую Airflow 1.10.1 с Python 3.5 и, допустим, я расширил оператор BaseOperator и добавил...
Получение cx_Oracle.DatabaseError: ORA-12170: TNS: истекло время ожидания соединения при создании...
В моей старой группе обеспечения доступности баз данных я создавал задачи следующим образом:...
Я бы сделал конвейер машинного обучения на Airflow. Пример) result = model.fit() Но файл DAG: (...
Я новичок в Python и воздушного потока. Попытка реализовать датчик, как показано ниже, и ошибка...
У меня странная проблема. Я пытаюсь динамически создавать пакеты (до 100 пакетов с несколькими...
Я хочу написать расширенный механизм повтора в своем операторе pube. если первое выполнение не...
Мне нужно что-то, что помогло бы мне переписать состояние экземпляра задачи и извлечь время...
Я запускаю puckel/docker-airflow в AWS, используя docker-compose и слегка модифицированный...
Мне нужно получить учетные записи из веб-службы, которая может занять текущее значение по умолчанию...
У меня есть образ докера, который создает соединение с Azure Datalake, используя adlCreds = lib
Я получаю ошибку в Airflow UI, когда пытаюсь получить страницу XComs (Admin -> XComs)...
У меня есть длительная задача Cloud Composer Airflow, которая запускает задание с помощью...
Я пытаюсь использовать Cloud Composer с длительным анализом функции DAG, который занимает около 5...
Привет, я пытался запустить скрипт Python параллельно с использованием воздушного потока.Но...
Я обновляюсь до Airflow 1.10.2 с 1.9.0, в python 2.7, и у меня проблемы с...
Есть идеи, почему я не могу запустить докер с помощью Airflow? Та же команда docker отлично...
Я хочу принять Apache Airflow для процессов ETL, которые загружают несколько текстовых файлов в...
Я пытался увидеть некоторые вопросы, например, например: Как добавить новый ярлык в работающую...
Как лучше всего повторить попытку оператора Airflow только для определенных сбоев / исключений?...