Репозиторий для размещения моих DAG'ов.
Это два простых DAG'a для Airflow. Что они делают:
- Берут данные из OpenWeatherMap API
- Достают данные из json файла
- Загружают данные в базу данных PostgreSQL
Они ничем не отличаются функционально, но api-ex-db_orm_dag.py оспользует ORM, вместо обычных запросов к базе данных через engine.connect()
Чтобы посмотреть как они работают, скачайте api-ex-db/aed-poc.mp4 и посмотрите любым удобным способом.
Этот DAG собирает коды ответа от сайтов из списка и отсылает репорт по телеграму.
Чтобы посмотреть как они работают, скачайте status-collector/sc-poc.mp4 и посмотрите любым удобным способом.