from tqsdk import TqApi, TqAuth
api = TqApi(auth=TqAuth("账号", "密码")) # 账号登录
quote = api.get_quote("SHFE.ag2106") # 订阅沪银2106的行情
klines_M = api.get_kline_serial("SHFE.ag2106", 5 * 60) # 订阅沪银2106的5分钟周期的K线数据
while True:
api.wait_update() # 等待行情更新函数
lowest = min(klines_M.low.iloc[-3:-1]) # 获取前三根K线的最低点
highest = max(klines_M.high.iloc[-3:-1]) # 获取前三根K线的最高点
if quote.last_price < lowest: # 判断行情的最新价是否跌破前三根K线的最低点
print("最新价跌破了前三根K线的最低点!!!")
elif quote.last_price > highest: # 判断行情的最新价是否跌破前三根K线的最低点
print("最新价跌破了前三根K线的最高点!!!")
jeepman 发表新评论 2021年2月27日
补充一下,最后一行代码应该是“print (‘最新价突破了前三根K线的最高点!!!’)”
希望对你有所帮助