FQuant Document

Appearance

DataSource API 参考 ​

DataSource 模块 ​

facade.py ​

DataSource 类 ​

数据源统一入口类。

python
from FQData.DataSource import DataSource, get_datasource

ds = DataSource()
ds = get_datasource()  # 获取单例实例
方法说明
get_stock_day(code, start, end, adjust)获取股票日线数据
get_stock_min(code, freq, start, end)获取股票分钟数据
get_index_day(code, start, end)获取指数日线数据
get_index_min(code, freq, start, end)获取指数分钟数据
get_future_day(code, start, end)获取期货日线数据
get_future_min(code, freq, start, end)获取期货分钟数据
get_realtime(code)获取实时行情
set_mode(mode)设置数据源模式

get_datasource() ​

获取 DataSource 单例实例。

python
def get_datasource() -> DataSource

返回: DataSource 实例

AsyncDataSource 类 ​

异步数据源类。

python
from FQData.DataSource import AsyncDataSource, get_async_datasource

async_ds = get_async_datasource()

base.py ​

DataSourceAdapter ​

数据源适配器基类。

python
from FQData.DataSource import DataSourceAdapter

class MyAdapter(DataSourceAdapter):
    def connect(self):
        pass

    def disconnect(self):
        pass

    def is_connected(self) -> bool:
        pass
方法说明
connect()建立连接
disconnect()断开连接
is_connected()检查连接状态

异常类 ​

异常说明
DataSourceError数据源异常基类
DataSourceConnectionError连接异常
DataNotFoundError数据未找到异常
DataSourceAPIErrorAPI 调用异常

枚举 ​

python
from FQData.DataSource import MarketType, FrequenceType

# 市场类型
MarketType.SH   # 上海
MarketType.SZ   # 深圳
MarketType.BJ   # 北京
MarketType.HK   # 香港
MarketType.US   # 美国

# 频率类型
FrequenceType.DAY   # 日线
FrequenceType.WEEK  # 周线
FrequenceType.MONTH # 月线
FrequenceType.MIN_1 # 1分钟
FrequenceType.MIN_5 # 5分钟
FrequenceType.MIN_15 # 15分钟
FrequenceType.MIN_30 # 30分钟
FrequenceType.MIN_60 # 60分钟

registry.py ​

DataSourceRegistry ​

数据源注册表（单例）。

python
from FQData.DataSource import DataSourceRegistry, register_source

registry = DataSourceRegistry()
register_source('tdx', TdxAdapter)
方法说明
register(name, adapter_class)注册数据源
get(name)获取数据源实例
list_sources()列出所有注册的数据源

health_check.py ​

DataSourceHealthCheck ​

数据源健康检查器。

python
from FQData.DataSource import DataSourceHealthCheck

checker = DataSourceHealthCheck()
status = checker.check()
方法说明
check()检查所有数据源
check_adapter(name)检查指定适配器

HealthStatus ​

健康状态类。

python
from FQData.DataSource import HealthStatus

status = HealthStatus(
    status='healthy',
    message='OK',
    details={'latency': 10}
)
属性说明
status状态 (healthy/unhealthy/unknown)
message状态消息
details详细信息字典
is_healthy是否健康

adapters/tdx/ ​

TdxStockAdapter ​

通达信股票适配器，提供股票列表、日线、分钟线、基本面、板块等数据获取功能。

python
from FQData.DataSource.adapters.tdx import TdxStockAdapter

adapter = TdxStockAdapter()
方法说明参数
get_stock_list(type_)获取股票列表type_: 证券类型 (stock/index/etf/bond/fund/delist/all)
get_stock_day(code, start, end, frequence)获取股票日线/周线/月线frequence: day/week/month/quarter/year
get_stock_min(code, start, end, frequence)获取股票分钟K线frequence: 1min/5min/15min/30min/60min
get_stock_info(code)获取股票财务信息code: 6位股票代码
get_stock_latest(code, frequence)获取最新一根K线frequence: 支持日线和分钟线
get_stock_xdxr(code)获取除权除息信息code: 6位股票代码
get_stock_block()获取股票板块数据无
get_stock_delist()获取退市股票列表无

支持的证券类型:

类型说明
stock/gp股票
index/zs指数
etf/ETFETF基金
bond债券
bond2可转债
fund基金
reverse/repo逆回购
stockb/bB股
bj北交所
delist/退市退市股票
industry_cn行业
all所有证券

使用示例:

python
# 获取股票列表
df = adapter.get_stock_list('stock')

# 获取日线数据
df = adapter.get_stock_day('600000', '2024-01-01', '2024-12-31', 'day')

# 获取分钟线数据
df = adapter.get_stock_min('600000', '2024-01-01', '2024-01-10', '5min')

# 获取退市股票列表
df = adapter.get_stock_delist()

TdxIndexAdapter ​

通达信指数适配器。

python
from FQData.DataSource.adapters.tdx import TdxIndexAdapter

adapter = TdxIndexAdapter()
data = adapter.get_index_bars(code='000001', category=9, start=0, count=100)

TdxFutureAdapter ​

通达信期货适配器。

python
from FQData.DataSource.adapters.tdx import TdxFutureAdapter

adapter = TdxFutureAdapter()
data = adapter.get_future_daily(code='IF2401', start='2024-01-01', end='2024-12-31')

TdxBondAdapter ​

通达信债券适配器。

TdxHKStockAdapter ​

通达信港股适配器。

TdxOptionAdapter ​

通达信期权适配器。

TdxRealtimeAdapter ​

通达信实时行情适配器。

TdxTransactionAdapter ​

通达信成交明细适配器。

相关文档 ​