import tushare as ts
import time
# 设置股票代码和监控条件
stock_code = '600519'
monitor_condition = 4000
# 获取股票实时数据
def get_stock_data():
df = ts.get_realtime_quotes(stock_code)
return df
# 监控股票价格
def monitor_stock_price():
while True:
df = get_stock_data()
price = float(df['price'][0])
if price >= monitor_condition:
# 符合条件,进行买入操作
print('股票价格符合条件,进行买入操作')
# TODO: 进行买入操作
time.sleep(5)
# 扫描大盘股票
def scan_market_stocks():
while True:
df = ts.get_today_all()
for index, row in df.iterrows():
if row['code'] == stock_code:
continue
price = float(row['trade'])
if price >= monitor_condition:
# 符合条件,加入监控列表
print('股票符合条件,加入监控列表')
# TODO: 将股票加入监控列表
time.sleep(60)
# 启动股票监控和大盘扫描
if __name__ == '__main__':
# TODO: 创建监控列表
# 启动股票监控线程
stock_monitor_thread = threading.Thread(target=monitor_stock_price)
stock_monitor_thread.start()
# 启动大盘扫描线程
market_scan_thread = threading.Thread(target=scan_market_stocks)
market_scan_thread.start()
在上述代码中,我们使用了tushare库来获取股票实时数据和大盘股票数据。在monitor_stock_price
函数中,我们使用一个无限循环来不断监控股票价格,如果符合条件就进行买入操作。在scan_market_stocks
函数中,我们使用一个无限循环来不断扫描大盘股票,如果符合条件就将其加入监控列表。最后,我们使用多线程的方式来同时启动股票监控和大盘扫描,以实现实时监控股票并持续扫描大盘的功能。
文章来源于互联网:如何用python实时监控股票,并且持续扫描大盘?