如何用AkShare根据股票代码查询股票名称？

Question

如何使用AkShare根据股票代码（如'600519'）准确查询对应的股票名称（如“贵州茅台”）？常见问题包括：直接调用`akshare.stock_info_a_code_name()`等函数时返回结果不完整或抛出KeyError，可能由于接口更新导致数据源失效；或输入代码未补全前缀（如sh/sz），造成匹配失败。此外，部分用户反馈在批量查询时性能较差，如何高效获取多个股票代码对应名称？需探讨稳定接口、参数格式及异常处理机制。

Answer 1

一、基础使用：通过AkShare查询单个股票代码对应的名称

AkShare 是一个开源的金融数据接口库，广泛用于获取A股、港股、美股等市场数据。最直接的方式是调用 akshare.stock_info_a_code_name() 获取所有A股代码与名称的映射表。

import akshare as ak

# 获取A股代码-名称映射
stock_name_df = ak.stock_info_a_code_name()
print(stock_name_df.head())
    

该函数返回一个包含两列的DataFrame：code 和 name，例如：

code	name
600000	浦发银行
600004	白云机场
600006	东风汽车
600007	中国国贸
600008	首创环保
600009	上海机场
600010	包钢股份
600011	华能国际
600015	华夏银行
600016	民生银行

二、常见问题分析与定位

在实际使用中，开发者常遇到以下三类问题：

1. KeyError 或返回空结果：可能由于AkShare底层接口变更导致 stock_info_a_code_name() 数据源失效。
2. 匹配失败：输入股票代码未加市场前缀（如 'sh600519'），而部分接口要求明确区分上交所（sh）和深交所（sz）。
3. 性能瓶颈：批量查询时频繁调用网络接口或重复加载全量数据，造成延迟高、响应慢。

以查询“600519”为例，若直接使用如下方式：

# 错误示例：未处理异常且假设函数稳定
def get_stock_name_bad(code):
    df = ak.stock_info_a_code_name()
    return df[df['code'] == code]['name'].values[0]
    

此方法存在风险：一旦接口更新或网络异常，程序将抛出 KeyError 或 AttributeError。

三、解决方案设计：构建鲁棒性查询机制

为提升稳定性，建议采用“缓存 + 异常重试 + 格式标准化”策略。以下是改进后的核心逻辑流程图：

graph TD
            A[输入股票代码] --> B{是否带sh/sz前缀?}
            B -- 是 --> C[去除前缀保留数字]
            B -- 否 --> D[直接使用]
            C --> E[标准化为6位字符串]
            D --> E
            E --> F[检查本地缓存]
            F -- 存在 --> G[返回名称]
            F -- 不存在 --> H[调用AkShare获取全量映射]
            H --> I{调用成功?}
            I -- 是 --> J[缓存结果并返回名称]
            I -- 否 --> K[切换备用接口或抛出自定义异常]
            K --> L[记录日志并提示用户]

四、高效批量查询实现方案

针对批量查询场景，应避免对每个代码重复调用全量接口。推荐一次性加载映射表，并构建字典索引：

import akshare as ak
import functools
import time

@functools.lru_cache(maxsize=1)
def get_stock_name_mapping():
    """缓存全量A股代码-名称映射"""
    try:
        df = ak.stock_info_a_code_name()
        return dict(zip(df['code'].astype(str), df['name']))
    except Exception as e:
        raise ConnectionError(f"AkShare接口异常: {e}")

def query_stock_names(codes: list) -> dict:
    """
    批量查询股票名称
    :param codes: 股票代码列表，支持带sh/sz或纯数字
    :return: 字典形式 {code: name}
    """
    mapping = get_stock_name_mapping()
    result = {}
    for code in codes:
        # 标准化处理前缀
        clean_code = code.lower().replace('sh', '').replace('sz', '')
        clean_code = clean_code.zfill(6)  # 补齐6位
        result[code] = mapping.get(clean_code, None)
    return result

# 示例调用
codes = ['600519', 'sz000858', 'sh601398', '000001']
names = query_stock_names(codes)
for k, v in names.items():
    print(f"{k} -> {v}")
    

输出示例：

• 600519 -> 贵州茅台
• sz000858 -> 五粮液
• sh601398 -> 工商银行
• 000001 -> 平安银行

五、接口稳定性增强与备选方案

考虑到AkShare依赖第三方网站，存在不可控风险。可引入多重保障机制：

策略	说明	适用场景
本地持久化缓存	定期导出映射为JSON/CSV，离线可用	网络受限环境
多源数据融合	结合Tushare、Baostock等其他接口	关键业务系统
定时任务更新	每日凌晨自动刷新缓存	高频查询服务
熔断与降级	接口失败时返回历史快照	高可用系统

此外，可通过配置中心动态切换数据源，提升系统弹性。