Cannot make Streaming data work in refinitiv-dataplatform library 1.0.0a0

weerayoot.chaisirithavornkul

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

weerayoot.chaisirithavornkul

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.

moragodkrit.chumsri_1

@weerayoot.chaisirithavornkul

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.

umer.nalla

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()

weerayoot.chaisirithavornkul

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?

umer.nalla

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'

moragodkrit.chumsri_1

https://community.developers.refinitiv.com/discussion/comment/54511#Comment_54511

@Olivier DAVANT

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=")

Preeti.Gupta

Hi @weerayoot.chaisirithavornkul,

did you get solution regarding this? I am facing the same issue while migrating the code. Thanks.

umer.nalla

https://community.developers.refinitiv.com/discussion/comment/54888#Comment_54888

Hi @Preeti.Gupta

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.

Preeti.Gupta

https://community.developers.refinitiv.com/discussion/comment/54889#Comment_54889

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'