mongo.py 文件源码

def get_range_daily_data(self, code, start=None, end=None):
        print u'????%s????' %code
        # date    open  high  close   low      volume       amount
        df = fc.get_stock_daily_data(code, start, end) 
        if df is None: 
            return
        #df.to_csv(str(code)+ "daily.csv")
        for row in range(0, df.shape[0]) :
            # daily data 
            dailybar = {
                'date' : str(df.index[row].date()),
                'open' : str(df.iat[row, 0]),
                'high' : str(df.iat[row, 1]),
                'low' : str(df.iat[row, 3]),
                'close' : str(df.iat[row, 2]),
                'volume' : str(df.iat[row, 4]),
                'amount' : str(df.iat[row, 5])
            }
            try:
                self.Daily_Db[code].insert(dailybar)
            except:
                pass
        self.Daily_Db[code].ensure_index([('date', pymongo.DESCENDING)])