Этот пример показывает, как настроить StringConsumer
HTTP class-PricesStreamer-to
отображение переданные потоком данные из гипотетического веб-сайта в окне рисунка MATLAB®. Создать рабочий пример:
Идентифицируйте URL, подобный:
url = matlab.net.URI('<URL>','accountId',<YOUR_ACCOUNT_ID>,'<NAME>','<VALUE>');
Измените PricesStreamer.putData
, чтобы считать данные, характерные для вашего веб-сервиса
Следующие задачи описаны в этой теме. Для получения информации об отображающихся табличных данных в окне рисунка смотрите uitable
.
PricesStreamer
PricesStreamer.m
является подклассом класса StringConsumer
, который является подклассом ContentConsumer
. PricesStreamer
получает переданные потоком данные, настроенные к данным, обеспеченным определенным веб-сервисом. В этом примере структура данных:
% Data contains one or more CRLF-separated JSON structures. % Each structure is one of the format: % {"heartbeat"="timestamp"} % {"tick"="timestamp", "bid"=bid, "ask"=ask} % where timestamp is a GMT time and bid and ask are numbers.
MATLAB вызывает функцию PricesStreamer.putData
для каждого фрагмента данных, полученных от сервера. Функция сначала преобразовывает необработанные байты uint8
в строку JSON с помощью StringConsumer
. Затем, это получает структуру MATLAB от строки JSON с помощью jsondecode
и затем отображает данные в таблице в фигуре, добавляя одну строку в верхние строки таблицы для каждого шага данных. Можно изменить функцию putData
, чтобы сделать что-то еще с данными, например, построить график в реальном времени или цены дельты отображения. PricesStreamer
устанавливает возвращаемое значение stop
останавливать операцию, когда пользователь закрывает фигуру. Для получения дополнительной информации смотрите ContentConsumer.putData
.
classdef PricesStreamer < matlab.net.http.io.StringConsumer % PricesStreamer accepts streamed JSON % and displays the result in a uitable in a figure window. % Copyright 2016-2017 The MathWorks, Inc. properties Figure Table Endit logical HaveTick logical end methods (Access=protected) function length = start(obj) if obj.Response.StatusCode ~= matlab.net.http.StatusCode.OK length = 0; else length = obj.start@matlab.net.http.io.StringConsumer; obj.Figure = figure('CloseRequestFcn',@obj.endit); obj.Figure.Position(4) = 550; obj.Figure.Position(2) = 50; obj.Table = uitable(obj.Figure,... 'ColumnName',{'Time','Bid','Ask'},... 'ColumnWidth',{130,'auto','auto'}); obj.Table.Position(4) = 500; obj.Table.Data = cell(0,3); obj.Endit = false; obj.HaveTick = false; end end end methods function [len,stop] = putData(obj, data) % Data contains one or more CRLF-separated JSON structures. % Each structure is one of the format: % {"heartbeat"="timestamp"} % {"tick"="timestamp", "bid"=bid, "ask"=ask} % where timestamp is a GMT time and bid and ask are numbers. if obj.Endit data = []; delete(obj.Figure); end first = obj.CurrentLength + 1; [len,stop] = obj.putData@matlab.net.http.io.StringConsumer(data); if isempty(data) || stop if ischar(data) % data == '' means user ctrl/c'ed, so set to obj.Endit = true; % delete figure on next close end stop = true; else stop = false; last = obj.CurrentLength; newData = obj.Response.Body.Data.extractBetween(first,last); % split at CRLFs strings = strsplit(newData, '\r\n'); try cellfun(@obj.displayJSON, strings); catch e fprintf('Error on JSON:\n%s<EOF>\n',data); obj.Endit = true; rethrow(e); end end end function displayJSON(obj, str) if ~isempty(str) try val = jsondecode(str); catch e fprintf('Error "%s" on JSON:\n%s<EOF>\n',e.message,str); rethrow(e); end if isfield(val,'tick') tick = val.tick; newdata = {cvtime(val.tick.time),tick.bid,tick.ask}; setExtent = ~obj.HaveTick; obj.HaveTick = true; elseif isfield(val, 'heartbeat') newdata = {cvtime(val.heartbeat.time),'',''}; setExtent = false; end obj.Table.Data = [newdata;obj.Table.Data]; if setExtent || ~mod(log10(length(obj.Table.Data)),1) % set extent on first tick and every power of 10 % add 15 for width of scroll bar obj.Table.Position(3) = obj.Table.Extent(3) + 15; end drawnow end end function endit(obj,~,~) % endit callback from close(obj.Figure) if exist('obj','var') && isvalid(obj) if obj.Endit if isvalid(obj.Figure) delete(obj.Figure); end else obj.Endit = true; end end end function delete(obj) if ~isempty(obj.Figure) && isvalid(obj.Figure) delete(obj.Figure); end end end end function time = cvtime(time) % Format time data for display time = datetime(time,'InputFormat','yyyy-MM-dd''T''HH:mm:ss.S''Z''','TimeZone','GMT'); time.TimeZone = 'local'; time = char(time, 'dd-MMM-yyyy HH:mm:ss.S'); end
uitable
Идентифицируйте структуры данных для своего варианта использования путем чтения информации API из веб-сервиса. Данные для этого примера содержат один или несколько CRLF-разделенные структуры JSON. Формат для структур является одним из следующих, где timestamp
является временем GMT, и bid
и ask
являются числами.
{"heartbeat"="timestamp"}
{"tick"="timestamp", "bid"=bid, "ask"=ask}
Чтобы считать этот определенный формат, замените метод StringConsumer.putData
. Следующие операторы от класса PricesStreamer
используют StringConsumer.putData
, чтобы считать следующий буфер, затем выбрать строки JSON.
first = obj.CurrentLength + 1; [len,stop] = obj.putData@matlab.net.http.io.StringConsumer(data); last = obj.CurrentLength; newData = obj.Response.Body.Data.extractBetween(first,last); % split at CRLFs strings = strsplit(newData, '\r\n');
Следующие операторы от функции displayJSON
индивидуально обрабатывают tick
JSON и структуры heartbeat
. Функция помощника cvtime
форматирует данные времени для отображения в таблице.
function displayJSON(obj, str) ... val = jsondecode(str); if isfield(val,'tick') tick = val.tick; newdata = {cvtime(val.tick.time),tick.bid,tick.ask}; ... elseif isfield(val, 'heartbeat') newdata = {cvtime(val.heartbeat.time),'',''}; ... end obj.Table.Data = [newdata;obj.Table.Data]; ... end
В этом примере MATLAB получает данные, пока веб-сервис активен. Пользователь может отключить поток путем закрытия окна рисунка или путем нажатия Ctrl+C. Чтобы сообщить MATLAB о пользовательском прерывании, установите аргумент stop
в putData
к false
. Задачи очистки включают закрытие фигуры, использующей свойство CloseRequestFcn
и удаляющей объект с помощью функции PricesStreamer.delete
.
PricesStreamer
Следующий код служит основой для того, чтобы получить данные из веб-сервиса. Чтобы запустить код, необходимо обеспечить значения для содержимого в символах <>
. URL для вашего веб-сервиса может включать дополнительные параметры, такие как информация о входе в систему и другая информация, указанная как имя, аргументы пары значения. Чтобы использовать PricesStreamer
, добавьте его в свой вызов matlab.net.http.RequestMessage.send
. Для получения информации о создании сообщений запроса смотрите Интерфейс HTTP.
url = matlab.net.URI('<URL>','accountId',<YOUR_ACCOUNT_ID>,'<NAME>','<VALUE>'); authInfo = matlab.net.http.AuthInfo(matlab.net.http.AuthenticationScheme.Bearer,... 'Encoded','<YOUR_CREDENTIALS>'); af = matlab.net.http.field.AuthorizationField('Authorization',authInfo); r = matlab.net.http.RequestMessage('get',af); consumer = PricesStreamer; % SavePayload set to retain all results - useful for debugging [resp,req,hist] = r.send(url,matlab.net.http.HTTPOptions('SavePayload',true),consumer); % Show the results for debugging show(resp)
Следующее является примером данных из данных об отправке веб-сервиса, описанных в Данных о Карте к MATLAB uitable Объект.
HTTP/1.1 200 Ok Server: openresty/1.9.15.1 Date: Wed, 06 Sep 2017 19:26:56 GMT Content-Type: application/json Transfer-Encoding: chunked Connection: close Access-Control-Allow-Origin: * {"tick":{"instrument":"AUD_CAD","time":"2017-09-06T19:26:54.304054Z","bid":0.97679,"ask":0.97703}} {"heartbeat":{"time":"2017-09-06T19:26:56.253091Z"}} {"tick":{"instrument":"AUD_CAD","time":"2017-09-06T19:26:57.226918Z","bid":0.97678,"ask":0.97703}} {"tick":{"instrument":"AUD_CAD","time":"2017-09-06T19:26:58.226909Z","bid":0.97678,"ask":0.97705}} {"heartbeat":{"time":"2017-09-06T19:26:58.720409Z"}} {"tick":{"instrument":"AUD_CAD","time":"2017-09-06T19:27:00.733194Z","bid":0.97679,"ask":0.97704}} {"heartbeat":{"time":"2017-09-06T19:27:01.251202Z"}} {"tick":{"instrument":"AUD_CAD","time":"2017-09-06T19:27:01.757501Z","bid":0.9768,"ask":0.97706}} {"heartbeat":{"time":"2017-09-06T19:27:03.720469Z"}}