求助如何批量下载TuShare的分笔股票数据

是 否 +2 论坛币

k人 参与回答

经管之家送您一份

应届毕业生专属福利!

求职就业群

赵安豆老师微信：zhaoandou666

经管之家联合CDA

送您一个全额奖学金名额~ !

立即领取

感谢您参与论坛问题回答

经管之家送您两个论坛币！

+2 论坛币

http://tushare.org/trading.html#id5这个网站链接

import tushare as ts

df =ts.get_tick_data('600848',date='2014-01-09')

#直接保存

df.to_excel('c:/day/600848.xlsx')

如何编写程序实现多线程下载 下列功能了

1、  多支股票，多日批量下载，保存时文件名=股票代码+日期

或是

2、  单支股票，多日批量下载，保存时文件名=股票代码+日期

扫码加我 拉你入群

请注明：姓名-公司-职位

以便审核进群资格，未注明则拒绝

分享0 收藏1 回帖

关键词：share USHA 批量下载 股票数据 ARE

tushare不错的资源，写个线程池简单版本：

1. import tushare as ts
   
2. from queue import Queue
   
3. import threading
   
4. 
   
5. 
   
6. class ThreadPool(object):
   
7.     def __init__(self,max_num=20):
   
8.         self.queue = Queue(maxsize=max_num)
   
9.         for i in range(max_num):
   
10.             self.queue.put(threading.Thread)
    
11. 
    
12.     def get_thread(self):
    
13.         return self.queue.get()
    
14. 
    
15.     def add_thread(self):
    
16.         self.queue.put(threading.Thread)
    
17. 
    
18. pool = ThreadPool(10)
    
19. 
    
20. 
    
21. def func(code,date,p):
    
22.     df = ts.get_tick_data(code=code,date=date)
    
23.     if not df.empty:
    
24.         df.to_excel(r'd:\work\%s_%s.xlsx'%(code,date))
    
25.     p.add_thread()
    
26. 
    
27. 
    
28. def tasks(codes,dates):
    
29.     for code in codes:
    
30.         for date in dates:
    
31.             thread = pool.get_thread()
    
32.             t = thread(target=func,args=(code,date,pool))
    
33.             t.start()
    
34. 
    
35. tasks(['600848','600165'],['2014-01-09','2014-01-08'])

复制代码

gjinwei 发表于 2017-12-31 14:09
tushare不错的资源，写个线程池简单版本：

谢谢！

gjinwei 发表于 2017-12-31 14:09
tushare不错的资源，写个线程池简单版本：

日期能不能 写成 如 start='2015-01-05',end='2015-02-09'

可以函数制作日期，也可从文件中加载出来。函数制作日期如下：

1. import pandas as pd
   
2. from datetime import datetime
   
3. def prepare_date(start,end,freq='D'):
   
4.     date_range=pd.date_range(start=start,end=end,freq=freq)
   
5.     return [datetime.strftime(date,'%Y-%m-%d') for date in date_range]
   
6. dates=prepare_date(start='2015-01-05',end='2015-02-05')
   
7. tasks(['600848','600165'],dates)

复制代码