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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

//! Marketaux news API (global/HK stocks).

use crate::client::AkShareClient;
use crate::error::{Error, Result};
use crate::types::NewsItem;
use crate::types::value_ext::ValueExt;

impl AkShareClient {
    /// Fetch stock news from Marketaux.
    ///
    /// `symbol` is the stock ticker (e.g. "AAPL", "0700.HK").
    /// `api_key` is the Marketaux API key (free tier: 100 req/day).
    /// `limit` is the max number of articles to return (API max: 3 on free tier).
    pub async fn marketaux_news(
        &self,
        symbol: &str,
        api_key: &str,
        limit: usize,
    ) -> Result<Vec<NewsItem>> {
        if symbol.is_empty() {
            return Err(Error::invalid_input("symbol must not be empty"));
        }
        if api_key.is_empty() {
            return Err(Error::invalid_input("api_key must not be empty"));
        }

        let limit_str = limit.min(3).to_string();
        let resp: serde_json::Value = self
            .get("https://api.marketaux.com/v1/news/all")
            .query(&[
                ("entities", symbol),
                ("api_token", api_key),
                ("limit", &limit_str),
            ])
            .send()
            .await?
            .json()
            .await?;

        let arr = resp
            .get("data")
            .and_then(|v| v.as_array())
            .ok_or_else(|| Error::decode("marketaux: missing 'data' array"))?;

        let items: Vec<NewsItem> = arr
            .iter()
            .filter_map(|item| {
                let title = item.str_field(&["title"])?;
                if title.is_empty() {
                    return None;
                }
                let description = item.str_or(&["description"], "");
                let url = item.str_field(&["url"]).map(str::to_string);
                let source = item.str_or(&["source"], "Marketaux");
                let published_at = item
                    .str_field(&["published_at"])
                    .map(|s| s[..10.min(s.len())].to_string())
                    .unwrap_or_default();

                Some(NewsItem {
                    published_at,
                    title: title.to_string(),
                    summary: description,
                    source,
                    url,
                })
            })
            .collect();

        Ok(items)
    }
}

#[cfg(test)]
mod tests {
    #[test]
    fn test_published_at_truncation() {
        // Marketaux returns ISO 8601 like "2026-06-15T12:00:00+00:00"
        let raw = "2026-06-15T12:00:00+00:00";
        assert_eq!(&raw[..10.min(raw.len())], "2026-06-15");
    }
}