Size: a a a

2021 October 31

AM

Aлексей Mатюхин... in Airflow
А что это?
источник

v

vasiliy in Airflow
Шареная сетевая файловая система
источник

v

vasiliy in Airflow
Крч в таком случае просите админов замаунтить на каждую ноду в один и тот же маунт поинт диск какой гигов на 500
источник

v

vasiliy in Airflow
Общий на всех
источник

AM

Aлексей Mатюхин... in Airflow
Не знаю. Наверное нет. Я же все с локального кома делаю. Сейчас я делаю только прототип, который будет потом в реальной инфре крутиться...
источник

AM

Aлексей Mатюхин... in Airflow
А зачем? Это же файлы с ДАГами, они много не занимают.
источник

v

vasiliy in Airflow
Делаете через hostpath провиженер, поставить две секунды оф хельмом. Через него создаёте пвс/пв который будет маунтится к каждой поде в /dags. Директорию
источник

v

vasiliy in Airflow
И кидайте туда сгенереные даги
источник

v

vasiliy in Airflow
По фауту каждый воркер будет иметь примаунченную шару по одному и тому же пути
источник

AM

Aлексей Mатюхин... in Airflow
Т.е. сделать примаунченную шару к локальному диску? Это было бы супер круто. Не представляете, как я сейчас мучаюсь. С заворачиванием ДАГа в образ, потом пушем в докер репозиторий, потом раскаткой helm-ом, все это не быстро, кодить и отлаживать очень тяжело!!!
источник

I

Igor in Airflow
к сожалению, представляем

Но да, чтобы всё было удобнее тебе точно нужен какой-то общий центр где будут даги, кто тебе его даст — гит контейнер, сетевая файловая система, или твой облачный провайдер — зависит от инфраструктуры. Паттерн что твой воркер на котором запустился генератор будет раскладывать их потом по другим дагам скорее не очень
источник

AM

Aлексей Mатюхин... in Airflow
А ДАГи генерите?
источник

I

Igor in Airflow
у нас это отдельный шаг в пайплайне, но и нет требования не перезапускать ничего
источник

v

vasiliy in Airflow
Короче я понял. Просите админов к каждой ноде сделать маунт.
источник

v

vasiliy in Airflow
Ставьте на кубер хостпас провиженер
источник

v

vasiliy in Airflow
Маунтите ЭТУ новую шару в каждый воркер
источник

v

vasiliy in Airflow
Чтобы зайти на воркер, сделать touch /dags/testfile и увидеть его там же с другого воркера
источник

v

vasiliy in Airflow
Настройте даг фолдер на эту директорию (airflow vars)
источник

DY

Dmitry Yakimets in Airflow
Вот, кстати, может быть интересно глянуть для вдохновения: https://airflowsummit.org/sessions/2021/data-lineage-with-apache-airflow-using-openlineage/
источник
2021 November 01

ЕГ

Евгений Глотов... in Airflow
Следующее на очереди у меня попробовать)
Датахаб и атлас уже протестированы)
источник