akshare 0.1.9

100% pure Rust implementation of akshare — unified access to Chinese and global financial market data APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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

use super::super::{
    CANDLES_CACHE_TTL_SECS, FundFlowEntry, MARKET_DATA_CACHE_PREFIX, MainFundFlow,
    MarketDataClient, SectorFundFlowRank,
};

impl MarketDataClient {
    // -----------------------------------------------------------------------
    // Fund Flow (资金流向)
    // -----------------------------------------------------------------------

    pub async fn fetch_fund_flow_individual(
        &self,
        symbol: &str,
    ) -> anyhow::Result<Vec<FundFlowEntry>> {
        self.cached_fetch(
            &format!(
                "{MARKET_DATA_CACHE_PREFIX}:fund-flow-individual:{}",
                symbol.trim()
            ),
            CANDLES_CACHE_TTL_SECS,
            || super::super::akshare_rust::a_share::fetch_fund_flow_individual(self, symbol),
        )
        .await
    }

    pub async fn fetch_fund_flow_concept(
        &self,
        symbol: &str,
    ) -> anyhow::Result<Vec<SectorFundFlowRank>> {
        self.cached_fetch(
            &format!(
                "{MARKET_DATA_CACHE_PREFIX}:fund-flow-concept:{}",
                symbol.trim()
            ),
            CANDLES_CACHE_TTL_SECS,
            || super::super::akshare_rust::a_share::fetch_fund_flow_concept(self, symbol),
        )
        .await
    }

    pub async fn fetch_fund_flow_industry(
        &self,
        symbol: &str,
    ) -> anyhow::Result<Vec<SectorFundFlowRank>> {
        self.cached_fetch(
            &format!(
                "{MARKET_DATA_CACHE_PREFIX}:fund-flow-industry:{}",
                symbol.trim()
            ),
            CANDLES_CACHE_TTL_SECS,
            || super::super::akshare_rust::a_share::fetch_fund_flow_industry(self, symbol),
        )
        .await
    }

    pub async fn fetch_main_fund_flow(&self, symbol: &str) -> anyhow::Result<Vec<MainFundFlow>> {
        let normalized = self
            .normalize_a_share_symbol(symbol)
            .ok_or_else(|| anyhow::anyhow!("invalid A-share symbol for main fund flow"))?;
        self.cached_fetch(
            &format!("{MARKET_DATA_CACHE_PREFIX}:main-fund-flow:{}", normalized),
            CANDLES_CACHE_TTL_SECS,
            || super::super::akshare_rust::a_share::fetch_main_fund_flow(self, symbol),
        )
        .await
    }
}