- Introduction
- Concepts and Design
-
CONFIGURATION
-
SESSION LAYER
- About the Session Layer
-
Session
-
session.Definition
- session.Definition object
-
session.Definition object methods
-
session.desktop.Definition
- session.desktop.Definition object
-
session.desktop.Definition methods
-
session.platform.Definition
- session.platform.Definition object
-
session.platform.Definition methods
-
Functions
- Callback functions
- Session event codes
- Session states
-
ACCESS LAYER
-
CONTENT LAYER
- About the Content Layer
-
Fundamental and Reference
- About Fundamental And Reference
-
fundamental_and_reference.Definition
- fundamental_and_reference.Definition object
-
fundamental_and_reference.Definition methods
- fundamental_and_reference.RowHeaders
-
Historical Pricing
- About Historical Pricing
-
Historical Pricing Events
- About historical pricing events
-
historical_pricing.events.Definition
- historical_pricing.events.Definition object
-
historical_pricing.events.Definition methods
-
Historical Pricing Summaries
- About historical pricing summaries
-
historical_pricing.summaries.Definition
- historical_pricing.summaries.Definition object
-
historical_pricing.summaries.Definition methods
- Historical pricing event types
- Historical pricing adjustments
- Historical pricing market session
-
News
- About news
-
News headlines
- About news headlines
-
news.headlines.Definition
- news.headlines.Definition object
-
news.headlines.Definition methods
-
News stories
- About news stories
-
news.story.Definition
- news.story.Definition object
-
news.story.Definition methods
- News SortOrder
-
Pricing
- About pricing
-
pricing.Definition
- pricing.Definition object
-
pricing.Definition methods
-
pricing stream methods
-
pricing.chain
- About pricing.chain
-
pricing.chain.Definition
- pricing.chain.Definition object
-
pricing.chain methods
- Pricing stream states
-
Search
- About search
-
search.Definition
- search.Definition object
-
search.Definition methods
-
search.SearchViews
-
SymbolConversion
- About SymbolConversion
-
SymbolConversion.Definition
- SymbolConversion.Definition object
-
SymbolConversion.Definition methods
- Symbol types
- CountryCode
- AssetClass
- AssetState
-
Trade data service
- About trade data service
-
trade_data_service.Definition
- trade_data_service.Definition object
-
trade_data_service.Definition methods
-
trade_data_service Stream
- trade_data_service Stream object
-
trade_data_service Stream methods
- Trade data service events
- Trade data service universe types
- Trade data service finalized orders
-
Estimates
- About Estimates
-
Estimates actual values for reported annual periods
- estimates.view_actuals.annual.Definition object
-
estimates.view_actuals.annual.Definition methods
-
Estimates actual values for reported interim periods
- estimates.view_actuals.interim.Definition object
-
estimates.view_actuals.interim.Definition methods
-
Estimates actual values for KPI Measures for reported annual periods
- estimates.view_actuals_kpi.annual.Definition object
-
estimates.view_actuals_kpi.annual.Definition methods
-
Estimates actual values for KPI Measures for reported interim periods
- estimates.view_actuals_kpi.interim.Definition object
-
estimates.view_actuals_kpi.interim.Definition methods
-
Annual estimates summary data for periodic estimates measures
- estimates.view_summary.annual.Definition object
-
estimates.view_summary.annual.Definition methods
-
Interim estimates summary data for periodic estimates measures
- estimates.view_summary.interim.Definition object
-
estimates.view_summary.interim.Definition methods
-
Estimates monthly historical snapshot value for last 12 months for all annual period estimates measures
- estimates.view_summary.historical_snapshots_periodic_measures_annual.Definition object
-
estimates.view_summary.historical_snapshots_periodic_measures_annual.Definition methods
-
Estimates monthly historical snapshot value for last 12 months for all interim period estimates measures
- estimates.view_summary.historical_snapshots_periodic_measures_interim.Definition object
-
estimates.view_summary.historical_snapshots_periodic_measures_interim.Definition methods
-
Estimates monthly historical snapshot value for non-periodic estimates measures for the last 12 months
- estimates.view_summary.historical_snapshots_non_periodic_measures.Definition object
-
estimates.view_summary.historical_snapshots_non_periodic_measures.Definition methods
-
Estimates monthly historical snapshot value for recommendations for the last 12 months
- estimates.view_summary.historical_snapshots_recommendations.Definition object
-
estimates.view_summary.historical_snapshots_recommendations.Definition methods
-
Estimates summary values for KPI measures for annual periods
- estimates.view_summary_kpi.annual.Definition object
-
estimates.view_summary_kpi.annual.Definition methods
-
Estimates summary values for KPI measures for interim periods
- estimates.view_summary_kpi.interim.Definition object
-
estimates.view_summary_kpi.interim.Definition methods
-
Estimates monthly historical snapshot value for all KPI measures for the last 12 months
- estimates.view_summary_kpi.historical_snapshots_kpi.Definition object
-
estimates.view_summary_kpi.historical_snapshots_kpi.Definition methods
-
ESG
- About ESG
-
esg.full_measures.Definition
- esg.full_measures.Definition object
-
esg.full_measures.Definition methods
-
esg.full_scores.Definition
- esg.full_scores.Definition object
-
esg.full_scores.Definition methods
-
esg.basic_overview.Definition
- esg.basic_overview.Definition object
-
esg.basic_overview.Definition methods
-
esg.standard_measures.Definition
- esg.standard_measures.Definition object
-
esg.standard_measures.Definition methods
-
esg.standard_scores.Definition
- esg.standard_scores.Definition object
-
esg.standard_scores.Definition methods
-
esg.universe.Definition
- esg.universe.Definition object
-
esg.universe.Definition methods
-
esg.bulk.Definition
- esg.bulk.Definition object
-
esg.bulk.Definition methods
-
esg.bulk.PackageManager
- esg.bulk.PackageManager object
-
esg.bulk.PackageManager object methods
-
DELIVERY LAYER
open_pricing_stream
The open_pricing_stream
creates and opens a pricing stream.
Module
refinitiv.data
Syntax
open_pricing_stream(universe, fields=None, service=None, on_data=None)
Parameters
Value | Description | Data type | Optional | Default value |
---|---|---|---|---|
universe | Instruments to request | str, List[str] | No | |
fields | Fields to request | str, List[str] | Yes | None |
service | Name of the streaming service publishing the instruments | str | Yes | None |
on_data | Callback function | Callable | Yes | None |
Returned value
PricingStream
instance
Usage
The following example demonstrates how to create a session, open and get a stream, display data, and then close the stream and session:
import datetime
import refinitiv.data as rd
# open session
rd.open_session()
# define callback
def display_data(data, instrument, stream):
current_time = datetime.datetime.now().time()
print(current_time, "- Data received for", instrument)
print(data)
print('\n')
# open stream and display data
stream = rd.open_pricing_stream(
universe=['GBP=', 'EUR=', 'JPY='],
fields=['BID', 'ASK'],
on_data=display_data
)
# wait for some data to come in
# ...
# ...
# ...
# close stream and session
stream.close()
rd.close_session()
This example produces the following output:
02:17:53.292794 - Data received for GBP=
BID ASK
GBP= 1.2192 1.2193
02:17:53.301338 - Data received for JPY=
BID ASK
JPY= 133.04 133.05
02:17:53.306010 - Data received for EUR=
BID ASK
EUR= 1.0318 1.0322
Related links
None.