Шаг 1 из 1

В этом модуле я расскажу как написать свой Operator и Hook. Они будут нужны нам для взаимодействия с внешним API сервисом, хранящим курсы валют. Также мы будем использовать PostgreOperator для укладки полученных данных в таблицу, которую также будет создавать отдельным таском.

Полный исходный код DAG вы можете найти в репозитории курса.

Начальный DAG выглядит следующим образом:

В пайплайне 3 таска:

1. create_table, отвечает за создание таблицы в базе данных PostgreSQL
2. get_rate, собственный Operator для работы с API сервиса курсов валют
3. insert_rate, укладывает полученный курс в таблицу, созданную в таске create_table