Size: a a a

2020 September 24

СГ

Станислав Горчаков... in Airflow
Ребят, подскажите, плиз по одному моменту
Запускаю докер через образ puckel/airflow. Проблема в том, что все время при рестарте контейнеров вылезает ошибка cryptography.fernet.InvalidToken, когда он пытается подключиться к имеющемся коннектам.
Я немного почитал и обнаружил, что нужно в airflow.cfg написать переменную fenter_key = сгенерированный. Я это сделал внутри контейнера, но это не спасло ситуацию и при перезапуске контейнера он как будто генерит этот ключ снова
источник

SG

Sergey Gavrilov in Airflow
Мм не знаю, я его пробрасывал через энвайронмент. Но судя по названию ошибки, вам стоит сгенерировать более корректный
источник

СГ

Станислав Горчаков... in Airflow
Sergey Gavrilov
Мм не знаю, я его пробрасывал через энвайронмент. Но судя по названию ошибки, вам стоит сгенерировать более корректный
не, ключ корректный, вот только нужно удалять запись из таблицы connections и создавать снова, и похоже, что этот статичный ключ он не берет(

Просто в сервис с airflow в docker-compose.yml добавляли переменную окружения AIRFLOW__CORE__FERNET_KEY?
источник

v

vasiliy in Airflow
Станислав Горчаков
не, ключ корректный, вот только нужно удалять запись из таблицы connections и создавать снова, и похоже, что этот статичный ключ он не берет(

Просто в сервис с airflow в docker-compose.yml добавляли переменную окружения AIRFLOW__CORE__FERNET_KEY?
уно моменто…у вас она на каждом компоненте указана?
источник

v

vasiliy in Airflow
вы какой екзекьютор юзаете?
источник

v

vasiliy in Airflow
селери?
источник

СГ

Станислав Горчаков... in Airflow
vasiliy
вы какой екзекьютор юзаете?
Local
источник

SG

Sergey Gavrilov in Airflow
Станислав Горчаков
не, ключ корректный, вот только нужно удалять запись из таблицы connections и создавать снова, и похоже, что этот статичный ключ он не берет(

Просто в сервис с airflow в docker-compose.yml добавляли переменную окружения AIRFLOW__CORE__FERNET_KEY?
Нет, для пукеля FERNET_KEY называется переменная
источник

v

vasiliy in Airflow
какая там схема? веб и воркер?
источник

СГ

Станислав Горчаков... in Airflow
vasiliy
какая там схема? веб и воркер?
веб вроде, если я правильно понимаю о чем речь
источник

СГ

Станислав Горчаков... in Airflow
Sergey Gavrilov
Нет, для пукеля FERNET_KEY называется переменная
а это норма в докер файле хранить токен? или как туда его прокинуть?
источник

v

vasiliy in Airflow
FERNET_KEY=
источник

v

vasiliy in Airflow
угу да, Сергей правильно написал
источник

v

vasiliy in Airflow
Станислав Горчаков
а это норма в докер файле хранить токен? или как туда его прокинуть?
нууу как.....
источник

v

vasiliy in Airflow
скажем так это меньшее зло и не сильно страшное
источник

СГ

Станислав Горчаков... in Airflow
ок, спасибо за ответы!)
источник

SG

Sergey Gavrilov in Airflow
Используйте или энв-файл напрямую, или упакуйте в docker-compose и тогда положите рядом в файлик .env
источник

А

Анастасия in Airflow
Привет!

Можете подсказать, как скопировать файлы из одной папки hdfs в другую по маске? Я к тому, что до этого использовала только webhdfshook: выбирала активную ноду, потом делала, что было нужно. Но в нем нет команды copy, насколько я понимаю. Можно сделать только read+write, мне бы так не хотелось(
источник

SG

Sergey Gavrilov in Airflow
Анастасия
Привет!

Можете подсказать, как скопировать файлы из одной папки hdfs в другую по маске? Я к тому, что до этого использовала только webhdfshook: выбирала активную ноду, потом делала, что было нужно. Но в нем нет команды copy, насколько я понимаю. Можно сделать только read+write, мне бы так не хотелось(
По своему опыту могу посоветовать одно. Если в HDFS есть такая команда, то самый простой путь — дописать её в webhdfshook и использовать модифицированную версию
источник

VN

Vova Narovchatskiy in Airflow
Всем привет!
Есть какие установленные минимальные требования к железу кластера у Airflow?
источник