Я изучаю поток воздуха, и мне нужно создать dag, который будет подключаться к удаленной базе данных oracle и вставлять данные из одной таблицы в другую. Ниже описано, что я делал до сих пор
- После установки запустил
pip install 'apache-airflow[oracle]', чтобы я мог использовать oracle operator - Созданная строка подключения из пользовательского интерфейса для подключения к удаленной базе данных
- Затем я написал свой первый даг, но он, похоже, не запускался.
Прежде чем я попытаюсь выяснить, почему он не работает, я хочу убедиться, что мне нужно что-то сделать другие шаги, которые я мог пропустить, как некоторые изменения в файле airflow.cfg, особенно в sql_alchemy_conn (этот файл я нашел в моем домашнем каталоге) или если требуется установить cx_oracle, чтобы я мог подключиться к удаленной базе данных или просто требуется строка подключения (шаг 2 выше).
О воздушном потоке упоминается так много вещей, но пока неясно, какие именно шаги выполняются. Если кто-то может помочь мне в этом, это будет высоко ценится. Это могут быть основы, но я застрял в том, что делать от начала до конца. Пожалуйста, помогите
Спасибо !!