如何通过Spark python启用SSL连接到MySql Rds？

Question

如何通过Spark python启用SSL连接到MySql Rds ?????

我们可以用ssl连接到Mysql RDS。

可以任何人告诉我们需要做什么配置？

Answer 1

此代码适用于连接到redshift和postgresql。我认为mySql也应该是一样的。只需更改数据库名称即可选择正确的驱动程序：

%pyspark
from sqlalchemy import create_engine
import pandas as pd
import psycopg2
sql = "select * from foo limit 10"
df = pd.read_sql(sql,create_engine("postgres://user:password@aws_url:port/database_name?sslmode=require").connect())
df.head(10)