1. 程式人生 > >利用Tu Share獲取股票交易資訊,c#實現

利用Tu Share獲取股票交易資訊,c#實現

 一、什麼是Tu Share

Tushare是一個免費、開源的python財經資料介面包。主要實現對股票等金融資料從資料採集、清洗加工 到 資料儲存的過程,使用者可以免費(部分資料的下載有積分限制)的通過它提供的財經介面獲取股票交易、期貨等財經資訊,功能非常強大。該介面和直接到各財經網站爬資料相比,最大的優勢就是快,去傳統財經網站爬資料,好多關鍵性的股票資訊只能一隻股一隻股爬,而Tu Share的API,一個呼叫可以獲得一天的全部資料,速度差了好幾個數量級。另外一方面各財經網站的介面的API沒有對外文件化,隨時可能變化,而Tu Share的API有正式的文件化相對比較穩定。

二、如何註冊

該網站使用積分制來控制資料的訪問許可權,如果想要訪問資料,先要到下面這個網址完成註冊,https://tushare.pro/register。註冊完成後,可以需要到個人主頁中拷貝Token,這個Token會在以後的訪問中用到,步驟如下

1、登入成功後,點選右上角->個人主頁

2、 在“使用者中心”中點選“介面TOKEN”

 

3、 可以點選右側複製按鈕複製token

三、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欄位,分別為欄位和資料內容

四、c#(.net core)實現

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

2、封裝方法,實現對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)
        {
        }
    }

3、封裝對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; }
        }
    }

4、呼叫示例

獲得日線行情,整個過程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 成交額 (千元)

 

 

 

  <