sql >> Databasteknik >  >> RDS >> Mysql

SSH-tunneln från Python stängs automatiskt

Enligt steven-rumbalski s kommentar ovan:

Ersätt: with SSHTunnelForwarder(...) as server
Med: server = SSHTunnelForwarder(...)
Sätt sedan in: server.start() ... server.stop()
runt koden du vill ska skickas via SSH-tunneln.

Här är den konverterade koden:

import pymysql, shlex, shutil, subprocess
import logging
import sshtunnel
from sshtunnel import SSHTunnelForwarder
import iot_config as cfg

def OpenSSHTunnel():
    global server
    sshtunnel.DEFAULT_LOGLEVEL = logging.DEBUG
    server = SSHTunnelForwarder(
        (cfg.sshconn['host'], cfg.sshconn['port']),
        ssh_username = cfg.sshconn['user'],
        ssh_private_key = cfg.sshconn['private_key_loc'],
        ssh_private_key_password = cfg.sshconn['private_key_passwd'],
        remote_bind_address = ('127.0.0.1', 3306)
    )

def OpenRemoteDB():
    global remotecur, remotedb
    remotedb = None
    remotedb = pymysql.connect(
        host='127.0.0.1',
        user=cfg.remotedbconn['user'],
        passwd=cfg.remotedbconn['passwd'],
        db=cfg.remotedbconn['db'],
        port=server.local_bind_port
    )
    remotecur = remotedb.cursor()
    print("Checkpoint 1")

def SyncActions():
    print("Checkpoint 2")
    # this should now work as expected
    remotecur.execute("SELECT ActionID, Description FROM cmAction")
    for r in remotecur:
        print(r)

# Main program starts here
OpenSSHTunnel()
server.start()
OpenRemoteDB()
SyncActions()
server.stop()



  1. Varför kan jag använda ett tecken som inte är en del av en teckenuppsättning (windows-1252)?

  2. Hur kan begränsningar för främmande nyckel tillfälligt inaktiveras med T-SQL?

  3. Ha mer än en AutoInkrement per tabell

  4. Hur man fyller på information i kolumner för e-post