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.

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-js

Access the folder

cd tradingeconomics-js/Examples/stream-nodejs/

Install dependencies

npm install

In userKey.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}");
}

s	pch	nch	price	dt	state	type	dhigh	dlow	o	prev	topic
“EURUSD:CUR”	1.09	0.01205	1.11265	1689184474970	open	currency	1.1133	1.1002	1.09651	1.1006	“EURUSD:CUR”
“EURUSD:CUR”	1.1	0.01208	1.11268	1689184480179	open	currency	1.1133	1.1002	1.09651	1.1006	“EURUSD:CUR”
“EURUSD:CUR”	1.1	0.01206	1.11266	1689184482085	open	currency	1.1133	1.1002	1.09651	1.1006	“EURUSD:CUR”

Response fields

Field	Type	Description	Example
s	string	Symbol	‘EURUSD:CUR’
pch	number	Percentage change	0.13
nch	number	Net change	0.0013
price	number	Latest market price	1.1057
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.0912
prev	number	Previous value	1.1044
topic	string	Topic subscribed	‘EURUSD:CUR’