GCPのCompute Engine上にMySQLサーバAと処理を実行するサーバBを立てています。
サーバBで発行した秘密鍵をサーバAにきちんと登録し、
ターミナルから以下のコマンドでSSH接続をすると問題なくアクセスができます。
海外のサイトに少しWith構文でSSH接続をするのをやめたら回避できたなどと言ったコメントを見たのですが、
試していません。
なにか下記のアプローチで根本的に誤っているところなどありましたら、お知恵をお貸し頂きたく。
ちなみに同じコードで同じ鍵を使ってローカル環境からサーバAに接続しても問題なくアクセスできます。
Pathなどの問題なのでしょうか。。。?
Terminal
1ssh ユーザー名@外部IP -i ~/.ssh/key -p 22
しかし、Python上で以下のコードだとエラーが出ます。
Error
12020-10-07 00:19:37,958| ERROR | Problem setting SSH Forwarder up: Couldn't open tunnel localhost:3306 <> localhost:3306 might be in use or destination not reachable 2Traceback (most recent call last): 3 File "SSHConnectionCheckForGCP.py", line 3, in <module> 4 a = hoge.hoge() 5 File "/home/hoge/hoge/hoge/hoge2.py", line 9, in hoge2 6 Columns = SQLOutputSorting.GetColumnsOfDB(sql1) 7 File "/home/hoge/hoge/hoge/hoge1.py", line 10, in hoge 8 temp2 = DataTakeFromDB.DataTakeFromDB(tempList2) 9 File "/home/hoge/hoge/hoge/hoge3.py", line 49, in hoge3 10 local_bind_address=(localhost, MYSQL_PORT) 11 File "/home/hoge/.pyenv/versions/3.7.0/lib/python3.7/site-packages/sshtunnel.py", line 1552, in __enter__ 12 self.start() 13 File "/home/hoge/.pyenv/versions/3.7.0/lib/python3.7/site-packages/sshtunnel.py", line 1307, in start 14 'An error occurred while opening tunnels.') 15 File "/home/hoge/.pyenv/versions/3.7.0/lib/python3.7/site-packages/sshtunnel.py", line 1100, in _raise 16 raise exception(reason) 17sshtunnel.HandlerSSHTunnelForwarderError: An error occurred while opening tunnels.
Python
1import mysql.connector 2from sshtunnel import SSHTunnelForwarder 3 4def SQLExecution(sqlList): 5 HOST = 'サーバAの外部IP' 6 PORT = 22 # SFTPのポート 7 USER = 'ユーザー名'#SSH接続の鍵に指定したユーザ名 8 KEY_FILE = '秘密鍵のファイル' # 秘密鍵ファイル 9 MYSQL_PORT = 'ポート番号' 10 11 SSH_BASTION_ADDRESS = HOST 12 SSH_PORT = PORT #GCEのPORT 13 SSH_USER = USER #秘密鍵に設定したユーザー名 14 SSH_PKEY_PATH = KEY_FILE #秘密鍵のパス 15 16#SSH接続する 17 with SSHTunnelForwarder( 18 (SSH_BASTION_ADDRESS, SSH_PORT), 19 ssh_pkey=SSH_PKEY_PATH, 20 ssh_username=SSH_USER, 21 # ssh_password=PASSPHRASE, 22 remote_bind_address=('localhost', MYSQL_PORT), 23 local_bind_address=('localhost', MYSQL_PORT) 24 ) as ssh: 25 処理A 26 処理B 27 処理C
hoge.py
1import SQLExecution 2temp = [] 3temp.append(SQL文) 4SQLExecution.SQLExecution(temp)
あなたの回答
tips
プレビュー