import jqdatasdk from jqdatasdk import * # 登录聚宽账号 jqdatasdk.auth('your_username', 'your_password') def get_top5_sectors(): # 获取上一个交易日日期 last_trading_day = get_last_datetime().strftime('%Y-%m-%d') # 获取所有行业和概念板块的代码列表 # 这里以中证行业指数为例,你可以根据需要修改为其他板块指数 sector_indexes = get_all_securities(types=['index'], date=last_trading_day) sector_indexes = sector_indexes[sector_indexes['name'].str.contains('行业指数')] sector_codes = sector_indexes.index.tolist() # 获取这些板块上一个交易日的涨跌幅数据 price_data = get_price(sector_codes, start_date=last_trading_day, end_date=last_trading_day, fields=['pct_change']) pct_change_data = price_data['pct_change'].iloc[0] # 筛选涨幅 TOP5 的板块 top5_sectors = pct_change_data.sort_values(ascending=False).head(5) # 输出结果 result = [] for code, pct_change in top5_sectors.items(): sector_name = sector_indexes.loc[code]['name'] result.append({ 'code': code, 'name': sector_name, 'pct_change': pct_change }) return result # 调用函数获取涨幅 TOP5 的板块 top5_sectors = get_top5_sectors() for sector in top5_sectors: print(f"代码: {sector['code']}, 名称: {sector['name']}, 涨幅: {sector['pct_change']}%")
您需要登录后才能查看源码,点击登录
点赞 0