基于akshare查取每天五分钟成交额，35分钟成交额，1h成交额，并输出为cvs

import os
#定义start,end
#数据格式为1997 01 01 06 30 00
import fun1
import pandas as pd
import numpy as np
start="20221207"
end='20230114'
best_ip = fun1.select_best_ip()
#AKshare获取数据部分#需要建的变量，股票的本身数据，以及根据日期建立的dataframe格式
import akshare as ak
#获取当前正在交易的股票代码，以及今天的市场情况
stock_sh_a_spot_em_df = ak.stock_sh_a_spot_em()
stock_code_list=stock_sh_a_spot_em_df['代码']
print(stock_code_list)
total = pd.DataFrame(columns=['日期', '开盘', '收盘', '最高', '最低', '成交量', '成交额', '振幅', '涨跌幅', '涨跌额', '换手率','涨跌幅_5', '涨跌额_5', '成交量_5', '成交额_5', '振幅_5', '涨跌幅_10', '涨跌额_10','成交量_10', '成交额_10', '振幅_10', '涨跌幅_05', '涨跌额_05', '成交量_05', '成交额_05','振幅_05', '涨跌幅_1h', '涨跌额_1h', '成交量_1h', '成交额_1h', '振幅_1h'])
k=0
#code=stock_code_list[1]
for code in stock_code_list:#单次返回指定沪深京 A 股上市公司、指定周期和指定日期间的历史行情日频率数据,采用后复权stock_zh_a_hist_df = ak.stock_zh_a_hist(symbol=code, period="daily",start_date=start,end_date=end, adjust="hfq")#单次返回指定股票、频率、复权调整和时间区间的分时数据, 其中 1 分钟数据只返回近 5 个交易日数据且不复权，缺点是只能获取近些日期的if stock_zh_a_hist_df.empty == False:trade_days=stock_zh_a_hist_df['日期'].valuesdf = pd.DataFrame(columns=['涨跌幅_5', '涨跌额_5', '成交量_5', '成交额_5', '振幅_5', '涨跌幅_10', '涨跌额_10','成交量_10', '成交额_10', '振幅_10', '涨跌幅_05', '涨跌额_05', '成交量_05', '成交额_05','振幅_05', '涨跌幅_1h', '涨跌额_1h', '成交量_1h', '成交额_1h', '振幅_1h'])for i in range(0,trade_days.size):trade_day=trade_days[i]jj = ak.stock_zh_a_hist_min_em(symbol=code, start_date=trade_day+' 09:30:00', end_date=trade_day+' 10:30:00', period='5', adjust='hfq')#提取关键数据data_all=jj.iloc[np.arange(0,12,1),[5,6,7,8,9,10]]sum=data_all.iloc[0,0:5]data_5=sumfor j in np.arange(1,12,1):sum=data_all.iloc[j,0:5]+sumif j==5:data_10=sumif j ==6:data_05=sumif j==11:data_1h=sumdata_5.index = data_5.index + '_5'data_10.index=data_10.index+'_10'data_05.index = data_05.index + '_05'data_1h.index = data_1h.index + '_1h'c=pd.concat([data_5, data_10,data_05, data_1h],axis=0,ignore_index=False)df.loc[i]=cdel data_5, data_10,data_05, data_1h,sum#这个数据处理好后，加入stock_zh_a_hist_df 中，记录5min 10min 30min 35min的累计数据，以及，2.30， 2.35的数据，需要注意近些日期数据的获取，意味着部分过往数据无法获取stock_data=pd.concat([stock_zh_a_hist_df,df],axis=1,ignore_index=False)for i in range(0, trade_days.size):total.loc[k]=stock_data.iloc[i]k=k+1print('complete'+code)
outputpath = 'C:/Users/cbl/Downloads/result_test.csv'
total.to_csv(outputpath,sep=',',index=False,encoding = 'utf_8_sig',header=True)

采集到的数据上传在我的主页
后面基于采集到的数据，去除了大市值和小市值做了一些相关性分析，结果文件在我的主页，资源下载里面，自行下载

基于akshare查取每天五分钟成交额，35分钟成交额，1h成交额，并输出为cvs相关推荐

基于AKSHARE的自动选股软件（BOLL、KDJ、成交额、换手率）
1.爬取沪深300股票的数据(便于更新) #-----------------------------从网页上爬取沪深300的数据------------------------------- imp ...
python基于scrapy爬取京东笔记本电脑数据并进行简单处理和分析
这篇文章主要介绍了python基于scrapy爬取京东笔记本电脑数据并进行简单处理和分析的实例,帮助大家更好的理解和学习使用python.感兴趣的朋友可以了解下一.环境准备 python3.8.3 ...
两电平变流器matlab仿真,基于H桥级联型五电平逆变器Matlab仿真分析.doc
基于H桥级联型五电平逆变器Matlab仿真分析基于H桥级联型五电平逆变器Matlab仿真分析 [摘要]多电平逆变器广泛应用于电机调速等领域,本文在分析级联型逆变器的基础上,深入分析了SPWM控制技 ...
【Microsoft Azure 的1024种玩法】五十四. 十分钟快速上手创建部署Azure speech服务
[简介] Azure语音服务是Microsoft提供稳定可靠的云通信服务,其在单个 Azure 订阅中统合了语音转文本.文本转语音以及语音翻译功能,我们可以通过各种方式(语音 CLI.语音 SDK.S ...
Python爬虫基于Akshare库的内外盘期货数据直接调用
基于Akshare库的内外盘期货数据直接调用下面接口函数就行 import akshare as ak # 内盘-历史行情数据(新浪)def inside_history_data(star_, e ...
Android基于IIS的APK下载(五)IIS的配置
这里使用的IIS是win7_64的. 步骤一:打开IIS.控制面板->管理工具(如果没有,请把查看方式调成大图标)->Internet 信息服务(IIS)管理器. 步骤二:配置网站目录步 ...
NYOJ 358 取石子(五)
取石子(五) 时间限制:1000 ms | 内存限制:65535 KB 难度:4 描述 himdd最近很想玩游戏,于是他找到acmj和他一起玩,游戏是这样的:有一堆石子,两个人轮流从其中取走一定的 ...
CasperJS基于PhantomJS抓取页面
CasperJS基于PhantomJS抓取页面 Casperjs是基于Phantomjs的,而Phantom JS是一个服务器端的 JavaScript API 的 WebKit. CasperJS是 ...
python获取app信息的库_基于python3抓取pinpoint应用信息入库
这篇文章主要介绍了基于python3抓取pinpoint应用信息入库,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 Pinpoint是用Java编写 ...

基于akshare查取每天五分钟成交额，35分钟成交额，1h成交额，并输出为cvs

基于akshare查取每天五分钟成交额，35分钟成交额，1h成交额，并输出为cvs相关推荐

最新文章

热门文章