Hello,
I am migrating my apps to refinitiv-dataplatform-1.0.0a0 and found that Streaming data dosen't work. I found that in pricing_.py during open_stream(), the function instantiate StreamingPrice with parameters that different from the constructor of the class. Could you please check?
Thanks
Hi @Preeti.Gupta,
I have chatted with the development team, they will release a new version with this issue fix, soon. Please upgrade to new version when it is released.
Can you provide the codes/parameters that look different from the constructor of the class? and elaborate more on the issue?
I did a quick check the pricin_.py and streamingprice.py from the site-packages and it seems to be a correct one. Also, try running the sample 2.3.0 - Content - StreamingPrices - Update DataFrame.ipynb and not found the problem.
Hi @weerayoot.chaisirithavornkul,
You can also try out the alternative examples under Developer Day Resources
These examples use a Session helper class which also outputs session events and status information - which may provide useful information.
In addition to this you can enable logging for the session in case you need additional diagnostics e.g.
mySession = get_session("platform")
mySession.set_log_level(6)
mySession.open()
Hello @moragodkrit,
in pricing_.py line 248
self._streaming_prices[universe] = StreamingPrice(self._session,
name=universe,
fields=fields,
streaming=not close_after_snapshot,
on_refresh=on_refresh,
on_update=on_update,
on_status=on_status,
on_complete=on_complete)
while StreamingPrice's constructor is
def __init__(self,
name,
session=None,
fields=None,
service=None,
streaming=None,
extended_params=None,
on_refresh=None,
on_status=None,
on_update=None,
on_complete=None,
on_error=None):
It seems the caller pass self._session to where is supposed to be name, and pass universe as an optional parameter which the called method doesn't accept name as an optional parameter.
Could you please check?
It seems to be an issue with the order of argument used inside the method open_stream from Pricing class. Can you check with Dev?
It looks like the correct codes at line 248 should be
StreamingPrice(session=self._session,...)
Otherwise, it will return
TypeError: __init__() got multiple values for argument 'name'
when you call
rdp.Pricing().open_stream(universe="EUR=")
Hi @weerayoot.chaisirithavornkul,
Please confirm which example you are running / code you are using and please expand on what you mean by 'Streaming data dosen't work'
Hi @weerayoot.chaisirithavornkul,
did you get solution regarding this? I am facing the same issue while migrating the code. Thanks.
If you are migrating code written to work with an older version of RDP Library, please note that the StreamingPrice Class was renamed to StreamingPrices for the latest alpha version. If you are using StreamingPrice, please change to StreamingPrices and see if that helps.
Note that there still is a StreamingPrice class - but that only allows a single RIC, whereas StreamingPrices allows multiple - and the parameters are slightly different too.
Hi @Umer Nalla,
Thanks for your reply. Yes, I am migrating the code and I have made changes to StreamingPrices (thank you for providing insight). But the issue which I am facing is related with open_stream function call.
I am getting error - TypeError: __init__() got multiple values for argument 'name'
