sources.py 文件源码

def __init__(self,cfg_name='mysql_tunnel'):
        import paramiko
        import pymysql.cursors
        import pymysql
        self.host = luigi.configuration.get_config().get(cfg_name, 'host')
        self.database = luigi.configuration.get_config().get(cfg_name, 'database')
        self.user = luigi.configuration.get_config().get(cfg_name, 'user')
        self.password = luigi.configuration.get_config().get(cfg_name, 'password')
        self.port = int(luigi.configuration.get_config().get(cfg_name, 'port'))
        self.tunnel_dest_host = luigi.configuration.get_config().get(cfg_name, 'tunnel_dest_host')
        self.tunnel_dest_user = luigi.configuration.get_config().get(cfg_name, 'user')
        self.tunnel_source_host = luigi.configuration.get_config().get(cfg_name, 'tunnel_source_host ')
        self.tunnel_source_port = luigi.configuration.get_config().get(cfg_name, 'tunnel_source_port')
        self.channel = self.__tunnel__()
        self.connection = self.__connect__()
        self.cursor = self.connection.cursor()