Tushare库之获取股票列表接口

柔情只为你懂 2021-11-14 15:08 860阅读 0赞

接口：stock\_basic  
描述：获取基础信息数据，包括股票代码、名称、上市日期、退市日期等

**输入参数**

<table> 
 <thead> 
  <tr> 
   <th>名称</th> 
   <th>类型</th> 
   <th>必选</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>is_hs</td> 
   <td>str</td> 
   <td>N</td> 
   <td>是否沪深港通标的，N否 H沪股通 S深股通</td> 
  </tr> 
  <tr> 
   <td>list_status</td> 
   <td>str</td> 
   <td>N</td> 
   <td>上市状态： L上市 D退市 P暂停上市</td> 
  </tr> 
  <tr> 
   <td>exchange</td> 
   <td>str</td> 
   <td>N</td> 
   <td>交易所 SSE上交所 SZSE深交所 HKEX港交所(未上线)</td> 
  </tr> 
 </tbody> 
</table>

**输出参数**

<table> 
 <thead> 
  <tr> 
   <th>名称</th> 
   <th>类型</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>ts_code</td> 
   <td>str</td> 
   <td>TS代码</td> 
  </tr> 
  <tr> 
   <td>symbol</td> 
   <td>str</td> 
   <td>股票代码</td> 
  </tr> 
  <tr> 
   <td>name</td> 
   <td>str</td> 
   <td>股票名称</td> 
  </tr> 
  <tr> 
   <td>area</td> 
   <td>str</td> 
   <td>所在地域</td> 
  </tr> 
  <tr> 
   <td>industry</td> 
   <td>str</td> 
   <td>所属行业</td> 
  </tr> 
  <tr> 
   <td>fullname</td> 
   <td>str</td> 
   <td>股票全称</td> 
  </tr> 
  <tr> 
   <td>enname</td> 
   <td>str</td> 
   <td>英文全称</td> 
  </tr> 
  <tr> 
   <td>market</td> 
   <td>str</td> 
   <td>市场类型 （主板/中小板/创业板）</td> 
  </tr> 
  <tr> 
   <td>exchange</td> 
   <td>str</td> 
   <td>交易所代码</td> 
  </tr> 
  <tr> 
   <td>curr_type</td> 
   <td>str</td> 
   <td>交易货币</td> 
  </tr> 
  <tr> 
   <td>list_status</td> 
   <td>str</td> 
   <td>上市状态： L上市 D退市 P暂停上市</td> 
  </tr> 
  <tr> 
   <td>list_date</td> 
   <td>str</td> 
   <td>上市日期</td> 
  </tr> 
  <tr> 
   <td>delist_date</td> 
   <td>str</td> 
   <td>退市日期</td> 
  </tr> 
  <tr> 
   <td>is_hs</td> 
   <td>str</td> 
   <td>是否沪深港通标的，N否 H沪股通 S深股通</td> 
  </tr> 
 </tbody> 
</table>

说明：旧版上的PE/PB/股本等字段，请在行情接口[“每日指标”][Link 1]中获取。

**接口示例**

pro = ts.pro_api()
    
    #查询当前所有正常上市交易的股票列表
    
    data = pro.stock_basic(exchange='', list_status='L', fields='ts_code,symbol,name,area,industry,list_date')

或者：

#查询当前所有正常上市交易的股票列表
    
    data = pro.query('stock_basic', exchange='', list_status='L', fields='ts_code,symbol,name,area,industry,list_date')

**数据样例**

ts_code     symbol     name     area industry    list_date
    0     000001.SZ  000001  平安银行   深圳       银行  19910403
    1     000002.SZ  000002   万科A   深圳     全国地产  19910129
    2     000004.SZ  000004  国农科技   深圳     生物制药  19910114
    3     000005.SZ  000005  世纪星源   深圳     房产服务  19901210
    4     000006.SZ  000006  深振业A   深圳     区域地产  19920427
    5     000007.SZ  000007   全新好   深圳     酒店餐饮  19920413
    6     000008.SZ  000008  神州高铁   北京     运输设备  19920507
    7     000009.SZ  000009  中国宝安   深圳      综合类  19910625
    8     000010.SZ  000010  美丽生态   深圳     建筑施工  19951027
    9     000011.SZ  000011  深物业A   深圳     区域地产  19920330
    10    000012.SZ  000012   南玻A   深圳       玻璃  19920228
    11    000014.SZ  000014  沙河股份   深圳     全国地产  19920602
    12    000016.SZ  000016  深康佳A   深圳     家用电器  19920327
    13    000017.SZ  000017  深中华A   深圳     文教休闲  19920331
    14    000018.SZ  000018  神州长城   深圳     装修装饰  19920616
    15    000019.SZ  000019  深深宝A   深圳      软饮料  19921012
    16    000020.SZ  000020  深华发A   深圳      元器件  19920428
    17    000021.SZ  000021   深科技   深圳     电脑设备  19940202
    18    000022.SZ  000022  深赤湾A   深圳       港口  19930505
    19    000023.SZ  000023  深天地A   深圳     其他建材  19930429
    20    000025.SZ  000025   特力A   深圳     汽车服务  19930621

根据以上接口可以将数据获取下来放到本地数据库

代码:

# -*- coding: utf-8 -*-
    """
    Created on 2019年3月11日 23点06分
    @author: fanbinglin
    """
    #%%导入模块
    from datetime import  datetime,timedelta,time#时间处理函数
    import pymysql #mysql操作库
    import pandas as pd
    import numpy as np
    import tushare as ts
    #%%全局对象
    
    #生产环境mysql配置
    mysqlSetting_server={
        'host':"ip",
        'port':3306,
        'user':"root", 
        'passwd':"********", 
        'db':"Finance", 
        'charset':'utf8'
    }
    #本地
    mysqlSetting_local={
        'host':"localhost",
        'port':3306,
        'user':"root", 
        'passwd':"*********", 
        'db':"Finance", 
        'charset':'utf8'
    }
    
    #执行sql语句
    def exeSql(mysqlSetting,sql):
        # 打开数据库连接
        db = pymysql.connect(host=mysqlSetting['host'], port=mysqlSetting['port'],user=mysqlSetting['user'], \
            passwd=mysqlSetting['passwd'], db=mysqlSetting['db'], charset=mysqlSetting['charset'] )
        # 使用cursor()方法获取操作游标 
        cursor = db.cursor()
        cursor.execute(sql)
        ret = cursor.fetchall()
        db.commit()
            
        # 关闭数据库连接
        db.close()
        return ret 
    #DataFrame对象落地数据库
    def df2sql(mysqlSetting,df,tableName):
        # 打开数据库连接
        db = pymysql.connect(host=mysqlSetting['host'], port=mysqlSetting['port'],user=mysqlSetting['user'], \
            passwd=mysqlSetting['passwd'], db=mysqlSetting['db'], charset=mysqlSetting['charset'] )
        
        # 使用cursor()方法获取操作游标 
        cursor = db.cursor()     
        #添加操作的sql语句
        sqlInsert="REPLACE INTO "+tableName+" ("
        for _,column in enumerate(df.columns):
            if _<len(df.columns)-1:
                sqlInsert =sqlInsert+column+','
            else:
                sqlInsert =sqlInsert+column+') VALUES '
        for index,row in df.iterrows():
            sqlInsertNew=sqlInsert+'('
            for i,column in enumerate(df.columns):    
                if i<len(df.columns)-1:
                    if pd.isnull(row[column]) or row[column] == 0:
                        sqlInsertNew=sqlInsertNew+'NULL'+','
                    else:
                        sqlInsertNew=sqlInsertNew+'\''+str(row[column])+'\''+','
                        #sqlInsertNew=sqlInsertNew+'\''+str(row[column])+'\''+','
                else:
                    if pd.isnull(row[column]) or row[column] == 0:
                        sqlInsertNew=sqlInsertNew+'NULL'         
                    else:
                        sqlInsertNew=sqlInsertNew+'\''+str(row[column])+'\''  
                        #sqlInsertNew=sqlInsertNew+'\''+str(row[column])+'\''
            sqlInsertNew=sqlInsertNew+');'
            print(sqlInsertNew)
            cursor.execute(sqlInsertNew)
        db.commit()
            
        # 关闭数据库连接
        db.close()
    if __name__ == '__main__':
        ts.set_token('357f92fd3836f2d018d20b9b840897abb3e5c9a62e17895b413e05fe')
        pro = ts.pro_api()
        data = pro.query('stock_basic',exchange='',list_status='L',fields='ts_code,symbol,name,area,industry,fullname,market,exchange,curr_type,list_status,list_date,is_hs')
        df2sql(mysqlSetting_local,data,"issueInfoTable")

这里的token是我的账号生成的，如果你也想注册，麻烦用 [推荐][Link 2] [https://tushare.pro/register?reg=241422][Link 2] 链接。

这里需要提前在本地装好Mysql数据库并根据代码建立好数据库和数据表，如果不会装数据库请参看之前的博客文章。

执行以上代码在数据库可以看到结果

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjA4Mzk4_size_16_color_FFFFFF_t_70][]

喜欢折腾代码的加群（群号:**822286811**）一起交流学习【python、VBA、Shell、Linux、dos、爬虫、拆机、装系统技术交流群】，点击链接加入群聊【计算机技术交流】：[https://jq.qq.com/?\_wv=1027&k=5V7RB2c][https_jq.qq.com_wv_1027_k_5V7RB2c]

[Link 1]: https://tushare.pro/document/2?doc_id=32
[Link 2]: https://tushare.pro/register?reg=241422
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjA4Mzk4_size_16_color_FFFFFF_t_70]: /images/20211114/87d847006c0a412e910e71fe74f76c1e.png
[https_jq.qq.com_wv_1027_k_5V7RB2c]: https://jq.qq.com/?_wv=1027&k=5V7RB2c