qmt_parser/
lib.rs

1#![warn(missing_docs)]
2//! `qmt-parser` 提供面向 MiniQMT / QMT 本地数据目录的解析能力。
3//!
4//! 这个 crate 主要覆盖三类能力：
5//!
6//! - 历史行情 `.dat` 文件解析：tick、1 分钟线、日线
7//! - 可选的 Polars `DataFrame` 输出
8//! - QMT 本地财务与分红数据读取
9//!
10//! 大多数用户可以直接从 crate 根模块调用重导出的顶层函数，例如
11//! [`parse_ticks_to_structs`]、[`parse_min_to_structs`]、
12//! [`parse_daily_to_structs`] 或 [`FinanceReader::read_file`]。
13//!
14//! # Feature Flags
15//!
16//! - `polars`：默认开启，启用 `parse_*_to_dataframe` 系列接口
17//!
18//! # Quick Start
19//!
20//! 解析 tick 文件为结构体：
21//!
22//! ```no_run
23//! use qmt_parser::parse_ticks_to_structs;
24//!
25//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
26//! let ticks = parse_ticks_to_structs("data/000001-20250529-tick.dat")?;
27//! println!("rows = {}", ticks.len());
28//! # Ok(())
29//! # }
30//! ```
31//!
32//! 解析日线并限制日期范围：
33//!
34//! ```no_run
35//! use qmt_parser::parse_daily_to_structs;
36//!
37//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
38//! let rows = parse_daily_to_structs("data/day/000001.dat", "20230101", "20231231")?;
39//! println!("rows = {}", rows.len());
40//! # Ok(())
41//! # }
42//! ```
43//!
44//! 在启用 `polars` feature 时生成 `DataFrame`：
45//!
46//! ```no_run
47//! # #[cfg(feature = "polars")]
48//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
49//! use qmt_parser::parse_min_to_dataframe;
50//!
51//! let df = parse_min_to_dataframe("data/000001-1m.dat")?;
52//! println!("{:?}", df.shape());
53//! # Ok(())
54//! # }
55//! #
56//! # #[cfg(not(feature = "polars"))]
57//! # fn main() {}
58//! ```
59//!
60//! # Modules
61//!
62//! - [`tick`]：Tick 分笔解析
63//! - [`min`]：1 分钟 K 线解析
64//! - [`day`]：日线解析与派生列处理
65//! - [`finance`]：财务 `.DAT` 解析
66//! - [`dividend`]：分红送配 LevelDB 查询
67//! - [`error`]：公共错误类型
68
69/// 日线解析与 DataFrame 导出。
70pub mod day;
71/// 分红送配 LevelDB 查询。
72pub mod dividend;
73/// 公开错误类型定义。
74pub mod error;
75/// QMT 财务 `.DAT` 解析。
76pub mod finance;
77/// 1 分钟 K 线解析与 DataFrame 导出。
78pub mod min;
79/// Tick 分笔解析与 DataFrame 导出。
80pub mod tick;
81
82/// 日线 DataFrame 的输出列名。
83pub use day::daily_dataframe_column_names;
84pub use day::{DailyKlineData, DailyReader};
85#[cfg(feature = "polars")]
86pub use day::{
87    parse_daily_file_to_dataframe, parse_daily_to_dataframe, parse_daily_to_dataframe_in_range,
88};
89pub use day::{
90    parse_daily_file_to_structs, parse_daily_to_structs, parse_daily_to_structs_in_range,
91};
92pub use dividend::{DividendDb, DividendError, DividendRecord};
93pub use error::{DailyParseError, MinParseError, TickParseError};
94pub use finance::{FileType, FinanceData, FinanceError, FinanceReader, FinanceRecord, Shareholder};
95/// 分钟线 DataFrame 的输出列名。
96pub use min::min_dataframe_column_names;
97#[cfg(feature = "polars")]
98pub use min::parse_min_to_dataframe;
99pub use min::{MinKlineData, MinReader, parse_min_to_structs};
100#[cfg(feature = "polars")]
101pub use tick::parse_ticks_to_dataframe;
102pub use tick::{
103    FULL_TICK_API_FIELD_NAMES, TICK_DATAFRAME_COLUMN_NAMES, tick_api_field_names,
104    tick_dataframe_column_names,
105};
106pub use tick::{TickData, TickReader, parse_ticks_to_structs};
qmt_parser/lib.rs

qmt_parser/
lib.rs
