[Python3]SSH経由でMYSQLに接続できない

Question

Pythonからのmysql接続で詰まったので相談させてください。

あるMYSQLのDBにSSH経由で接続したいと思っていますが、うまくいきません。
Mac OSで、Python3.6です。

下記にpythonのコードと、エラーメッセージを転記します。

# -*- coding: utf-8 -*-

from sshtunnel import SSHTunnelForwarder
import MySQLdb #package:mysqlclient

with SSHTunnelForwarder(
		("[www.abc.com]",22),
		ssh_host_key=None,
		ssh_pkey=None,
		ssh_username="[ssh_username]",
		ssh_password="[ssh_password]",
		remote_bind_address=("127.0.0.1", 3306)
	) as ssh:
	conn = MySQLdb.connect(
		host="127.0.0.1",
		user="[db_username]",
		password="[db_password]",
		db = "[db_name]",
		charset="utf8"
	)
	c = conn.cursor()
	c.execute( 'show tables' )
	conn.commit() #施した変更を保存する

	for row in c.fetchall():
		print(row)
	print('=====')

	conn.close()

上記を実行し、表示されたエラーメッセージが下記。

$ python mysql_ssh_test.py
Traceback (most recent call last):
  File "mysql_ssh_test.py", line 21, in <module>
    charset="utf8"
  File "/Users/user_name/Python/lib/python3.6/site-packages/MySQLdb/__init__.py", line 86, in Connect
    return Connection(*args, **kwargs)
  File "/Users/user_name/Python/lib/python3.6/site-packages/MySQLdb/connections.py", line 204, in __init__
    super(Connection, self).__init__(*args, **kwargs2)
_mysql_exceptions.OperationalError: (2003, "Can't connect to MySQL server on '127.0.0.1' (61)")

ちなみに、通常そのDBに接続する際は、SeaquelProを利用しており、SSHを通じてDBにアクセスができています。その設定画面が下記です。

とりあえずSSH経由でMYSQL接続が成功できればと思っています。
どうぞよろしくお願いします。

Answer 1

local_bind_addressを指定していないのでMySQLへ接続するときに接続ポートをssh.local_bind_portにしてあげないといけないと思います。

https://sshtunnel.readthedocs.io/en/latest/

local_bind_address (tuple) – Local tuple in the format (str, int) representing the IP and port of the local side of the tunnel. Both elements in the tuple are optional so both ('', 8000) and ('10.0.0.1', ) are valid values

Default: ('0.0.0.0', RANDOM_PORT)

Comments

[r1_1092829]

YouheiSakurai 様

回答ありがとうございます。
おっしゃっていただいた通りでした。

Mysql接続に関して、下記のようにssh.local_bind_portを書き加えたところ動きました！

conn = MySQLdb.connect(
host="127.0.0.1",
port = ssh.local_bind_port,
user="[db_username]",
password="[db_password]",
db = "[db_name]",
charset="utf8"
)

この度はありがとうございました！
引き続きよろしくお願いします。