#oracle #airflow
#Oracle #воздушный поток
Вопрос:
я пытаюсь перенести данные из одного oracle_db1.table1 в другой oracle_db2.table1. Я уже установил backport-provider:https://pypi.org/project/apache-airflow-backport-providers-oracle /. Импорт теперь работает нормально. Но при попытке выполнить первые задачи я получаю эту ошибку. Я думаю, что это что-то о соединении:
Вот журнал ошибок
[2020-08-18 12:30:15,485] {logging_mixin.py:112} INFO -
[2020-08-18 12:30:15,485] {base_hook.py:84}
INFO - Using connection to: id: DB1234.
Host: 192.168.50.123:1521/testserver, Port: 1521, Schema: blup, Login: blup, Password: xxXXX, extra: None
[2020-08-18 12:30:15,485] {logging_mixin.py:112} INFO -
[2020-08-18 12:30:15,485] {connection.py:342} ERROR - Expecting value: line 1 column 1 (char 0).
И вот мой пример задачи DAG:
T3 = OracleToOracleOperator(
task_id="insert_data_to_db",
oracle_destination_conn_id= "BCDEFG",
destination_table= "BCDEFG.TEST_BENUTZER3",
oracle_source_conn_id= "DESTINATION_DB",
source_sql= """
SELECT * FROM DESTINATION_DB.BENUTZER
""",
source_sql_params=None,
rows_chunk=5000
)
Заранее спасибо
Комментарии:
1. Можете ли вы показать мне свой объект подключения? Как вы это добавляете? Также проверьте, хорошо ли подключается ваш экземпляр airflow.
2. Здравствуйте, проблема решена. Это была проблема с подключением. Были входные данные в «extra». Я удалил их. теперь это работает. Спасибо
Ответ №1:
проблема с подключением. Были входные данные в «extra». Я удалил их. тогда это работает