import pymysql.cursors import pymysql import pandas as pd from datetime import datetime import numpy as np
config = { 'host':'127.0.0.1', 'port':3306, 'user':'root', 'password':'123456', 'db':'stock', 'charset':'utf8', 'cursorclass':pymysql.cursors.DictCursor, } con= pymysql.connect(**config) try: with con.cursor() as cursor: sql="select * from stock_price limit 10" cursor.execute(sql) results=cursor.fetchall() finally: con.close();
df=pd.DataFrame(results) df.head()
print(df) print('\n\n') df['ma3']=df['Close'].rolling(3,min_periods=1).mean() print(df)