Не могли бы вы посоветовать, поддерживает ли Airflow шифрование на стороне сервера AWS KMS? Если да...

Данные присутствуют в ведре. Но звонки API говорит, что файл не присутствует. Одна важная вещь,...

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

Я работаю в $AIRFLOW_HOME/dags. Я создал следующие файлы: - common |- __init__.py # empty |- common

Я использую операторы EMR CreateJobFlow, AddSteps, StepSensor и TerminateJobFlow в моей DAG, чтобы...

У меня есть две машины. Machine1: веб-сервер воздушного потока, планировщик воздушного потока....

Когда я запускаю работника воздушного потока с какой-то очередью, выдается следующее сообщение об...

Я пытаюсь запустить Airflow в контейнере и использовал доступное изображение здесь .Я обнаружил,...

Я новичок в воздушном потоке (v1.10).У меня есть два пакета, каждый из которых требует одинаковых...

В документах указаны инструкции по интеграции Я хочу, чтобы каждый раз, когда планировщик прекращал...

Это, кажется, довольно распространенная проблема.У меня есть DAG, где я не только могу запустить...

У меня есть следующий код: def chunck_import(**kwargs): ... for i in range(1, num_pages + 1): start...

Я хочу создать динамически созданную группу доступности базы данных из запроса к таблице базы...

В настоящее время у меня есть DAG, состоящая из 4 операторов, как показано ниже: with...

У меня есть даг, который работает еженедельно по воскресеньям.Есть одна задача, BashOperator,...

Попытка заставить HDFSSensor работать.Я установил соединение hdfs, и файл есть, но он продолжает...

Моя ОС - Mac OS.Я следовал официальному руководству по установке воздушного потока для установки.Но...

За пределами оператора мне нужно вызвать SubdagOperator и передать ему возвращаемое значение...

Сегодня весь день я получал эту ошибку в планировщике Airflow. sqlalchemy.exc.IntegrityError:...

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

Я создал Apache Airflow DAG со следующими параметрами по умолчанию.Я хочу, чтобы этот DAG...

Это мой оператор: bigquery_check_op = BigQueryOperator( task_id='bigquery_check',...

Я хочу, чтобы один даг начинался после завершения другого.одно решение использует функцию внешнего...

Очень простой вопрос - такая сильная головная боль dag = DAG( dag_id='dag_id',...

Я копирую пример кода с воздушным потоком example_branch_dop_operator_v3 в свой собственный...