sqlalchemy通过ssh连接远程mysql服务器

Posted 黄土地上的黑石头

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了sqlalchemy通过ssh连接远程mysql服务器相关的知识,希望对你有一定的参考价值。

 首先需要一个模块sshtunnel,如果没有直接pip install sshtunnel

from sshtunnel import SSHTunnelForwarder
from sqlalchemy import Column, String, Integer, create_engine, event
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.exc import DisconnectionError

ssh_host = ""  # 堡垒机ip地址或主机名
ssh_port = 22  # 堡垒机连接mysql服务器的端口号,一般都是22,必须是数字
ssh_user = ""  # 这是你在堡垒机上的用户名
ssh_password = ""  # 这是你在堡垒机上的用户密码
mysql_host = ""  # 这是你mysql服务器的主机名或ip地址
mysql_port = 3306  # 这是你mysql服务器上的端口,3306,mysql就是3306,必须是数字
mysql_user = ""  # 这是你mysql数据库上的用户名
mysql_password = ""  # 这是你mysql数据库的密码
mysql_db = "" # mysql服务器上的数据库名

Base = declarative_base()

class Phones(Base):
    __tablename__ = ‘phones‘
    id = Column(Integer, primary_key=True)
    name = Column(String(32))


def checkout_listener(dbapi_con, con_record, con_proxy):
    try:
        try:
            dbapi_con.ping(False)
        except TypeError:
            dbapi_con.ping()
    except dbapi_con.OperationalError as exc:
        if exc.args[0] in (2006, 2013, 2014, 2045, 2055):
            raise DisconnectionError()
        else:
            raise


with SSHTunnelForwarder(
        (ssh_host, ssh_port),
        ssh_username=ssh_user,
        ssh_password=ssh_password,
        remote_bind_address=(mysql_host, mysql_port)
) as server:
    server.start()  # ssh通道服务启动
    local_port = str(server.local_bind_port)
    engine = create_engine(
        ‘mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8‘.format(mysql_user, mysql_password, ‘127.0.0.1‘, local_port,mysql_db),
        pool_size=100,
        pool_recycle=3600)

    event.listen(engine, ‘checkout‘, checkout_listener)  # 防止报连接池相关的错误
    Base.metadata.create_all(engine)  # 检测文件中所有继承了Base类的类,在mysqld中建立所有的表,类就是表
    Session = sessionmaker(bind=engine)
    session = Session()

 

以上是关于sqlalchemy通过ssh连接远程mysql服务器的主要内容,如果未能解决你的问题,请参考以下文章

ubuntu16.04 ssh服无法远程连接解决办法

ssh免密连接远程服务器

使用带有公钥和密码的 SSH 隧道通过 SQLAlchemy 连接到远程 PostgreSQL 数据库,所有这些都来自 Windows 机器

如何通过 ssh 将 php 应用程序与远程 mysql 数据库连接起来

Windows平台使用Navicat for MySQL通过SSH密钥认证连接远程MySQL数据库

Navicat远程连接MySQL服务器