我在本地运行了一个Docker化的PostgreSQL,可以通过pgAdmin4和psql
连接到它。
使用相同的连接细节,在UI上设置了一个Airflow连接。
然而,当尝试加载使用该连接的DAG时,会抛出错误:
Broken DAG: [/usr/local/airflow/dags/s3upload.py] Traceback (most recent call last): File "/usr/local/lib/python3.7/site-packages/airflow/providers/postgres/hooks/postgres.py", line 113, in get_conn self.conn = psycopg2.connect(**conn_args) File "/usr/local/lib/python3.7/site-packages/psycopg2/init.py", line 127, in connect conn = _connect(dsn, connection_factory=connection_factory, **kwasync) psycopg2.OperationalError: could not connect to server: Connection refused Is the server running on host "127.0.0.1" and accepting TCP/IP connections on port 54320?
如上所述,PostgreSQL实例正在运行,并且端口转发处于活动状态,这已通过成功的pgAdmin和psql
登录证明。
有任何想法吗?