qdatac.sync

Classes

`Dest`	同步目的
`Funcs`	同步的数据类型
`MySync`	数据同步
`MyBlockSync`	数据同步（阻塞版本）

Module Contents

class qdatac.sync.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.sync.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

class qdatac.sync.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.sync.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()