У меня есть поле даты (для закрытого контракта на регистрацию), которое я создал в пользовательском...
Я ищу решение для запуска задания Azure Databricks, обеспечения непрерывного выполнения задания и...
В файле airflow.cfg я настроил значение min_file_process_interval равным 120 секундам. У даг был...
Вот мой DAG: from airflow import DAG from airflow.operators.bash_operator import BashOperator from...
Я пишу скрипт на python, который вычисляет что-то. Именно поэтому скрипт отделен от папки dags. В...
При столкновении с архитектурой, в которой задействованы несколько веб-серверов, на которых...
Я хочу создать задание в oracle, которое выполняется каждую минуту в 00 секунд, например, 01:00...
Мне нужно запускать ежедневную работу по восстановлению только с этого момента и до одного года, я...
Я создал задачу с PythonOperator в качестве оператора.Он вызывает функцию в другой папке с...
Я писал запрос на удаление любой строки с датой публикации более 5 дней назад.Формат postDate -...
Как я могу вызвать задачу rake из планировщика Heroku? Мне нужно вызвать команду rake...
Когда я пытаюсь следовать руководству Kubernetes Configure Multiple Schedulers , я не могу успешно...
Я пытаюсь понять, подходит ли мне поток воздуха для этого сценария. В настоящее время у меня есть...
У меня есть работа с 3 задачами 1) Получить токен, используя запрос POST 2) Получить значение...
После изучения и изучения основ Airflow, я все еще не могу понять, как я буду выполнять...
Мне всегда было интересно, почему реализация SmoothRateLimiter в Гуаве должна была...
Проблема У меня развернуто приложение для узлов в Heroku, и я пытаюсь использовать Heroku Scheduler...
Я работаю над облачной функцией Firebase, чтобы отправлять инициированные push-уведомления.Прямо...
Я хотел бы отправлять оповещения через свою пользовательскую функцию обратного вызова, которую я...
Я пытаюсь запустить методы poll, poll1, poll2 для запуска независимо, прямо сейчас, если poll ()...
Здравствуйте, я новый пользователь Airflow. Я запустил веб-сервер Airflow и хочу запустить на нем...
Привет, я новичок в Воздушный поток , я пытаюсь импортировать мою собственную флягу настройки как...
У меня установлена версия Docker-ce 18.09.1 в CentOS Linux версии 7.5.1804 (Core). Я пытаюсь...
Я новичок в Воздушный поток . У меня возникли проблемы с удалением Airflow v1.10.3, я использую...
Во время работы SQL-конвейеров pySpark через Airflow я заинтересован в получении некоторой...