from tqsdk import TqApi import datetime import pandas as pd import time api = TqApi() pd.set_option(‘display.max_colwidth’, 10000) pd.set_option(‘expand_frame_repr’, False) pd.set_option(‘display.max_columns’, None, ‘display.max_rows’, None) # 获得 cu2003 10秒K线的引用 df = api.get_kline_serial(“SHFE.rb2010”, 10,1440) print(datetime.datetime.fromtimestamp(df.iloc[-1][“datetime”] / 1e9)) def get_k(): while True: api.wait_update() time.sleep(1) df[‘Time’] = pd.to_datetime(df[‘datetime’]) return df while True: df=get_k() df2=df df2[‘Time’] = df2[‘Time’] + pd.Timedelta(hours=8) df2[’ema5′] = df2[‘close’].rolling(5, min_periods=1).mean() df2[’ema20′] = df2[‘close’].rolling(20, min_periods=1).mean() df2[’ema120′] = df2[‘close’].rolling(120, min_periods=1).mean() print(df2) # bd_15 = df2.loc[df2[’ema5′] <4000, ’ema5′].values[0] # # # df2[‘bd_ab’] = df2[’ema5′] / bd_15 # # df2.loc[df2[‘bd_ab’] > 2.5, ‘duo’] = 1
注释部分去掉注释之后k线数据就不更新了，不去掉注释可以更新，弄了几天了一计算指标就不能更新也不报错
