如何使用气流将数据从一个 oracle 数据库传输到另一个 oracle 数据库答案

【问题标题】：How do I transfer data from one oracle database to another oracle database with airflow如何使用气流将数据从一个 oracle 数据库传输到另一个 oracle 数据库
【发布时间】：2020-08-18 14:24:51
【问题描述】：

我正在尝试将数据从一个 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
    )

提前感谢

【问题讨论】：

你能告诉我你的连接对象吗？你是怎么添加的？还要检查您的气流实例的连接是否良好。
您好，问题已解决。这是连接的问题。 “额外”中有输入。我删除了它们。现在它可以工作了。谢谢你

标签： oracle airflow

【解决方案1】：

连接问题。 “额外”中有输入。我删除了它们。然后就可以了

【讨论】：