如何通过Spark Python启用SSL连接到MySQL RD

Question

如何通过Spark Python启用SSL连接到MySQL RD

我们能够使用SSL连接到MySQL RD。

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

Answer 1

此代码可用于连接到RedShift＆amp;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)