efinance库中使用装饰器@multitasking.task不成功问题

是 否 +2 论坛币

k人 参与回答

经管之家送您一份

应届毕业生专属福利!

求职就业群

赵安豆老师微信：zhaoandou666

经管之家联合CDA

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

立即领取

感谢您参与论坛问题回答

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

+2 论坛币

下面的代码通过efinance库获取股票盘口信息，然后合并为数据框total_final ，代码可以运行，但是速度比较慢。
计划增加@multitasking.task来加速，不过一直出不了结果。请各位大佬指点下。谢谢!

1. print(snap_df_total)

复制代码

语句显示是有数据的，到了

1. total_final = get_snap_data(snap_st_list)

复制代码

则没有结果出来。




详细代码如下：

1. import pandas as pd
   
2. import numpy as np
   
3. import efinance as ef
   
4. import multitasking
   
5. import signal
   
6. signal.signal(signal.SIGINT, multitasking.killall)
   
7. 
   
8. snap_df_total = pd.DataFrame()
   
9. snap_st_list =ef.stock.get_realtime_quotes()['股票代码'].head(5)
   
10. 
    
11. @multitasking.task
    
12. def get_snap_data(snap_st_list):
    
13.     snap_df_total = pd.DataFrame()
    
14.     for single_st in snap_st_list:
    
15.         snap_ser = ef.stock.get_quote_snapshot(single_st)
    
16.         snap_temp = pd.DataFrame(snap_ser).T
    
17.         snap_df_total = pd.concat([snap_df_total,snap_temp],axis = 0)
    
18.         print(snap_df_total)
    
19.     return snap_df_total
    
20. 
    
21. total_final = get_snap_data(snap_st_list)

复制代码

扫码加我 拉你入群

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

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

分享0 收藏0 回帖

关键词：Finance Financ Asking Nance multi

你要知道程序慢，到底是本地数据处理慢，还是下载数据慢。有针对性使用多任务才有意义。一般本地数据处理多任务没啥问题，要是数据下载慢，使用多任务未必能提速，毕竟服务器端可能会对同一个ip的多任务下载做一定的限制哦。