fields =
{'TR.EPSActValue':
{'params':{"Period":"FQ0", "Frq": "FQ"},'sort_dir':'asc'}
},
{'TR.EPSActValue.periodenddate':
{'params':{"Period":"FQ0", "Frq": "FQ"},'sort_dir':'asc'}
},
]
I'm trying to request these fields, but I always get the following message as response:
Status received for FNOX.NGM {'status': <StreamState.Closed: 1>, 'code': 'ConnectionError', 'message': 'Cannot send request to ADS'}
NOTE: The method get_data returns the data normally with these fields, but with StramingPrices I get the error message. Any idea of the reason / solution?
Request with get_data:
df, err = ek.get_data(valid_rics, fields)
Request with StramingPrices:
def get_streaming(instruments, fields):
return ek.StreamingPrices(
instruments = instruments,
fields = fields,
on_refresh = on_update,
on_update = on_update,
on_status = on_status,
on_complete = on_complete,
)
def on_update(stream, instrument_name, fields)
print(f'Upate for {instrument_name}: {fields}'.)
def on_status(stream, instrument_name, status)
print('Status received for {} {}'.format(instrument_name, status))
def on_complete(stream)
print(stream.get_snapshot())
streaming = get_streaming(valid_rics, fields)
streaming.open()
asyncio.get_event_loop().run_until_complete(asyncio.sleep(600))
RICs:
valid_rics = [ 'CCHW.NLB', 'FNOX.NGM', 'MMED.NLB', 'NTAR.NLB', 'OLIS.DH', 'SOSIL.NGM', 'SYNTH.TE', ]
Thank you in advance.
