LSEG Data Library for Python

get_stream

The get_stream function returns the data stream from the Delivery Platform (formerly Refinitiv Data Platform), defined in the omm_stream.Definition object.

Module

lseg.data.delivery.omm_stream

Syntax

get_stream(session)

Parameters

Returned value

OMMStream instance

Usage

The following example demonstrates how to retrieve the streaming data from a previously defined OMM stream in the "MarketPrice" domain, for the "BID", "ASK", "OPEN_PRC", "HST_CLOSE", and "TIMACT" fields of the EUR instrument:

import json
import datetime
from lseg.data.delivery import omm_stream


# define callback function to catch the messages from stream.
def display_event(eventType, event):
    currentTime = datetime.datetime.now().time()
    print("----------------------------------------------------------")
    print(">>> {} event received at {}".format(eventType, currentTime))
    print(json.dumps(event, indent=2))

stream = omm_stream.Definition(
        name="EUR=",
        fields=['BID', 'ASK', 'OPEN_PRC', 'HST_CLOSE', 'TIMACT'],
).get_stream()

# Refresh - the first full image we get back from the server
stream.on_refresh(lambda event, item_stream: display_event("Refresh", event))

stream.open()

stream.close()

This example produces the following output:

Related links

None.