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

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

Когда вы следуете этому руководству: http://michal.karzynski

Вывод ошибки ниже: ronakvora:dtc ronakvora$ pip install apache-airflow Installing build...

Я смог успешно тренироваться, используя gcloud ml-engine sumbit job CLI.Затем я скопировал значение...

Для чего используется URI пакета?Это обязательно?Если да, то как мне его создать?В настоящее время...

Когда я запускаю свой конвейер Beam из командной строки, используя прямой бегун или бегун потока...

Я настроил Airflow в кластере Kubernetes.Для запуска задач я использую KubernetesPodOperator. Когда...

$ virtualenv --version 16.3.0 $ pip --version pip 19.0.1 Я создал новую среду.И запускаю pip install...

Что такое соглашение для правильного импорта модуля в Airflow?Я хотел бы импортировать этот...

Я пытаюсь настроить Airflow как кластер.Исполнителю сельдерея не удается подключиться к rabbitmq...

У меня Apache Airflow работает отлично с настройками по умолчанию, когда я устанавливаю...

Я настраиваю Airflow в Kubernetes Engine, и теперь у меня есть следующие (работающие) модули:...

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

Я написал плагин воздушного потока, который просто содержит один пользовательский оператор (для...

Я пытаюсь использовать Airflow SFTPHook , передав ssh_conn_id и получаю сообщение об ошибке: No...

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

Приложение My Airflow работает в экземпляре AWS EC2, который также выполняет роль IAM. В настоящее...

Что происходит с цепочкой задач Celery, когда Radis отключается между периодическими снимками? Я...

Я запускаю Airflow в управляемом Cloud-composer environment (версия 1.9.0), который работает в...

Я пытаюсь обработать данные из внешнего источника и сохранить их в моем MongoDB. Поэтому я пытаюсь...

Я пытаюсь установить пакет apache-airflow [all_dbs] на мою anaconda env (python 3.6), но я...

Как я могу импортировать файл json в Google Cloud Composer с помощью командной строки? Я попробовал...

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

Я создаю новый оператор для перемещения данных из базы данных SQL Server в базу данных SQL Azure....