跳转至

资金流分析

CapitalFlowMinutesMapping

字段映射 市场、板块（行业、概念、地区）分钟级资金流向数据

CapitalFlowMinutes 

CapitalFlowMinutes(
    market: Optional[TypeMarket] = None,
    plate_code: Optional[str] = None,
    security_code: Optional[str] = None,
    size: Optional[int] = 0,
    verbose: Optional[bool] = False,
    logger: Optional[Callable] = None,
    **kwargs: Any
)

查询 市场、板块（行业、概念、地区）分钟级资金流向数据

  1. 查询市场总体资金流量
  2. 查询全部 行业、地区、概念 板块资金流量
  3. 查询指定板块资金流量
  4. 查询不同行业、地区、概念板块下的主力流入流出排名
Notes 
指标定义
　　- 超大单：大于等于50万股或者100万元的成交单;
　　- 大单：大于等于10万股或者20万元且小于50万股和100万元的成交单;
　　- 中单：大于等于2万股或者4万元且小于10万股和20万元的成交单;
　　- 小单：小于2万股和4万元的成交单;
Notes 
from wisecon.stock.capital_flow import *

# 1. 查询市场的资金分钟流向数据
data = CapitalFlowMinutes(market="沪深两市", size=10).load()
data.to_frame(chinese_column=True)

# 2.1 查询板块的资金分钟流向数据(概念)
data = CapitalFlowMinutes(plate_code="BK1044", size=10).load()
data.to_frame(chinese_column=True)

# 2.2 查询板块的资金分钟流向数据(地区)
data = CapitalFlowMinutes(plate_code="BK0158", size=10).load()
data.to_frame(chinese_column=True)

# 2.3 查询板块的资金分钟流向数据(行业)
data = CapitalFlowMinutes(plate_code="BK1044", size=10).load()
data.to_frame(chinese_column=True)

# 3. 查询股票的资金分钟流向数据
data = CapitalFlowMinutes(security_code="300750", size=10).load()
data.to_frame(chinese_column=True)

Parameters:

Name Type Description Default
market Optional[TypeMarket]

市场名称: ["沪深两市", "沪市", "深市", "创业板", "沪B", "深B"]

 None
plate_code Optional[str]

板块代码, 支持地区板块、行业板块、概念板块

 None
security_code Optional[str]

股票代码

 None
size Optional[int]

数据条数

 0
verbose Optional[bool]

是否打印日志

 False
logger Optional[Callable]

自定义日志函数

 None
**kwargs Any

其他参数

 {}
Source code in wisecon\stock\capital_flow\minutes.py 
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
def __init__(
        self,
        market: Optional[TypeMarket] = None,
        plate_code: Optional[str] = None,
        security_code: Optional[str] = None,
        size: Optional[int] = 0,
        verbose: Optional[bool] = False,
        logger: Optional[Callable] = None,
        **kwargs: Any
):
    """
    Notes:
        ```python
        from wisecon.stock.capital_flow import *

        # 1. 查询市场的资金分钟流向数据
        data = CapitalFlowMinutes(market="沪深两市", size=10).load()
        data.to_frame(chinese_column=True)

        # 2.1 查询板块的资金分钟流向数据(概念)
        data = CapitalFlowMinutes(plate_code="BK1044", size=10).load()
        data.to_frame(chinese_column=True)

        # 2.2 查询板块的资金分钟流向数据(地区)
        data = CapitalFlowMinutes(plate_code="BK0158", size=10).load()
        data.to_frame(chinese_column=True)

        # 2.3 查询板块的资金分钟流向数据(行业)
        data = CapitalFlowMinutes(plate_code="BK1044", size=10).load()
        data.to_frame(chinese_column=True)

        # 3. 查询股票的资金分钟流向数据
        data = CapitalFlowMinutes(security_code="300750", size=10).load()
        data.to_frame(chinese_column=True)
        ```

    Args:
        market: 市场名称: `["沪深两市", "沪市", "深市", "创业板", "沪B", "深B"]`
        plate_code: 板块代码, 支持地区板块、行业板块、概念板块
        security_code: 股票代码
        size: 数据条数
        verbose: 是否打印日志
        logger: 自定义日志函数
        **kwargs: 其他参数
    """
    self.market = market
    self.plate_code = plate_code
    self.security_code = security_code
    self.size = size
    self.mapping = CapitalFlowMinutesMapping()
    self.verbose = verbose
    self.logger = logger
    self.kwargs = kwargs
    self.request_set(description="市场、板块（行业、概念、地区）分钟级资金流向数据", )

CapitalFlowCurrentMapping

字段映射 当前股票资金流量统计

CapitalFlowCurrent 

CapitalFlowCurrent(
    market: Optional[TypeMarket] = None,
    plate_code: Optional[Union[str, List[str]]] = None,
    security_code: Optional[Union[str, List[str]]] = None,
    size: Optional[int] = 0,
    verbose: Optional[bool] = False,
    logger: Optional[Callable] = None,
    **kwargs: Any
)

查询 当前股票资金流量统计，最多可以同步查询10条，超过10条请使用 StockFlow 方法。

  1. 查询沪深两市市场当前资金动向数据
  2. 查询某行业、地区、概念板块当前资金动向数据
  3. 查询具体股票的当前资金动向数据
Notes 
from wisecon.stock.capital_flow import *

# 1. 查询股票的资金当前流向数据
data = CapitalFlowCurrent(security_code="300750", size=10).load()
data.to_frame(chinese_column=True)

# 2. 查询板块的资金当前流向数据
data = CapitalFlowCurrent(plate_code="BK0477", size=10).load()
data.to_frame(chinese_column=True)

# 3. 查询市场的资金当前流向数据
data = CapitalFlowCurrent(market="深市A股", size=10).load()
data.to_frame(chinese_column=True)

Parameters:

Name Type Description Default
market Optional[TypeMarket]

市场名称 ["全部股票", "沪深A股", "沪市A股", "科创板", "深市A股", "创业板", "沪市B股", "深市B股"]

 None
plate_code Optional[Union[str, List[str]]]

板块代码, 行业、概念、地区

 None
security_code Optional[Union[str, List[str]]]

股票代码

 None
size Optional[int]

数据条数

 0
verbose Optional[bool]

是否显示日志

 False
logger Optional[Callable]

日志记录器

 None
**kwargs Any

其他参数

 {}
Source code in wisecon\stock\capital_flow\current.py 
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
def __init__(
        self,
        market: Optional[TypeMarket] = None,
        plate_code: Optional[Union[str, List[str]]] = None,
        security_code: Optional[Union[str, List[str]]] = None,
        size: Optional[int] = 0,
        verbose: Optional[bool] = False,
        logger: Optional[Callable] = None,
        **kwargs: Any
):
    """
    Notes:
        ```python
        from wisecon.stock.capital_flow import *

        # 1. 查询股票的资金当前流向数据
        data = CapitalFlowCurrent(security_code="300750", size=10).load()
        data.to_frame(chinese_column=True)

        # 2. 查询板块的资金当前流向数据
        data = CapitalFlowCurrent(plate_code="BK0477", size=10).load()
        data.to_frame(chinese_column=True)

        # 3. 查询市场的资金当前流向数据
        data = CapitalFlowCurrent(market="深市A股", size=10).load()
        data.to_frame(chinese_column=True)
        ```

    Args:
        market: 市场名称 `["全部股票", "沪深A股", "沪市A股", "科创板", "深市A股", "创业板", "沪市B股", "深市B股"]`
        plate_code: 板块代码, 行业、概念、地区
        security_code: 股票代码
        size: 数据条数
        verbose: 是否显示日志
        logger: 日志记录器
        **kwargs: 其他参数
    """
    self.market = market
    self.plate_code = plate_code
    self.security_code = security_code
    self.size = size
    self.mapping = CapitalFlowCurrentMapping()
    self.verbose = verbose
    self.logger = logger
    self.kwargs = kwargs
    self.request_set(description="当前股票资金流量统计", )
    self.validate_max_security_codes(security_code=security_code)

CapitalFlowHistoryMapping

字段映射 资金流向历史数据(大盘沪深两市/板块历史数据)

CapitalFlowHistory 

CapitalFlowHistory(
    market: Optional[TypeMarket] = None,
    plate_code: Optional[str] = None,
    security_code: Optional[str] = None,
    size: Optional[int] = 0,
    verbose: Optional[bool] = False,
    logger: Optional[Callable] = None,
    **kwargs: Any
)

查询 资金流向历史数据(大盘沪深两市/板块历史数据)

  1. 查询沪深两市市场历史资金动向数据
  2. 查询某行业、地区、概念板块历史资金动向数据
  3. 查询具体股票的历史资金动向数据
Notes 
from wisecon.stock.capital_flow import *

# 1. 查询市场的资金历史流向数据
data = CapitalFlowHistory(market="沪深两市", size=10).load()
data.to_frame(chinese_column=True)

# 2.1 查询板块的资金历史流向数据(概念)
data = CapitalFlowHistory(plate_code="BK1044", size=10).load()
data.to_frame(chinese_column=True)

# 2.2 查询板块的资金历史流向数据(地区)
data = CapitalFlowHistory(plate_code="BK0158", size=10).load()
data.to_frame(chinese_column=True)

# 2.3 查询板块的资金历史流向数据(行业)
data = CapitalFlowHistory(plate_code="BK1044", size=10).load()
data.to_frame(chinese_column=True)

# 3. 查询股票的资金历史流向数据
data = CapitalFlowHistory(security_code="300750", size=10).load()
data.to_frame(chinese_column=True)

Parameters:

Name Type Description Default
market Optional[TypeMarket]

市场名称: ["沪深两市", "沪市", "深市", "创业板", "沪B", "深B"]

 None
plate_code Optional[str]

板块代码, 支持地区板块、行业板块、概念板块

 None
security_code Optional[str]

股票代码

 None
size Optional[int]

数据条数

 0
verbose Optional[bool]

是否显示日志

 False
logger Optional[Callable]

日志记录器

 None
**kwargs Any

其他参数

 {}
Source code in wisecon\stock\capital_flow\history.py 
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
def __init__(
        self,
        market: Optional[TypeMarket] = None,
        plate_code: Optional[str] = None,
        security_code: Optional[str] = None,
        size: Optional[int] = 0,
        verbose: Optional[bool] = False,
        logger: Optional[Callable] = None,
        **kwargs: Any
):
    """
    Notes:
        ```python
        from wisecon.stock.capital_flow import *

        # 1. 查询市场的资金历史流向数据
        data = CapitalFlowHistory(market="沪深两市", size=10).load()
        data.to_frame(chinese_column=True)

        # 2.1 查询板块的资金历史流向数据(概念)
        data = CapitalFlowHistory(plate_code="BK1044", size=10).load()
        data.to_frame(chinese_column=True)

        # 2.2 查询板块的资金历史流向数据(地区)
        data = CapitalFlowHistory(plate_code="BK0158", size=10).load()
        data.to_frame(chinese_column=True)

        # 2.3 查询板块的资金历史流向数据(行业)
        data = CapitalFlowHistory(plate_code="BK1044", size=10).load()
        data.to_frame(chinese_column=True)

        # 3. 查询股票的资金历史流向数据
        data = CapitalFlowHistory(security_code="300750", size=10).load()
        data.to_frame(chinese_column=True)
        ```

    Args:
        market: 市场名称: `["沪深两市", "沪市", "深市", "创业板", "沪B", "深B"]`
        plate_code: 板块代码, 支持地区板块、行业板块、概念板块
        security_code: 股票代码
        size: 数据条数
        verbose: 是否显示日志
        logger: 日志记录器
        **kwargs: 其他参数
    """
    self.market = market
    self.plate_code = plate_code
    self.security_code = security_code
    self.size = size
    self.mapping = CapitalFlowHistoryMapping()
    self.verbose = verbose
    self.logger = logger
    self.kwargs = kwargs
    self.request_set(description="资金流向历史数据(大盘沪深两市/板块历史数据)", )

PlateFlowMapping

字段映射 市场、板块（行业、概念、地区）资金流向数据

PlateFlow 

PlateFlow(
    market: Optional[TypeMarket] = None,
    plate_type: Optional[
        Literal["行业", "概念", "地区"]
    ] = None,
    plate_code: Optional[str] = None,
    size: Optional[int] = 50,
    sort_by: Optional[str] = None,
    ascending: Optional[bool] = False,
    days: Optional[Literal[1, 3, 5, 10]] = None,
    verbose: Optional[bool] = False,
    logger: Optional[Callable] = None,
    **kwargs: Any
)

查询 市场、板块（行业、概念、地区）资金流向数据

  1. 查询市场总体资金流量；返回全部股票当前1/3/5/10天的资金动向
  2. 查询全部 行业、地区、概念 板块资金流量；返回全部板块下股票当前1/3/5/10天的资金动向
  3. 查询指定板块资金流量；返回具体板块下股票当前1/3/5/10天的资金动向
  4. 查询不同行业、地区、概念板块下的主力流入流出排名
Notes 
指标定义
　　- 超大单：大于等于50万股或者100万元的成交单;
　　- 大单：大于等于10万股或者20万元且小于50万股和100万元的成交单;
　　- 中单：大于等于2万股或者4万元且小于10万股和20万元的成交单;
　　- 小单：小于2万股和4万元的成交单;
　　- 流入：买入成交额;
　　- 流出：卖出成交额;
　　- 主力流入：超大单加大单买入成交额之和;
　　- 主力流出：超大单加大单卖出成交额之和;
　　- 净额：流入-流出;
　　- 净比：(流入-流出)/总成交额;
　　- 5日排名：5日主力净占比排名（指大盘连续交易的5日);
　　- 5日涨跌：最近5日涨跌幅（指大盘连续交易的5日);
　　- 10日排名：10日主力净占比排名（指大盘连续交易的10日);
　　- 10日涨跌：最近10日涨跌幅（指大盘连续交易的10日);
Notes 
from wisecon.stock.capital_flow import *

# 1. 查询市场总体资金流量
data = PlateFlow(market="沪深A股", days=1).load()
data.to_frame(chinese_column=True)

# 2. 查询全部 `行业、地区、概念` 板块资金流量
data = PlateFlow(plate_type="行业", days=1).load()
data.to_frame(chinese_column=True)

# 3. 查询指定板块资金流量
# 3.1 行业板块
data = PlateFlow(plate_code="BK1027", days=1).load()
data.to_frame(chinese_column=True)

# 3.1 地区板块
data = PlateFlow(plate_code="BK0158", days=1).load()
data.to_frame(chinese_column=True)

# 3.1 概念板块
data = PlateFlow(plate_code="BK1044", days=1).load()
data.to_frame(chinese_column=True)

# 4. 主力排名
data = PlateFlow(market="全部股票", sort_by="f184").load()
data.to_frame(chinese_column=True)

# 4.1 主力流入排名
PlateFlow(plate_type="行业", days=1, sort_by="f62")
PlateFlow(plate_type="行业", days=3, sort_by="f267")
PlateFlow(plate_type="行业", days=5, sort_by="f164")
PlateFlow(plate_type="行业", days=10, sort_by="f174")

# 4.2 主力流出排名
PlateFlow(plate_type="行业", days=1, sort_by="f62", ascending=True)
PlateFlow(plate_type="行业", days=3, sort_by="f267", ascending=True)
PlateFlow(plate_type="行业", days=5, sort_by="f164", ascending=True)
PlateFlow(plate_type="行业", days=10, sort_by="f174", ascending=True)

Parameters:

Name Type Description Default
market Optional[TypeMarket]

市场名称 ["全部股票", "沪深A股", "沪市A股", "科创板", "深市A股", "创业板", "沪市B股", "深市B股"]

 None
plate_type Optional[Literal['行业', '概念', '地区']]

板块类型, ["行业", "概念", "地区"]

 None
plate_code Optional[str]

板块代码, 支持行业、概念、地区等代码

 None
days Optional[Literal[1, 3, 5, 10]]

统计天数 1, 3, 5, 10

 None
size Optional[int]

返回数据量

 50
sort_by Optional[str]

排序字段名称, 可通过 PlateFlowMapping 查询

 None
verbose Optional[bool]

是否打印日志

 False
logger Optional[Callable]

自定义日志函数

 None
**kwargs Any

其他参数

 {}
Source code in wisecon\stock\capital_flow\plate.py 
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
def __init__(
        self,
        market: Optional[TypeMarket] = None,
        plate_type: Optional[Literal["行业", "概念", "地区"]] = None,
        plate_code: Optional[str] = None,
        size: Optional[int] = 50,
        sort_by: Optional[str] = None,
        ascending: Optional[bool] = False,
        days: Optional[Literal[1, 3, 5, 10]] = None,
        verbose: Optional[bool] = False,
        logger: Optional[Callable] = None,
        **kwargs: Any
):
    """
    Notes:
        ```python
        from wisecon.stock.capital_flow import *

        # 1. 查询市场总体资金流量
        data = PlateFlow(market="沪深A股", days=1).load()
        data.to_frame(chinese_column=True)

        # 2. 查询全部 `行业、地区、概念` 板块资金流量
        data = PlateFlow(plate_type="行业", days=1).load()
        data.to_frame(chinese_column=True)

        # 3. 查询指定板块资金流量
        # 3.1 行业板块
        data = PlateFlow(plate_code="BK1027", days=1).load()
        data.to_frame(chinese_column=True)

        # 3.1 地区板块
        data = PlateFlow(plate_code="BK0158", days=1).load()
        data.to_frame(chinese_column=True)

        # 3.1 概念板块
        data = PlateFlow(plate_code="BK1044", days=1).load()
        data.to_frame(chinese_column=True)

        # 4. 主力排名
        data = PlateFlow(market="全部股票", sort_by="f184").load()
        data.to_frame(chinese_column=True)

        # 4.1 主力流入排名
        PlateFlow(plate_type="行业", days=1, sort_by="f62")
        PlateFlow(plate_type="行业", days=3, sort_by="f267")
        PlateFlow(plate_type="行业", days=5, sort_by="f164")
        PlateFlow(plate_type="行业", days=10, sort_by="f174")

        # 4.2 主力流出排名
        PlateFlow(plate_type="行业", days=1, sort_by="f62", ascending=True)
        PlateFlow(plate_type="行业", days=3, sort_by="f267", ascending=True)
        PlateFlow(plate_type="行业", days=5, sort_by="f164", ascending=True)
        PlateFlow(plate_type="行业", days=10, sort_by="f174", ascending=True)
        ```

    Args:
        market: 市场名称 `["全部股票", "沪深A股", "沪市A股", "科创板", "深市A股", "创业板", "沪市B股", "深市B股"]`
        plate_type: 板块类型, `["行业", "概念", "地区"]`
        plate_code: 板块代码, 支持行业、概念、地区等代码
        days: 统计天数 `1, 3, 5, 10`
        size: 返回数据量
        sort_by: 排序字段名称, 可通过 `PlateFlowMapping` 查询
        verbose: 是否打印日志
        logger: 自定义日志函数
        **kwargs: 其他参数
    """
    self.market = market
    self.plate_type = plate_type
    self.plate_code = plate_code
    self.size = size
    self.sort_by = sort_by
    self.ascending = ascending
    self.days = days
    self.mapping = PlateFlowMapping()
    self.verbose = verbose
    self.logger = logger
    self.kwargs = kwargs
    self.request_set(description="市场、板块（行业、概念、地区）资金流向数据", )