qdatac

Submodules

Classes

Loader

数据库查询接口

MongoLoader

数据库查询接口，mongodb实现

BlockMongoLoader

数据库查询接口，mongodb实现（阻塞版本）

MySync

数据同步

MyBlockSync

数据同步（阻塞版本）

Dest

同步目的

Funcs

同步的数据类型

Functions

get_loader(→ Optional[loader.Loader])

获取数据获取实例

int_to_str_date(→ str)

数据库时间转换为字符串格式

Package Contents

class qdatac.Loader(url: str)

Bases: abc.ABC

Inheritance diagram of qdatac.Loader

数据库查询接口

static to_dataframe(to_frame, data)
static datetime_to_int(date: str | datetime.datetime) → int

datetime转换为数据格式的时间

static json_def_handler(obj)
async load_bond_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载可转债信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_bond_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载可转债k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_fund_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载etf基金信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_fund_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载etf基金k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_fund_net(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载etf基金净值信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_index_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载指数信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_index_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载指数指标信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_index(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票指标信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_industry(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载行业信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_industry_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载行业k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_industry_detail(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载行业明细信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_concept(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票概念信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_concept_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_concept_detail(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票明细信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_yjbb(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票业绩报表信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_margin(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票融资融券信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async count(*, tab: str) → int

加载数据库条数

参数:

tab (str) – 库表名称。

返回:

条数

返回类型:

int

async load_info(*, tab: str, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载基本信息

参数:

  • tab (str) – 库表名称。

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_daily(*, tab: str, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载基本k线信息

参数:

  • tab (str) – 库表名称。

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

class qdatac.MongoLoader(url: str)

Bases: qdatac.loader.Loader

Inheritance diagram of qdatac.MongoLoader

数据库查询接口，mongodb实现

loader
async load_bond_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载可转债信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_bond_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载可转债k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_fund_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载etf基金信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_fund_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载etf基金k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_fund_net(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载etf基金净值信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_index_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载指数信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_index_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载指数指标信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_index(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票指标信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_industry(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载行业信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_industry_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载行业k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_industry_detail(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载行业明细信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_concept(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票概念信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_concept_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票k线信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_concept_detail(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票明细信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_yjbb(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票业绩报表信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_stock_margin(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载股票融资融券信息

参数:

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async count(*, tab: str) → int

加载数据库条数

参数:

tab (str) – 库表名称。

返回:

条数

返回类型:

int

async load_info(*, typ: str, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载基本信息

参数:

  • tab (str) – 库表名称。

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

async load_daily(*, typ: str, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

加载基本k线信息

参数:

  • tab (str) – 库表名称。

  • filter (Optional[Dict], optional) – 过滤条件，同mongodb格式，默认 {}。

  • sort (Optional[Dict], optional) – 排序条件， 同mongodb格式，默认 {}。

  • limit (Optional[int], optional) – 限制条数， 默认 None，不限制

  • to_frame (bool, optional) – 是否转换为DataFrame格式，默认 是

返回类型:

Union[List[Dict], pd.DataFrame]

class qdatac.BlockMongoLoader(url: str)

Bases: qdatac.loader.BlockLoader

Inheritance diagram of qdatac.BlockMongoLoader

数据库查询接口，mongodb实现（阻塞版本）

loader
static to_dataframe(to_frame, data)
load_bond_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_bond_info()

load_bond_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_bond_daily()

load_fund_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_fund_info()

load_fund_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_fund_daily()

load_fund_net(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_fund_net()

load_index_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_index_info()

load_index_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_index_daily()

load_stock_info(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_info()

load_stock_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_daily()

load_stock_index(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_index()

load_stock_industry(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_industry()

load_stock_industry_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_industry_daily()

load_stock_industry_detail(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_industry_detail()

load_stock_concept(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_concept()

load_stock_concept_daily(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_concept_daily()

load_stock_concept_detail(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_concept_detail()

load_stock_yjbb(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_yjbb()

load_stock_margin(*, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_stock_margin()

count(*, tab: str) → int

参考: qdatac.loader.Loader.count()

load_info(*, typ: str, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_info()

load_daily(*, typ: str, filter: Dict | None = {}, sort: Dict | None = {}, limit: int | None = None, to_frame=True) → List[Dict] | pandas.DataFrame

参考: qdatac.loader.Loader.load_daily()

class qdatac.MySync(dest: Dest, funcs: List[int] | None = None)

数据同步

inner
async sync(skip_basic=False, task_count=4, split_count=5)

同步函数

参数:

  • skip_basic (bool, optional) – 是否忽略基础数据，默认否。

  • task_count (int, optional) – 任务数量，默认4，如果不清楚，不要改变。过多并发容易被封。

  • split_count (int, optional) – 同一个任务切分分组数，默认5。

shutdown()

停止同步

class qdatac.MyBlockSync(dest: Dest, funcs: List[int] | None = None)

数据同步（阻塞版本）

inner
sync(skip_basic=False, task_count=4, split_count=5)

参考：qdatac.sync.MySync.sync()

shutdown()

参考：qdatac.sync.MySync.shutdown()

class qdatac.Dest(*, file: str | None = None, mongo: str | None = None, mysql: str | None = None)

同步目的

file
mongo
mysql
to_list() → List[Tuple] | None

转换为list

返回:

list

返回类型:

Optional[List[Tuple]]

class qdatac.Funcs

同步的数据类型

TradeDate = 1
IndexInfo = 2
IndexDaily = 3
StockInfo = 4
StockBar = 5
StockIndex = 6
StockIndustry = 7
StockIndustryDetail = 8
StockIndustryBar = (9,)
StockConcept = (10,)
StockConceptDetail = 11
StockConceptBar = (12,)
StockYJBB = 13
StockMargin = 14
FundInfo = 15
FundNet = 16
FundBar = 17
BondInfo = 18
BondBar = 19
qdatac.get_loader(typ: str, url: str, block: bool = False) → loader.Loader | None

获取数据获取实例

参数:

  • typ (str) – 类型，目前只支持mongodb

  • url (str) – 链接字符串

  • block (bool, optional) – 是否使用阻塞版本，默认否。

返回类型:

Optional[Loader]

qdatac.int_to_str_date(t: int) → str

数据库时间转换为字符串格式

参数:

t (int) – 数据库时间

返回:

字符串格式时间

返回类型:

str