我正在尝试使用Python连接到一个PostgreSQL实例,它通过一个SSH隧道位于Azure上。我可以用DBeaver连接到数据库,没有任何问题。这是我正在使用的代码。
from sshtunnel import SSHTunnelForwarder
server = SSHTunnelForwarder(
('160.**.**.**', 22),
ssh_username="*******",
ssh_password="*******",
remote_bind_address=('localhost', 5432))
server.start()
print("server connected")
params = {
'database': '*******',
'user': '*****postgresadmin@*****dev-postgres',
'password': '************',
'host': '**********-postgres.postgres.database.azure.com',
'port': server.local_bind_port
}
conn = psycopg2.connect(**params)
cur = conn.cursor()
text = "select * from table"
cur.execute(text)
然而,我得到了以下错误:
conn = _connect(dsn, connection_factory=connection_factory, **kwasync) psycopg2.OperationalError: could not translate host name "**********-postgres.postgres.database.azure.com" to address: Unknown host
我还使用this尝试了sqlalchemy,也得到了相同的结果。你知道我做错了什么吗?我是否需要主机的IP地址而不是域?
发布于 2021-05-31 16:26:52
如果您想在远程服务器上执行某些操作,则可以使用SSHTunnelForwarder。
如果您需要使用远程服务器作为连接到另一台服务器的桥梁,则需要另一个代码块:
import sshtunnel
with sshtunnel.open_tunnel(
(REMOTE_SERVER_IP, 443),
ssh_username="",
ssh_password="*******",
remote_bind_address=(AZURE_SERVER_HOST, 22),
local_bind_address=('0.0.0.0', 10022)
) as tunnel:
params = {
'database': '*******',
'user': '*****postgresadmin@*****dev-postgres',
'password': '************',
'host': '127.0.0.1',
'port': 10022
}
conn = psycopg2.connect(**params)
cur = conn.cursor()
text = "select * from table"
cur.execute(text)
https://stackoverflow.com/questions/67768598
复制相似问题