1. 连接sqlalchemy

pandas.read_sql 可以在数据库中执行指定的SQL语句查询，以DataFrame 的类型返回查询结果。

import sqlalchemy
import pandas as pd

# 创建数据库连接，这里使用的是pymysql
engine = sqlalchemy.create_engine("mysql+pymysql://username:password@ip:port/store_name")
sql = "select * from test where id = %(pid)s"
# 使用 params 进行参数传递
data_df = pd.read_sql(sql, engine, params={'pid': '1'})

备注：使用 read_sql 中的 params 传入参数

pd.read_sql(sql, con, index_col=None, coerce_float=True, params=None, parse_dates=None, columns=None, chunksize=None)[source]

2. 连接mysql

#coding=utf-8
import pymysql
import pandas as pd

# 连接数据库
conn = pymysql.connect(
    host='10.11.11.101',
    port=9527,
    user='BI',
    passwd='qBy112wer',
    db='tt',
    charset='utf8'
)

sql_1 = "select from_unixtime(send_time, '%Y-%m-%d %H:%i:%s') as timeStr from db_name.table_name where task_id={};".format(id)
res = pd.read_sql(sql_1, conn)
print(res)

conn.close()