Size: a a a

2020 October 07

RB

Roman Bakhtaraev in Airflow
Коллеги, приветствую, а поделитесь инфой, кто какой чарт использует для разворачивания airflow с использованием k8s executor? Сам сейчас использую от astronomer
источник

AK

Anvar Khamidov in Airflow
Коллеги, добрый вечер!

Стоит такая подзадача для себя, у меня идет ассинхронная загрузка, там 3 метода питоновских операторов. Мне нужно дождаться загрузки этих операторов, чтобы в дальнейшем пометить в базе данных что загрузка была совершена. Что подскажете делать в таком случае?
источник

AK

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

Используется файл и его я помечаю в psql
источник

PA

Panchenko Andrey in Airflow
Селект из базы проверить есть ли там файл или нет
источник

PA

Panchenko Andrey in Airflow
Я так делаю
источник

PA

Panchenko Andrey in Airflow
Сначала пишу в таблицу, потом пишу лог и проверяю лог
источник

PA

Panchenko Andrey in Airflow
Сенсор можно на таблицу повесить
источник

AK

Anvar Khamidov in Airflow
Panchenko Andrey
Сначала пишу в таблицу, потом пишу лог и проверяю лог
в логах пишешь что типо файл используется и после чего чекаешь в нем его?
источник

PA

Panchenko Andrey in Airflow
Пишу в табличку файл с именем таким то строк столько зписан тогда-то
источник

ME

Max Efremov in Airflow
А не проще sql sensor просто?
источник

AK

Anvar Khamidov in Airflow
Panchenko Andrey
Пишу в табличку файл с именем таким то строк столько зписан тогда-то
хмм, идея неплохая, спасибо
источник

AK

Anvar Khamidov in Airflow
Чтобы чекать что все загрузилось и чекать статус, круто, слушай
источник

AK

Anvar Khamidov in Airflow
Max Efremov
А не проще sql sensor просто?
Да, тоже по идее можно, пока не щупал сенсоры
источник

PA

Panchenko Andrey in Airflow
Max Efremov
А не проще sql sensor просто?
Это я тоже предлагал
источник

PA

Panchenko Andrey in Airflow
Max Efremov
А не проще sql sensor просто?
А если много файлов?
источник

PA

Panchenko Andrey in Airflow
Как проверить?
источник

AK

Anvar Khamidov in Airflow
Panchenko Andrey
Это я тоже предлагал
да, спасибо
Пока проектирую схему для использования файлов удобную
источник

ME

Max Efremov in Airflow
Panchenko Andrey
Как проверить?
много сенсоров 😁
источник

AK

Anvar Khamidov in Airflow
пока у меня только файл, который используем и флаг с уведомлением
источник

PA

Panchenko Andrey in Airflow
Max Efremov
много сенсоров 😁
Хорош
источник