2016-07-04 132 views
0

我正在使用sqlalchemy和pandas连接到数据库并从sql表创建数据框。SQL Alchemy:无法使用engine.connect连接()

这是我的代码:

port=3306 
unix_socket='/var/lib/mysql/mysql.sock' 

conn = "mysql://user:[email protected]/dbname?port=3306?unix_socket=/var/lib/mysql/mysql.sock" 

_engine = create_engine(conn) 
print conn 
print _engine 

db_conn=_engine.connect() 

输出:

Traceback (most recent call last): 
    File "runner_train_test.py", line 37, in <module> 
    _engine.connect() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/engine/base.                      py", line 2018, in connect 
    return self._connection_cls(self, **kwargs) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/engine/base.                      py", line 72, in __init__ 
    if connection is not None else engine.raw_connection() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/engine/base.                      py", line 2104, in raw_connection 
    self.pool.unique_connection, _connection) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/engine/base.                      py", line 2074, in _wrap_pool_connect 
    return fn() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 318, in unique_connection 
    return _ConnectionFairy._checkout(self) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 713, in _checkout 
    fairy = _ConnectionRecord.checkout(pool) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 480, in checkout 
    rec = pool._do_get() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 1060, in _do_get 
    self._dec_overflow() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/util/langhel                      pers.py", line 60, in __exit__ 
    compat.reraise(exc_type, exc_value, exc_tb) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 1057, in _do_get 
    return self._create_connection() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 323, in _create_connection 
    return _ConnectionRecord(self) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 449, in __init__ 
    self.connection = self.__connect() 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/pool.py", li                      ne 607, in __connect 
    connection = self.__pool._invoke_creator(self) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/engine/strat                      egies.py", line 97, in connect 
    return dialect.connect(*cargs, **cparams) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/sqlalchemy/engine/defau                      lt.py", line 385, in connect 
    return self.dbapi.connect(*cargs, **cparams) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/MySQLdb/__init__.py", l                      ine 81, in Connect 
    return Connection(*args, **kwargs) 
    File "/usr/local/anaconda2/lib/python2.7/site-packages/MySQLdb/connections.py"                      , line 193, in __init__ 
    super(Connection, self).__init__(*args, **kwargs2) 
TypeError: an integer is required 
+0

Aaaaaaaahhhhhh请使用四个空格格式化代码! –

+1

我不认为你可以使用unixsocket和端口。 – syntonym

+0

重复与答案:http://stackoverflow.com/questions/22557967/typeerror-an-integer-is-required-sqlalchemy-flask – Mixone

回答

0

你的连接字符串看起来是错误的。该sqlalchemy documentation州以下字符串:mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>或谷歌云计算的例子:mysql+mysqldb://[email protected]/<dbname>?unix_socket=/cloudsql/<projectid>:<instancename>所以你的字符串应probabably是:

mysql://[email protected]/dbname?unix_socket=/var/lib/mysql/mysql.sock