No Response for Multiple RIC streams
I viewed this question about stream id per ric vs batches to get an idea of how to approach this. I'm running into issues when I send multiple requests for stream (as opposed to Non-Streaming) data. When I send 4 separate requests to receive streaming data for some RICS. I only get streams for 2. I don't receive any responses (Status, Update, Refresh) for the other requests
Here's a (simplified) version of what my code looks like:
const rics = ['AAPL.OQ', 'IBM.N', 'DIS.N', 'TSLA.OQ']
for (const ric of rics) {
//The request is made with ids: AAPL=>2, IBN=>3, DIS=>4, TSLA=>5
//Helper method creates the message, and sends the message from the websocket
sendStreamRequest(ric);
}
Example of what a message looks like:
{
ID: 2,
Key: {
Name: 'AAPL.OQ'
},
Streaming: true,
Type: 'Request'
}
My method to use an id for a stream (right now) is really simple. I start with id=2, and increment the id by 1 for each different RIC.
With the current code I have, I'll receive a response for the first 2 APPL, IBM, but no other responses for the other 2 messages I sent - not a Status, Refresh, or Update message.
Any ideas why this may be happening?
Best Answer
-
Hi @jonathan.powell,
The basic code you provided looks ok. Based on what you are seeing, I can only assume there may be some issues within the callbacks and how you are handling the messages. There are a few things you can try.
- Make sure you can retrieve all the data as expected. That is, change the size of your rics array to only contain 1 RIC per execution. Execute the app 4 times changing the ric each time.
- Try sending the rics as a batch. For example, simply pass in the rics array into the 'Name' parameter and observe the behavior. The 'Name' property can accept either a string or array of strings.
- Simplify your code to eliminate any post-processing except to print out the native JSON message received.
When I ran a simple example, this is what I submitted:
{
"Key": {
"Name": "IBM.N"
},
"Domain": "MarketPrice",
"View": [
"BID",
"ASK",
"DSPLY_NAME"
],
"ID": 2
}
{
"Key": {
"Name": "DIS.N"
},
"Domain": "MarketPrice",
"View": [
"BID",
"ASK",
"DSPLY_NAME"
],
"ID": 3
}
etc.And the responses look like this:
{
"ID": 2,
"Type": "Refresh",
"Key": {
"Service": "ELEKTRON_DD",
"Name": "IBM.N"
},
"Qos": {
"Timeliness": "Realtime",
"Rate": "JutConflated"
},
"PermData": "AwEBYsA=",
"SeqNumber": 6096,
"Fields": {
"DSPLY_NAME": "INTL BUS MACHINE",
"BID": 0.0,
"ASK": 0.0,
}
}
etc...0
Answers
-
Hello @jonathan.powell
Are you connecting to your local TREP or ERT in Cloud? Could you please share a full JSON messages log when the problem occurs?
1
Categories
- All Categories
- 6 AHS
- 39 Alpha
- 161 App Studio
- 4 Block Chain
- 4 Bot Platform
- 16 Connected Risk APIs
- 47 Data Fusion
- 30 Data Model Discovery
- 608 Datastream
- 1.3K DSS
- 577 Eikon COM
- 4.9K Eikon Data APIs
- 7 Electronic Trading
- Generic FIX
- 7 Local Bank Node API
- Trading API
- 2.7K Elektron
- 1.3K EMA
- 236 ETA
- 519 WebSocket API
- 33 FX Venues
- 10 FX Market Data
- 1 FX Post Trade
- 1 FX Trading - Matching
- 12 FX Trading – RFQ Maker
- 5 Intelligent Tagging
- 2 Legal One
- 20 Messenger Bot
- 2 Messenger Side by Side
- 9 ONESOURCE
- 7 Indirect Tax
- 59 Open Calais
- 264 Open PermID
- 39 Entity Search
- 2 Org ID
- PAM
- PAM - Logging
- 8.4K Private Comments
- 6 Product Insight
- Project Tracking
- ProView
- ProView Internal
- 20 RDMS
- 1.4K Refinitiv Data Platform
- 367 Refinitiv Data Platform Libraries
- 3 Refinitiv Due Diligence
- LSEG Due Diligence Portal API
- 3 Refinitiv Due Dilligence Centre
- Rose's Space
- 1.1K Screening
- 18 Qual-ID API
- 13 Screening Deployed
- 23 Screening Online
- 10 World-Check Customer Risk Screener
- 990 World-Check One
- 44 World-Check One Zero Footprint
- 45 Side by Side Integration API
- Test Space
- 3 Thomson One Smart
- 1.2K TR Internal
- Global Hackathon 2015
- 2 Specialists Who Code
- 10 TR Knowledge Graph
- 150 Transactions
- 142 REDI API
- 1.7K TREP APIs
- 4 CAT
- 21 DACS Station
- 117 Open DACS
- 1.1K RFA
- 103 UPA
- 172 TREP Infrastructure
- 224 TRKD
- 886 TRTH
- 5 Velocity Analytics
- 5 Wealth Management Web Services
- 59 Workspace SDK
- 9 Element Framework
- 5 Grid
- 13 World-Check Data File
- Yield Book Analytics
- 46 中文论坛