这个问题可能涉及到一些后端代码和配置的问题。首先,需要检查Postgres Hook的连接是否正常。在Airflow的DAG文件中,可以添加一个PythonOperator来测试Postgres Hook连接。例如:
from airflow.hooks.postgres_hook import PostgresHook
from airflow.operators.python_operator import PythonOperator
def test_postgres_hook():
hook = PostgresHook(postgres_conn_id='my_postgres_conn')
conn = hook.get_conn()
print('Connected to Postgres')
test_conn_task = PythonOperator(
task_id='test_postgres_connection',
python_callable=test_postgres_hook,
dag=dag,
)
运行DAG后,将会从logs中看到‘Connected to Postgres’。 如果Postgres Hook连接成功,请查看您的代码中的执行语句是否正确。例如,您的代码是否尝试写入不存在的列或表格?您的代码是否使用正确的列名和数据类型进行插入? 最后,可以尝试在Postgres数据库中运行查询,以查看您是否成功插入了数据。如果查询没有数据返回,请检查数据是否正确写入表格中。