pandas to_sql sqlalchemy 与secure_transport的连接答案

【问题标题】：pandas to_sql sqlalchemy connection with secure_transportpandas to_sql sqlalchemy 与secure_transport的连接
【发布时间】：2019-10-17 22:22:27
【问题描述】：

我正在尝试将数据发送到具有 --require_secure_transport=ON 的服务器上的 mysql 数据库。

当我尝试使用以下代码连接到它时

import pandas as pd
import pymysql
from sqlalchemy import create_engine

connect_string = 'mysql+pymysql://{}:{}@{}/{}'.format(user,pw,host,database)
connector = create_engine(connect_string)   
df = pd.read_csv('iris.data')
df.to_sql('iris',connector,if_exists='replace',index_label='id')

我收到以下错误

InternalError: (pymysql.err.InternalError) (3159, 'Connections using insecure transport are prohibited while --require_secure_transport=ON.') (Background on this error at: http://sqlalche.me/e/2j85)

我已经搜索了如何使连接器使用 secure_transport 的选项，但我找不到任何可行的方法。

我发现一个解决方案要求将 ?ssl=true 添加到 connect_string 的末尾

connect_string = 'mysql+pymysql://{}:{}@{}/{}?ssl=true'.format(user,pw,host,database)

但这给出了以下错误

    ca = sslp.get('ca')

AttributeError: 'str' object has no attribute 'get'

我可以通过这种方式仅使用 pymysql 连接到数据库

ssl={'ssl': {'key': 'ssl/client-key.pem','cert': 'ssl/client-cert.pem','ca': 'ssl/ca-cert.pem'}}
con = pymysql.Connect(host,user,pw,database,ssl=ssl)
cur = con.cursor()
cur.execute("show tables;")

但我找不到使用 sqlalchemy 连接器实现此功能的方法。有人对如何使它起作用有一些建议吗？

问候

【问题讨论】：

标签： python python-3.x pandas ssl sqlalchemy

【解决方案1】：

在环顾四周后想出了解决方案。

Mysql 通常设置为在没有提供给它的情况下即时生成 ca 文件和密钥，但问题是向 pymysql 发送正确的标志，因此它不会去寻找本地 ca 文件。

在这里找到了这个： Unable to make TLS TCP connection to remote MySQL server with PyMySQL, other tools work

您只需传递一个带有“ssl”键的字典，该字典有一个带有值为 True 的键的字典。为了清楚起见，我使用键名“fake_flag_to_enable_tls”，但它可以是任何看起来的东西。

connect_args={'ssl':{'fake_flag_to_enable_tls': True}}
connect_string = 'mysql+pymysql://{}:{}@{}/{}'.format(user,pw,host,database)
connector = create_engine(connect_string,connect_args=connect_args) 
df = pd.read_csv('iris.data')
df.to_sql('iris',connector,if_exists='replace',index_label='id')

希望其他人觉得这很有用。

【讨论】：