Size: a a a

2018 February 01

JS

John Smith in Airflow
то есть чистить всё руками? или скриптом из airflow же?
источник

JS

John Smith in Airflow
через сколько должен "подхватиться" новый DAG
источник

JS

John Smith in Airflow
&
источник

JS

John Smith in Airflow
?
источник

SS

Sergey Sheremeta in Airflow
30 секунд по дефолту вроде
источник

JS

John Smith in Airflow
а лог ошибок никак не выводится в web-interface&
источник

JS

John Smith in Airflow
?
источник

МС

Максим Сёмочкин in Airflow
Неа. Это «нормально». Поможет точно толко рестарт всех компонент + очистка базы.
источник

OI

Oleg Ilinsky in Airflow
ошибки выполнения выводятся, внутри дага в разделе logs
а если ошибка при создании дага, то да, только в list_dags
источник

МС

Максим Сёмочкин in Airflow
В логах scheduler можно посмотреть на ошибки создания
источник

OI

Oleg Ilinsky in Airflow
👍🏻
не знал)
источник

JS

John Smith in Airflow
Мда...сыроват...
источник

JS

John Smith in Airflow
Коллеги...а кто как ..верней чем синхронизирует выгрузку  из таблиц...по, например, полю id
источник

JS

John Smith in Airflow
То есть база пополняемая таблицами, называющиеся по дням: 2018_02_01...и так далее...в них пишется ...много
источник

JS

John Smith in Airflow
В apache Nifi - есть костыль из коробки
источник

JS

John Smith in Airflow
Аля "взять только новые строки"
источник

JS

John Smith in Airflow
Цепочка задач...должна по расписанию брать новые строки...что то делать...и складывать в другую базу
источник

OI

Oleg Ilinsky in Airflow
Возможно, есть способ получше, но мы такое собираемся через таблицу аудита делать
источник

OI

Oleg Ilinsky in Airflow
Ну и можно запилить оператор для инкрементальной загрузки, который скроет всю работу с метаданными.
источник

JS

John Smith in Airflow
Oleg Ilinsky
Возможно, есть способ получше, но мы такое собираемся через таблицу аудита делать
Таблица из названия таблиц их последнего отработанного id и статус
источник