Tushare 数据接入教程

将 easy_tushare 模块放置于节点所在 Home 目录的 modules 目录下。节点所在 Home 目录可通过 getHomeDir() 函数获取。

假设 Home 目录为 /DolphinDB/server，则将 easy_tushare 文件夹放置于 /DolphinDB/server/modules/ 路径下。

同步方式包括：

• 使用 xftp 等传输软件将模块传输至服务器上指定的路径。

• 使用 scp 命令：scp -r easy_tushare @<服务器ip>:/DolphinDB/server/modules/

• 使用 VS Code 的 DolphinDB 插件，右键选择同步模块。

• 使用 DolphinDB 的 GUI 客户端同步模块。

easy_tushare 模块依赖以下 DolphinDB 插件：

• httpClient：用于发送 HTTP 请求调用 Tushare API，可通过 HttpClient 教程安装。

• py（可选）：如果需要导入前复权、后复权等数据，可通过 Py（3.9 及以上版本）教程安装。

easy_tushare 模块使用以下三个分布式数据库：

表3-1 数据库信息

执行以下命令创建数据库：

use easy_tushare::ts_init
create_db()

get_api_data

语法

get_api_data(token, apiName, params=NULL, columns=[], ddbCols=[])

功能

获取 Tushare 某个接口的数据。

参数

• token：Tushare API 的认证令牌（Token），字符串类型。

• apiName：Tushare 数据接口名称，如 "stock_basic"、"daily" 等。

• params：接口参数，字典类型，如 {"trade_date":"20250101"}。

• columns：指定返回的列名，数组类型。

• ddbCols：指定 DolphinDB 表中的列名映射，数组类型（可选）。

返回值

返回一个 DolphinDB 内存表，包含请求的数据。

示例

use easy_tushare::ts_init
token = "your_tushare_token"
data = get_api_data(token, "stock_basic", {"list_status":"L"}, ["ts_code","name","industry","list_date"])

每个资产类别均提供 *_init_tables() 函数，用于创建该类别下的所有数据表。

通用语法

<asset>_init_tables(table_names=[])

• 当 table_names 为空时，创建该类别下的所有表。

• 当 table_names 指定表名列表时，仅创建指定的表。

示例

use easy_tushare::stock_init
// 创建所有股票数据表
stock_init_tables()

// 仅创建股票基础信息表和日线行情表
stock_init_tables(["stock_basic", "stock_daily"])

每个资产类别均提供 *_history_data_load() 函数，用于批量导入历史数据，任务提交为后台任务执行。

通用语法

<asset>_history_data_load(token, start_date, end_date, table_names=[])

参数

• token：Tushare API 令牌。

• start_date：开始日期，DATE 类型，如 2020.01.01。

• end_date：结束日期，DATE 类型。

• table_names：要导入的表名列表（可选）。为空时导入该类别下的所有数据表。

示例

use easy_tushare::stock_init
// 批量导入2024年所有股票日线数据
stock_history_data_load(token, 2024.01.01, 2024.12.31)

// 仅导入股票基础信息和日线行情
stock_history_data_load(token, 2024.01.01, 2024.12.31, ["stock_basic", "stock_daily"])

每个资产类别均提供 scheduleJob_*_data_daily 函数，用于每日增量导入当天数据。

通用语法

scheduleJob_bond_data_daily(token, table_names=[])

示例

use easy_tushare::stock_schedulejob
// 提交当日所有股票数据的定时任务
scheduleJob_stock_data_daily(token)

每日增量导入执行时间

表 4-1 定时任务执行时间表

以下示例展示从环境初始化到数据导入的完整流程。

// 第一步：加载模块
use easy_tushare::ts_init
use easy_tushare::stock_init
use easy_tushare::stock_schedulejob

// 第二步：初始化插件
// httpClient插件
installPlugin("httpClient");
loadPlugin("httpClient");
// py插件
// 如有需要参考安装：https://docs.dolphindb.cn/zh/plugins/py/py_3_9.html

// 第三步：创建数据库
create_db()

// 第四步：创建股票数据表
stock_init_tables()

// 第五步：批量导入2024年历史数据
token = "your_tushare_token"
stock_history_data_load(token, 2024.01.01, 2024.12.31)

// 第六步：注册每日增量定时任务
scheduleJob_stock_data_daily(token)

以下代码展示指定数据表名进行数据导入。

use easy_tushare::stock_init

// 仅导入指定表
stock_init_tables(["stock_basic", "stock_daily"])
stock_history_data_load(token, 2024.01.01, 2024.12.31, ["stock_basic", "stock_daily"])

// 仅导入分钟K线数据
stock_init_tables(["stock_1min_k", "stock_5min_k"])
stock_history_data_load(token, 2024.01.01, 2024.12.31, ["stock_1min_k", "stock_5min_k"])

以下代码介绍如何进行多资产数据并行导入。

use easy_tushare::ts_init
use easy_tushare::stock_init
use easy_tushare::futures_init
use easy_tushare::bond_init
use easy_tushare::index_init

token = "your_tushare_token"

// 初始化数据库
create_db()

// 初始化各资产类别表
stock_init_tables()
futures_init_tables()
bond_init_tables()
index_init_tables()

// 使用 submitJob 后台并行导入历史数据
stock_history_data_load(token, 2024.01.01, 2024.12.31)
futures_history_data_load(token, 2024.01.01, 2024.12.31)
bond_history_data_load(token, 2024.01.01, 2024.12.31)
index_history_data_load(token, 2024.01.01, 2024.12.31)

股票数据表按业务主题分为以下 8 类：

基础数据

表 6-1 股票基础数据表信息

行情数据

表 6-2 股票行情数据表信息

财务数据

表 6-3 股票财务数据表信息

参考数据

表 6-4 股票参考数据表信息

特色数据

表 6-5 股票特色数据表信息

两融及转融通相关数据

表 6-6 股票两融及转融通数据表信息

资金流向数据

表 6-7 股票资金流向数据表信息

打板专题数据

表 6-8 股票打板专题数据表信息

期货数据包含以下表

表 6-9 期货数据表信息

债券数据包含以下表

表 6-10 债券数据表信息

指数数据包含以下表

表 6-11 指数数据表信息

期权数据包含以下表

表 6-12 期权数据表信息

外汇数据包含以下表

表 6-13 外汇数据表信息

黄金现货数据包含以下表

表 6-14 黄金现货数据表信息

ETF 数据包含以下表

表 6-15 ETF数据表信息

公募基金数据包含以下表

表 6-16 公募基金数据表信息

大模型语料数据包含以下表

表 6-17 大模型语料数据表信息