碼農(nóng)小馬七夕節(jié)去相親了，見了一個不錯的姑娘,，長的非常甜美,！聊著聊著很投緣！通過介紹人了解到,，對方也很滿意～～想著自己單身多年的生活就要結(jié)束啦,，心里滿是歡喜，美美噠,！但是突然想起年初還有幾萬塊在股市里面,，一直被套著，心里難受,！

為了以后能多一點娶老婆的本錢,，日子過的好一點，怎么咬著牙也要把股票的錢撈回來,，這些可都是辛苦加班賺來的呀,！怎么辦呢，于是一咬牙,，干脆用萬能的Python寫一個量化股票系統(tǒng),！

image

這個小迷小量化系統(tǒng),，麻雀雖小但是五臟俱全，我們今天先從實時提醒這個模塊做起,，提醒系統(tǒng)分下面幾個部分：

-實時獲取股票數(shù)據(jù)

-連接郵件服務器

-預警配置管理

-監(jiān)控數(shù)據(jù)并發(fā)送郵件

希望通過實時提醒,，來提高交易的收益率，試試看,，萬一有用呢,，反正寫代碼對碼農(nóng)來說，so easy!

一.實時獲取股票價格

為了更準確的獲取股票的價格,，我們這里用比較有名的金融庫tushare來獲取,，里面封裝了大量的股票的數(shù)據(jù)Api，非常好用,！

image

1).首先設計一個stock類,，這個類第一件大事：

查詢股票的實時價格和k線數(shù)據(jù)比如(5min,15min),然后把數(shù)據(jù)返回出來，為了提高效率,，我們肯定是用并發(fā)出來,，所以start_run函數(shù)會成為一個線程函數(shù)

2).第二件大事：

我們獲取的實時的數(shù)據(jù)，需要傳遞給外邊的模塊調(diào)用,，子線程和主線程間通信的話,，最簡單的方法用queue來搞定，所以我們stock類會init里面?zhèn)魅胍粋€queue

3).控制線程：

這個stock我們希望外邊能控制它的運行和停止,，在stock類的入口,，我們加入了一個_terminal變量

4).神奇的tushare庫

利用tushare這個神奇的API,構(gòu)造兩個類函數(shù)分布query_stock_real_price和get_kline_data獲取數(shù)據(jù)：

def query_stock_real_price(self):

df = ts.get_realtime_quotes(self.stock_num)

df=df[['price','time']]

price=df['price'].values[0]

time=df['time'].values[0]

return price,time

def get_kline_data(self, ktype='ma5'):

today=datetime.now().strftime('%Y-%m-%d')

df = ts.get_hist_data(self.stock_num, start='2018-08-08', end=today)

return (df[[ktype]])

二.郵件系統(tǒng)

簡單實時提醒系統(tǒng)，我們用郵件,，比如你的qq郵箱,，是可以實時的收到一些郵件提醒的信息，我們這里用Python自帶的 SMTP和EMAIL模塊處理：

1). 連接郵件服務器

image

為了方便擴展和復用,，也用一個類來封裝郵件server!構(gòu)造一些郵件服務器的地址和密碼,，然后連接就可以了，非常簡單,。

2).構(gòu)造郵件內(nèi)容

服務器連接好了,，之后我們需要發(fā)送郵件，需要寫一個郵件標題和內(nèi)容,，比如 xx股票,，現(xiàn)在價格多少之類的。

image

1).為了更好的封裝數(shù)據(jù),，用類裝飾器對titel和content進行封裝,，這樣外邊無法直接訪問這兩塊內(nèi)容。

2).mail類會初始化一些信息,，比如要發(fā)送到郵件地址,，而且要把前面構(gòu)造好的SMTP服務器對象傳進來,，方便發(fā)送郵件。

image

3).初始化一個MIMEText對象,，填充一些郵件的內(nèi)容比如from,to,subject等等,。為了有時間性，我們在郵件的開頭加一個時間戳,。

三.預警系統(tǒng)

我們需要有一個配置文件,，里面不停的修改我們對股票的價格的設置，比如到了你的止損或者止盈的位置,，或者到了你的一些量化策略的地方,，需要提醒你注意等等。這里我們只是簡單的說明,，只寫最大和最小的股價預警,，示例一下：

setting 文件：

{

'high_price': 15,

'low_price': 10

}

1).死循環(huán)監(jiān)控數(shù)據(jù)

我們啟動一個線程，用一個死循環(huán)來不停的從隊列里面獲取股票的數(shù)據(jù),，然后進行一些監(jiān)聽的邏輯判斷,，先看一下核心代碼：

image

因為股票有交易時間，我們這里簡單粗暴的讓程序只在交易時間運行,，當然如果要把程序放在遠端服務器上的話,，需要進一步優(yōu)化,不然每一天都要啟動一下！

死循環(huán)里面會不停的讀區(qū)預警設置里面的股價的漲到多少最高價和最低價,，一旦觸達這個價格,，立刻發(fā)送郵件提醒！

寫了這么久,，看一下效果吧：

image

好了,，上面是一個簡單的股票實時提醒程序，利用了一些Python自帶的郵件庫和一個金融庫,，算是一個綜合小練習！,，完成一個量化系統(tǒng),，還有兩個重要的功能沒有完成，需要繼續(xù)加油,，歡迎大家留言討論,。