Отобразите переданные потоком данные в окне рисунка

Этот пример показывает, как настроить 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

Сопоставьте данные с MATLAB объект 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');

Отобразите данные в формате JSON

Следующие операторы от функции 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"}}

Смотрите также

|

Для просмотра документации необходимо авторизоваться на сайте