Streaming

The Trading Economics API streaming endpoint can be used to receive live market data utilizing a persistent web socket connection. Streaming data from the API consists of making an authorization request and leaving the socket open to continually receive data. You can authorize using your API client credentials (key/secret). Then you will be able to subscribe to 1 or more of our streaming channels. Please consider that all market-related methods are beta and under heavy development.

Get live market

Subscribe to markets streaming data.

import tradingeconomics as te
import json
te.login('you_private_key')

def on_message(ws, message):
    print(json.loads(message))

te.subscribe('EURUSD:CUR')
te.run(on_message)

te.subscribe( ['EURUSD:CUR', 'AAPL:US', 'CL1:COM'] )

Clone the repository

git clone https://github.com/tradingeconomics/tradingeconomics

Access the folder

cd tradingeconomics/nodejs/Examples/stream-nodejs

Install dependencies

npm install

In app.js file, set-up your client key and secret. Then subscribe to markets.

Client = new te_client({
    url: 'wss://stream.tradingeconomics.com/',
    key: 'API_CLIENT_KEY', // <--
    secret: 'API_CLIENT_SECRET' // <--
    //reconnect: true
});

Client.subscribe('EURUSD:CUR')

Client.subscribe(['EURUSD:CUR', 'AAPL:US', 'CL1:COM'])

Only a single market topic EURUSD:CUR can be subscribed using guest:guest. For other markets topic, a “key:secret” is required.

using System.Net.WebSockets;
using System.Text;

try
{
    using (var cws = new ClientWebSocket())
    {
        await cws.ConnectAsync(new Uri($"wss://stream.tradingeconomics.com/?client='your_private_key'"), CancellationToken.None);

        if (cws.State == WebSocketState.Open)
        {
            var buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(@"{""topic"": ""subscribe"", ""to"": """ + "market_symbol" + @""" }"));
            await cws.SendAsync(buffer, WebSocketMessageType.Binary, true, CancellationToken.None);
        }

        await Task.Delay(1024);

        while (cws.State == WebSocketState.Open)
        {
            var buffer = new ArraySegment<byte>(new byte[1024]);
            var result = await cws.ReceiveAsync(buffer, CancellationToken.None);
            if (result.MessageType == WebSocketMessageType.Close)
            {
                await cws.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
            }

            Console.WriteLine($"Receiving: {Encoding.UTF8.GetString(buffer.Array, 0, result.Count).Trim()}");
        }
    }
}
catch (Exception e)
{
    Console.WriteLine($"Error with message: {e.Message}");
}

Response fields

Field	Type	Description	Example
s	string	Symbol	‘EURUSD:CUR’
pch	number	Percentage change	0.13
nch	number	Net change	0.00139
price	number	Latest market price	1.10579
dt	timestamp	Timestamp of last market price (epoch)	1681474172576
state	string	Market state (open/close)	‘open’
type	string	Type of market (currency/indexes/commodity)	‘currency’
dhigh	number	Daily high	1.1075
dlow	number	Daily low	1.1042
o	number	Day open	1.09129
prev	number	Previous value	1.1044
topic	string	Topic subscribed	‘EURUSD:CUR’