利用Tu Share獲取股票交易信息，c#實現

 1、什麼是Tu Share

Tushare是一個免費、開源的python財經數據接口包。主要實現對股票等金融數據從數據採集、清洗加工 到 數據存儲的過程，用戶能夠免費（部分數據的下載有積分限制）的經過它提供的財經接口獲取股票交易、期貨等財經信息，功能很是強大。該接口和直接到各財經網站爬數據相比，最大的優點就是快，去傳統財經網站爬數據，好多關鍵性的股票信息只能一隻股一隻股爬，而Tu Share的API，一個調用能夠得到一天的所有數據，速度差了好幾個數量級。另一方面各財經網站的接口的API沒有對外文檔化，隨時可能變化，而Tu Share的API有正式的文檔化相對比較穩定。

2、如何註冊

該網站使用積分制來控制數據的訪問權限，若是想要訪問數據，先要到下面這個網址完成註冊，https://tushare.pro/register。註冊完成後，能夠須要到我的主頁中拷貝Token，這個Token會在之後的訪問中用到，步驟以下

一、登陸成功後，點擊右上角->我的主頁

二、 在「用戶中心」中點擊「接口TOKEN」

 

三、 能夠點擊右側複製按鈕複製token

3、Http API說明

Tushare HTTP數據獲取的方式，採用了post的機制，經過提交JSON body參數，就能夠得到您想要的數據。具體參數說明以下：

輸入參數

api_name：接口名稱，好比stock_basic

token ：用戶惟一標識，可經過登陸pro網站獲取

params：接口參數，如daily接口中start_date和end_date

fields：字段列表，用於接口獲取指定的字段，以逗號分隔，如"open,high,low,close"

輸出參數

code： 接口返回碼，2002表示權限問題。

msg：錯誤信息，好比「系統內部錯誤」，「沒有權限」等

data：數據，data裏包含fields和items字段，分別爲字段和數據內容

4、c#(.net core)實現

一、在Visual Studio中安裝下面幾個包：Microsoft.Extensions.Http、Newtonsoft.Json

二、封裝方法，實現對REST web service的調用

public interface IHttpClientUtility
{
     string HttpClientPost(string url, object datajson);
}

public class HttpClientUtility : IHttpClientUtility
    {
        

        public HttpClientUtility()
        {
            
        }
        public  string HttpClientPost(string url, object datajson)
        {
            using (HttpClient httpClient = new HttpClient()) //http對象
            {
                httpClient.DefaultRequestHeaders.Accept.Clear();
                httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
                httpClient.Timeout = new TimeSpan(0, 0, 5);
                //轉爲連接須要的格式
                HttpContent httpContent = new JsonContent(datajson);
                //請求
                HttpResponseMessage response = httpClient.PostAsync(url, httpContent).Result;
                if (response.IsSuccessStatusCode)
                {
                    Task<string> t = response.Content.ReadAsStringAsync();
                    return t.Result;
                }
                throw new Exception("調用失敗");
            }
                                                                       
        }
    }

 

    public class JsonContent : StringContent
    {
        public JsonContent(object value)
            : base(JsonConvert.SerializeObject(value), Encoding.UTF8,
                "application/json")
        {
        }

        public JsonContent(object value, string mediaType)
            : base(JsonConvert.SerializeObject(value), Encoding.UTF8, mediaType)
        {
        }
    }

三、封裝對Tu Share API的調用

public  class TuShareUtility 
    {
        private IHttpClientUtility _httpClientUtility;
        private string _url = "http://api.waditu.com/";
        
        public TuShareUtility(IHttpClientUtility httpClientUtility)
        {
            _httpClientUtility = httpClientUtility;
        }

        /// <summary>
        /// 調用TuShare API
        /// </summary>
        /// <param name="apiName"></param>
        /// <param name="parmaMap"></param>
        /// <param name="fields"></param>
        /// <returns></returns>
        public  DataTable GetData(string apiName,Dictionary<string,string> parmaMap,params string[] fields)
        {
            var tuShareParamObj=new TuShareParamObj(){ ApiName = apiName ,Params = parmaMap,Fields = string.Join(",",fields)};
            //作Http調用
            var result=_httpClientUtility.HttpClientPost(_url, tuShareParamObj);
            //將返回結果序列化成對象
            var desResult=JsonConvert.DeserializeObject<TuShareResult>(result);
            //若是調用失敗，拋出異常
            if(!string.IsNullOrEmpty(desResult.Msg))
                throw new Exception(desResult.Msg);
            //返回結果分紅兩部分，一部分是列頭信息，另外一部分是數據自己，用這兩部分數據能夠構建DataTable
            DataTable dt = new DataTable();
            foreach (var dataField in desResult.Data.Fields)
            {
                dt.Columns.Add(dataField);
            }

            foreach (var dataItemRow in desResult.Data.Items)
            {
                var newdr=dt.NewRow();
                for (int i=0;i< dataItemRow.Length;i++)
                {
                    newdr[i] = dataItemRow[i];
                }

                dt.Rows.Add(newdr);
            }
            return dt;
        }

        private class TuShareParamObj
        {
            [JsonProperty("api_name")]
            public string ApiName { get; set; }

            [JsonProperty("token")]
            public string Token { get; } = "****************";//你的Token

            [JsonProperty("params")]
            public Dictionary<string, string> Params { get; set; }

            [JsonProperty("fields")]
            public string Fields { get; set; }
        }

        private class TuShareData
        {
            [JsonProperty("fields")]
            public string[] Fields { get; set; }

            [JsonProperty("items")]
            public string[][] Items { get; set; }
        }

        private class TuShareResult
        {
            [JsonProperty("code")]
            public string Code { get; set; }

            [JsonProperty("msg")]
            public string Msg { get; set; }

            [JsonProperty("data")]
            public TuShareData Data { get; set; }
        }
    }

四、調用示例

得到日線行情，整個過程1秒左右，返回6月24日，股票相關交易信息，代碼以下，(該網站的其它接口定義能夠到https://tushare.pro/document/2查看)

var tuShareUtility=new TuShareUtility();
Dictionary<string, string> p = new Dictionary<string, string>();
p["trade_date"] = "20200624";
var table = tuShareUtility.GetData("daily", p, "");

返回以下結果

返回字段說明

名稱	類型	描述
ts_code	str	股票代碼
trade_date	str	交易日期
open	float	開盤價
high	float	最高價
low	float	最低價
close	float	收盤價
pre_close	float	昨收價
change	float	漲跌額
pct_chg	float	漲跌幅 （未復權，若是是復權請用 通用行情接口 ）
vol	float	成交量 （手）
amount	float	成交額 （千元）