qdatac.mongo

Classes

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

Module Contents

class qdatac.mongo.MongoLoader(url: str)

Bases: qdatac.loader.Loader

数据库查询接口，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.mongo.BlockMongoLoader(url: str)

Bases: qdatac.loader.BlockLoader

数据库查询接口，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()