标签:em hsgt north akshare df flow 净流入 北向 stock
import akshare as ak stock_hsgt_north_net_flow_in_em_df = ak.stock_hsgt_north_net_flow_in_em(symbol="北上") stock_em_hsgt_north_cash_df = ak.stock_hsgt_north_cash_em(symbol="北上") stock_hsgt_north_acc_flow_in_em_df = ak.stock_hsgt_north_acc_flow_in_em(symbol="北上") print('北向净流入',stock_hsgt_north_net_flow_in_em_df) # print('北向资金余额',stock_em_hsgt_north_cash_df) # print('北向累计净流入',stock_hsgt_north_acc_flow_in_em_df) for one in stock_hsgt_north_net_flow_in_em_df.values: # print(one[1]) if one[1]<0: print(one) """遍历每一个交易日,对北上进行分析""" signal = '无信号' for index, row in stock_hsgt_north_net_flow_in_em_df.iterrows(): # print(index) # print(row) if index<252: continue df_data_temp = stock_hsgt_north_net_flow_in_em_df.iloc[index-252:index] # 计算近 252 天的平均数和标准差 average = df_data_temp['value'].sum()/252 std = df_data_temp['value'].std() # 计算上下限 up_line = float(format(average + std * 1.5, '.4f')) down_line = float(format(average - std * 1.5, '.4f')) # 判断并输出 if row['value'] >= up_line: signal = '看多' print('{0}:<{1}> 北上净流入:{2}亿元,看多线:{3}亿元, 看空线:{4}亿元'.format(row['date'], signal, format(row['value'], '.4f'), up_line, down_line)) elif row['value'] <= down_line: signal = '看空' print('{0}:<{1}> 北上净流入:{2}亿元,看多线:{3}亿元, 看空线:{4}亿元'.format(row['date'], signal, format(row['value'], '.4f'), up_line, down_line)) if index == stock_hsgt_north_net_flow_in_em_df.shape[0] - 1: print('\n最新数据\n{0}: <{1}> \n北上净流入:{2}亿元,看多线:{3}亿元, 看空线:{4}亿元\n'.format(row['date'], signal, format(row['value'], '.4f'), up_line, down_line))
但是akshare只能获取净流入,北向余额和累计净流入,本策略使用净买入会更好,如果有知道如何又akshare计算净买入的,欢迎评论区告知!!!
标签:em,hsgt,north,akshare,df,flow,净流入,北向,stock 来源: https://www.cnblogs.com/xingnie/p/16103126.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。