Update Dockerfile, Python scripts, and Jupyter Notebook for LSEG Real-Time Platform

- Updated Dockerfile to use Python 3.12 and improved multi-stage build process.
- Changed maintainer label to "LSEG Developer Relations" and updated build date.
- Modified requirements.txt to include specific versions for dependencies.
- Updated trcc_posting.py to reflect changes in copyright and improve code consistency.
- Changed hostname variable to 'ADS_HOST' for better configurability.
- Updated Jupyter Notebook to reflect changes in branding and improve documentation.
- Added new requirements_notebook.txt for Jupyter Notebook dependencies.
- Updated images to reflect the new branding and content.

Author: wasin-waeosri

.gitignore

@@ -3,4 +3,8 @@ console_python/market_price.py
 result/
 notebook_python/test_ws_post.ipynb
 notebook_python/test_ws_post2.ipynb
-notebook_python/.ipynb_checkpoints
+notebook_python/.ipynb_checkpoints
+venv/
+nbvenv/
+run.txt
+console_python/nbvenv/

README.md

@@ -1,17 +1,30 @@
-FROM python:3.7-alpine
+#Build stage
+ARG PYTHON_VERSION=3.12
+FROM python:${PYTHON_VERSION} AS builder 
 
-LABEL maintainer="Wasin Waeosri <wasin.waeosri@rifinitiv.com>"
-LABEL build_date="2019-07-30"
+LABEL maintainer="LSEG Developer Relations"
+LABEL build_date="2025-10-06"
 
-# Copy requirements.txt first 
-COPY requirements.txt /
-# instruction to be run during image build
-RUN pip install -r requirements.txt
+#Copy requirements.txt
+COPY requirements.txt .
 
-# then copy the application
-RUN mkdir /app
-COPY trcc_posting.py /app
-#COPY market_price.py /app
+# install dependencies to the local user directory (eg. /root/.local)
+#RUN pip install --no-cache-dir --user -r requirements.txt
+RUN pip install --trusted-host pypi.python.org --trusted-host files.pythonhosted.org --trusted-host pypi.org --no-cache-dir --user -r requirements.txt
+
+# Run stage
+FROM python:${PYTHON_VERSION}-alpine3.22
 WORKDIR /app
 
+# Update PATH environment variable + set Python buffer to make Docker print every message instantly.
+ENV PATH=/root/.local:$PATH \
+    PYTHONUNBUFFERED=1\
+    PYTHONIOENCODING=utf-8\
+    PYTHONLEGACYWINDOWSSTDIO=utf-8
+
+# copy only the dependencies installation from the 1st stage image
+COPY --from=builder /root/.local /root/.local
+COPY trcc_posting.py /app
+
+#Run Python
 ENTRYPOINT ["python", "-u","/app/trcc_posting.py"]

console_python/Dockerfile

@@ -1,3 +1,6 @@
-###### Requirements Libraries ######
-requests
-websocket-client>0.49
+certifi==2025.8.3
+charset-normalizer==3.4.3
+idna==3.10
+requests==2.32.5
+urllib3==2.5.0
+websocket-client==1.8.0

console_python/requirements.txt

@@ -2,12 +2,12 @@
 # |            This source code is provided under the Apache 2.0 license      --
 # |  and is provided AS IS with no warranty or guarantee of fit for purpose.  --
 # |                See the project's LICENSE.md for details.                  --
-# |           Copyright Refinitiv 2020. All rights reserved.                  --
+# |           Copyright LSEG 2025. All rights reserved.                       --
 # |-----------------------------------------------------------------------------
 
 
 #!/usr/bin/env python
-""" Simple example of posting Market Price JSON data To RCC via Refinitiv Real-Time Distribution System 3.2.x using Websockets """
+""" Simple example of posting Market Price JSON data To RCC via LSEG Real-Time Distribution System 3.2.x using Websockets """
 
 import sys
 import time
@@ -20,7 +20,7 @@
 from threading import Thread, Event
 
 # Global Default Variables
-hostname = '127.0.0.1'
+hostname = 'ADS_HOST'
 port = '15000'
 user = 'root'
 app_id = '256'
@@ -43,30 +43,30 @@ def process_message(ws, message_json):  # Process all incoming messages.
     """ Parse at high level and output JSON of message """
     message_type = message_json['Type']
 
-    if message_type == "Refresh":
+    if message_type == 'Refresh':
         if 'Domain' in message_json:
             message_domain = message_json['Domain']
-            if message_domain == "Login":
+            if message_domain == 'Login':
                 process_login_response(ws, message_json)
-    elif message_type == "Ping":
+    elif message_type == 'Ping':
         pong_json = {'Type': 'Pong'}
         ws.send(json.dumps(pong_json))
-        print("SENT:")
+        print('SENT:')
         print(json.dumps(pong_json, sort_keys=True,
                          indent=2, separators=(',', ':')))
 
-    """ If our TRI stream is now open, we can start sending posts. """
+    #If our TRI stream is now open, we can start sending posts.
     global next_post_time
     if ('ID' in message_json and message_json['ID'] == 1 and next_post_time == 0 and
-            (not 'State' in message_json or message_json['State']['Stream'] == "Open" and message_json['State']['Data'] == "Ok")):
+            (not 'State' in message_json or message_json['State']['Stream'] == 'Open' and message_json['State']['Data'] == 'Ok')):
         next_post_time = time.time() + 3
         print('Here')
 
 
 # Process incoming Login Refresh Response message.
 def process_login_response(ws, message_json):
     """ Send Off-Stream Post """
-    print("Sending Off-Stream Post to Real-Time Advanced Distribution Server")
+    print('Sending Off-Stream Post to Real-Time Advanced Distribution Server')
     send_market_price_post(ws)
 
 
@@ -76,55 +76,55 @@ def send_market_price_post(ws):
     global bid_value
     global ask_value
     global primact_1_value
-    """ Send a post message contains a market-price content to RCC """
+    # Send a post message contains a market-price content to RCC
 
-    """ Contribution fields """
+    # Contribution fields
     contribution_fields = {
-        "BID": bid_value,
-        "ASK": ask_value,
-        "PRIMACT_1": primact_1_value
+        'BID': bid_value,
+        'ASK': ask_value,
+        'PRIMACT_1': primact_1_value
     }
 
-    """ OMM Post msg Key """
+    # OMM Post msg Key
     mp_post_key = {
-        "Name": post_item_name,
-        "Service": service_name
+        'Name': post_item_name,
+        'Service': service_name
     }
 
-    """ OMM Post Payload """
+    # OMM Post Payload
     contribution_payload_json = {
-        "ID": 0,
-        "Type": "Update",
-        "Domain": "MarketPrice",
-        "Fields": contribution_fields,
-        "Key": {}
+        'ID': 0,
+        'Type': 'Update',
+        'Domain': 'MarketPrice',
+        'Fields': contribution_fields,
+        'Key': {}
     }
 
-    """ OMM Off-Stream Post message """
+    # OMM Off-Stream Post message
     mp_post_json_offstream = {
-        "Domain": "MarketPrice",
-        "Ack": True,
-        "PostID": post_id,
-        "PostUserInfo": {
-            "Address": position,
-            "UserID": int(app_id)
+        'Domain': 'MarketPrice',
+        'Ack': True,
+        'PostID': post_id,
+        'PostUserInfo': {
+            'Address': position,
+            'UserID': int(app_id)
         },
-        "Key": {},
-        "Message": {},
-        "Type": "Post",
-        "ID": login_id
+        'Key': {},
+        'Message': {},
+        'Type': 'Post',
+        'ID': login_id
     }
 
-    contribution_payload_json["Key"] = mp_post_key
-    mp_post_json_offstream["Key"] = mp_post_key
-    mp_post_json_offstream["Message"] = contribution_payload_json
+    contribution_payload_json['Key'] = mp_post_key
+    mp_post_json_offstream['Key'] = mp_post_key
+    mp_post_json_offstream['Message'] = contribution_payload_json
 
     ws.send(json.dumps(mp_post_json_offstream))
-    print("SENT:")
+    print('SENT:')
     print(json.dumps(mp_post_json_offstream,
                      sort_keys=True, indent=2, separators=(',', ':')))
 
-    """ increase post data value """
+    # increase post data value
     post_id += 1
     bid_value += 1
     ask_value += 1
@@ -151,13 +151,13 @@ def send_login_request(ws):
     login_json['Key']['Elements']['Position'] = position
 
     ws.send(json.dumps(login_json))
-    print("SENT:")
+    print('SENT:')
     print(json.dumps(login_json, sort_keys=True, indent=2, separators=(',', ':')))
 
 
 def on_message(ws, message):
     """ Called when message received, parse message into JSON for processing """
-    print("RECEIVED: ")
+    print('RECEIVED: ')
     message_json = json.loads(message)
     print(json.dumps(message_json, sort_keys=True, indent=2, separators=(',', ':')))
 
@@ -170,56 +170,56 @@ def on_error(ws, error):
     print(error)
 
 
-def on_close(ws):
+def on_close(ws, close_status_code, close_msg):
     """ Called when websocket is closed """
     global web_socket_open
-    print("WebSocket Closed")
+    print(f'WebSocket Closed: {close_status_code} {close_msg}')
     web_socket_open = False
 
 
 def on_open(ws):
     """ Called when handshake is complete and websocket is open, send login """
 
-    print("WebSocket successfully connected!")
+    print('WebSocket successfully connected!')
     global web_socket_open
     web_socket_open = True
     send_login_request(ws)
 
 
-if __name__ == "__main__":
+if __name__ == '__main__':
 
     # Get command line parameters
     try:
-        opts, args = getopt.getopt(sys.argv[1:], "", [
-                                   "help", "hostname=", "port=", "app_id=", "user=", "position=", "item=", "service="])
+        opts, args = getopt.getopt(sys.argv[1:], '', [
+                                   'help', 'hostname=', 'port=', 'app_id=', 'user=', 'position=', 'item=', 'service='])
         print(opts)
     except getopt.GetoptError:
         print(
             'Usage: market_price.py [--hostname hostname] [--port port] [--app_id app_id] [--user user] [--position position] [--item post item name] [--service TRCC Post Service]  [--help] ')
         sys.exit(2)
     for opt, arg in opts:
-        if opt in ("--help"):
+        if opt in ('--help'):
             print(
                 'Usage: market_price.py [--hostname hostname] [--port port] [--app_id app_id] [--user user] [--position position] [--item post item name] [--service TRCC Post Service] [--help]')
             sys.exit(0)
-        elif opt in ("--hostname"):
+        elif opt in ('--hostname'):
             hostname = arg
-        elif opt in ("--port"):
+        elif opt in ('--port'):
             port = arg
-        elif opt in ("--app_id"):
+        elif opt in ('--app_id'):
             app_id = arg
-        elif opt in ("--user"):
+        elif opt in ('--user'):
             user = arg
-        elif opt in ("--position"):
+        elif opt in ('--position'):
             position = arg
-        elif opt in ("--item"):
+        elif opt in ('--item'):
             post_item_name = arg
-        elif opt in ("--service"):
+        elif opt in ('--service'):
             service_name = arg
 
     # Start websocket handshake
-    ws_address = "ws://{}:{}/WebSocket".format(hostname, port)
-    print("Connecting to WebSocket " + ws_address + " ...")
+    ws_address = f'ws://{hostname}:{port}/WebSocket'
+    print(f'Connecting to WebSocket {ws_address} .... ')
     web_socket_app = websocket.WebSocketApp(ws_address, header=['User-Agent: Python'],
                                             on_message=on_message,
                                             on_error=on_error,

console_python/trcc_posting.py

@@ -0,0 +1,93 @@
+anyio==4.11.0
+argon2-cffi==25.1.0
+argon2-cffi-bindings==25.1.0
+arrow==1.3.0
+asttokens==3.0.0
+async-lru==2.0.5
+attrs==25.3.0
+babel==2.17.0
+beautifulsoup4==4.14.2
+bleach==6.2.0
+certifi==2025.8.3
+cffi==2.0.0
+charset-normalizer==3.4.3
+colorama==0.4.6
+comm==0.2.3
+debugpy==1.8.17
+decorator==5.2.1
+defusedxml==0.7.1
+executing==2.2.1
+fastjsonschema==2.21.2
+fqdn==1.5.1
+h11==0.16.0
+httpcore==1.0.9
+httpx==0.28.1
+idna==3.10
+ipykernel==6.30.1
+ipython==9.6.0
+ipython_pygments_lexers==1.1.1
+isoduration==20.11.0
+jedi==0.19.2
+Jinja2==3.1.6
+json5==0.12.1
+jsonpointer==3.0.0
+jsonschema==4.25.1
+jsonschema-specifications==2025.9.1
+jupyter-events==0.12.0
+jupyter-lsp==2.3.0
+jupyter_client==8.6.3
+jupyter_core==5.8.1
+jupyter_server==2.17.0
+jupyter_server_terminals==0.5.3
+jupyterlab==4.4.9
+jupyterlab_pygments==0.3.0
+jupyterlab_server==2.27.3
+lark==1.3.0
+MarkupSafe==3.0.3
+matplotlib-inline==0.1.7
+mistune==3.1.4
+nbclient==0.10.2
+nbconvert==7.16.6
+nbformat==5.10.4
+nest-asyncio==1.6.0
+notebook_shim==0.2.4
+packaging==25.0
+pandocfilters==1.5.1
+parso==0.8.5
+platformdirs==4.4.0
+prometheus_client==0.23.1
+prompt_toolkit==3.0.52
+psutil==7.1.0
+pure_eval==0.2.3
+pycparser==2.23
+Pygments==2.19.2
+python-dateutil==2.9.0.post0
+python-json-logger==4.0.0
+pywin32==311 ; platform_system == "Windows"
+pywinpty==3.0.2 ; platform_system == "Windows"
+PyYAML==6.0.3
+pyzmq==27.1.0
+referencing==0.36.2
+requests==2.32.5
+rfc3339-validator==0.1.4
+rfc3986-validator==0.1.1
+rfc3987-syntax==1.1.0
+rpds-py==0.27.1
+Send2Trash==1.8.3
+setuptools==80.9.0
+six==1.17.0
+sniffio==1.3.1
+soupsieve==2.8
+stack-data==0.6.3
+terminado==0.18.1
+tinycss2==1.4.0
+tornado==6.5.2
+traitlets==5.14.3
+types-python-dateutil==2.9.0.20250822
+typing_extensions==4.15.0
+uri-template==1.3.0
+urllib3==2.5.0
+wcwidth==0.2.14
+webcolors==24.11.1
+webencodings==0.5.1
+websocket-client==1.8.0