Size: a a a

2020 July 17

ME

Max Efremov in Airflow
и те и те
источник

ME

Max Efremov in Airflow
возможно ещё недопилили
источник
2020 July 18

BB

Bral Bral in Airflow
Что нужно делать, если при выполнении дага нужно лог в отдельный файл , а не стандартный файл для дага
источник

BB

Bral Bral in Airflow
logging переопределять? или есть другие решения
источник

BB

Bral Bral in Airflow
ну вот например, чиститься файл - нужно залогировать сколько строк было изначально, сколько повторов, сколько некорректных строк и тд
источник

BB

Bral Bral in Airflow
цеплять эту информацию из стандартного лога не очень удобно
источник

BB

Bral Bral in Airflow
в бд сразу писать не хочу, потому что может быть такое , что она будет недоступна
источник

GG

George Gaál in Airflow
А на диске может место кончиться под логи 🤷‍♂
источник

GG

George Gaál in Airflow
Все что угодно может свалиться где угодно
источник

ME

Max Efremov in Airflow
Bral Bral
ну вот например, чиститься файл - нужно залогировать сколько строк было изначально, сколько повторов, сколько некорректных строк и тд
Можно через s3hook сделать файл лога на s3
источник

ME

Max Efremov in Airflow
Если база может быть недоступна, можно поднять кластер кафки и писать в кафку, например
источник

ME

Max Efremov in Airflow
Или касандру, чтобы именно кластер был, который разом не свалится (ну, в теории :) )
источник

BB

Bral Bral in Airflow
George Gaál
А на диске может место кончиться под логи 🤷‍♂
Место мониториться
источник

BB

Bral Bral in Airflow
Max Efremov
Если база может быть недоступна, можно поднять кластер кафки и писать в кафку, например
Да, в Кафку и буду , спасибо .
источник
2020 July 20

L

Lexis in Airflow
Артём Бобровник
Всем привет!
Может, кто сталкивался с такой проблемой:
Есть постгрес оператор, который выполняет запрос в базу. Сам запрос отрабатывает за несколько секунд. Но даг на нем виснет и запрос не выполняется. При этом несколько проходов по дагу все может быть хорошо, а потом в какой-то рандомный проход виснет.
При этом никакой ошибки нет. Таск находится в состоянии running.
Если много памяти жрет оператор может шедулер, например, на пиках памяти умирать
источник

АБ

Артём Бобровник... in Airflow
Lexis
Если много памяти жрет оператор может шедулер, например, на пиках памяти умирать
Он вообще на аирфлоу ничего не загружает. Просто шлёт запрос insert ... select ... ;
источник

L

Lexis in Airflow
Артём Бобровник
Он вообще на аирфлоу ничего не загружает. Просто шлёт запрос insert ... select ... ;
ну у меня похожее было когда системные ошибки происходили  типа нехватает памяти или места на диске (для логов)
источник

АБ

Артём Бобровник... in Airflow
Спасибо, посмотрю в эту сторону.
источник
2020 July 21

K

KrivdaTheTriewe in Airflow
уже два года ору от этой штуки
источник

ME

Max Efremov in Airflow
А что тут не верно? То, что рандомный коннекшен берёт?
источник