Split off DataFrame and non DF example for StreamingEvents

Author: umernalla

2.Content/2.2-Pricing/2.2.03-Pricing-StreamingEvents.ipynb

@@ -72,7 +72,7 @@
     {
      "data": {
       "text/plain": [
-       "<refinitiv.data._data.core.session._platform_session.PlatformSession at 0x228ff300640>"
+       "<refinitiv.data._data.core.session._platform_session.PlatformSession at 0x2da3a6080a0>"
       ]
      },
      "execution_count": 2,
@@ -98,47 +98,21 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "# declare a DataFrame to use for storing our streaming data\n",
-    "df = DataFrame()\n",
-    "# and one to store status events\n",
-    "df_status = DataFrame()\n",
-    "\n",
     "# Function to handle the intial Refresh for each item\n",
     "def handle_refresh(streaming_prices, instrument_name, fields):\n",
-    "# We will do nothing in this instance - instead  we will use the create_dataframe below\n",
-    "# to create a dataframe - once we have received initial values for all items\n",
+    "    # One way to access data - get dataframe\n",
+    "    print(f\"Refresh : {streaming_prices.get_snapshot()}\")\n",
     "    return\n",
     "\n",
-    "# Function to initially populate Dataframe, once initial values received for all items\n",
-    "def create_dataframe(streaming_prices):\n",
-    "    global df\n",
-    "    snapshot = streaming_prices.get_snapshot()\n",
-    "    field_names = snapshot.columns[1:]\n",
-    "    instrument_names = snapshot['Instrument'].values\n",
-    "    df = DataFrame(index=instrument_names, columns=field_names)\n",
-    "    df['Status']=''\n",
-    "    for price in streaming_prices:\n",
-    "        for field_name, field_value in price.get_fields().items():\n",
-    "            df.at[price.name, field_name] = field_value\n",
-    "        if price.name in df_status.index:\n",
-    "            df.at[price.name, 'Status'] = df_status.code[price.name]\n",
-    "    display(df)\n",
-    "\n",
     "# Function to update dataframe, when we receive updates for individual items\n",
-    "def update_dataframe(streaming_prices, instrument_name, fields):\n",
-    "    global df\n",
-    "    clear_output(wait=True)\n",
-    "    for field_name, field_value in fields.items():\n",
-    "        df.at[instrument_name, field_name] = field_value\n",
-    "    if instrument_name in df_status.index:\n",
-    "            df.at[instrument_name, 'Status'] = df_status.code[price.name]\n",
-    "    display(df)\n",
+    "def handle_update(streaming_prices, instrument_name, fields):\n",
+    "    # Alternative way of accesing data - access the updated fields\n",
+    "    print(f\"Update : {instrument_name}:{fields}\")\n",
     "    \n",
     "# Function to extract status code for an item as & when received from server\n",
-    "# The status object also contains a more detailed 'message'\n",
-    "def get_status(streaming_prices, instrument_name, status):\n",
-    "    global init_status\n",
-    "    df_status.at[instrument_name, 'code'] = status['code']"
+    "# Status contains a 'code' and a more detailed 'message'\n",
+    "def handle_status(streaming_prices, instrument_name, status):\n",
+    "    print(f\"Status : {instrument_name}:{status['code']}:{status['message']}\")"
    ]
   },
   {
@@ -153,88 +127,62 @@
    "execution_count": 4,
    "metadata": {},
    "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Refresh :   Instrument     BID     ASK\n",
+      "0       EUR=  1.1934  1.1938\n",
+      "1       GBP=    <NA>    <NA>\n",
+      "2       JPY=    <NA>    <NA>\n",
+      "3     BADRIC    <NA>    <NA>\n",
+      "Refresh :   Instrument     BID     ASK\n",
+      "0       EUR=  1.1934  1.1938\n",
+      "1       GBP=  1.3956   1.396\n",
+      "2       JPY=    <NA>    <NA>\n",
+      "3     BADRIC    <NA>    <NA>\n",
+      "Refresh :   Instrument     BID     ASK\n",
+      "0       EUR=  1.1934  1.1938\n",
+      "1       GBP=  1.3956   1.396\n",
+      "2       JPY=  110.92  110.95\n",
+      "3     BADRIC    <NA>    <NA>\n",
+      "Status : BADRIC:NotFound:**The record could not be found\n"
+     ]
+    },
     {
      "data": {
-      "text/html": [
-       "<div>\n",
-       "<style scoped>\n",
-       "    .dataframe tbody tr th:only-of-type {\n",
-       "        vertical-align: middle;\n",
-       "    }\n",
-       "\n",
-       "    .dataframe tbody tr th {\n",
-       "        vertical-align: top;\n",
-       "    }\n",
-       "\n",
-       "    .dataframe thead th {\n",
-       "        text-align: right;\n",
-       "    }\n",
-       "</style>\n",
-       "<table border=\"1\" class=\"dataframe\">\n",
-       "  <thead>\n",
-       "    <tr style=\"text-align: right;\">\n",
-       "      <th></th>\n",
-       "      <th>BID</th>\n",
-       "      <th>ASK</th>\n",
-       "      <th>Status</th>\n",
-       "    </tr>\n",
-       "  </thead>\n",
-       "  <tbody>\n",
-       "    <tr>\n",
-       "      <th>EUR=</th>\n",
-       "      <td>1.1901</td>\n",
-       "      <td>1.1905</td>\n",
-       "      <td></td>\n",
-       "    </tr>\n",
-       "    <tr>\n",
-       "      <th>GBP=</th>\n",
-       "      <td>1.3915</td>\n",
-       "      <td>1.3919</td>\n",
-       "      <td></td>\n",
-       "    </tr>\n",
-       "    <tr>\n",
-       "      <th>JPY=</th>\n",
-       "      <td>110.76</td>\n",
-       "      <td>110.79</td>\n",
-       "      <td></td>\n",
-       "    </tr>\n",
-       "    <tr>\n",
-       "      <th>CAD=</th>\n",
-       "      <td>1.2371</td>\n",
-       "      <td>1.2375</td>\n",
-       "      <td></td>\n",
-       "    </tr>\n",
-       "  </tbody>\n",
-       "</table>\n",
-       "</div>"
-      ],
       "text/plain": [
-       "         BID     ASK Status\n",
-       "EUR=  1.1901  1.1905       \n",
-       "GBP=  1.3915  1.3919       \n",
-       "JPY=  110.76  110.79       \n",
-       "CAD=  1.2371  1.2375       "
+       "<StreamState.Open: 3>"
       ]
      },
+     "execution_count": 4,
      "metadata": {},
-     "output_type": "display_data"
+     "output_type": "execute_result"
+    },
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Update : GBP=:{'BID': 1.3957, 'ASK': 1.3958}\n",
+      "Update : JPY=:{'BID': 110.93, 'ASK': 110.94}\n",
+      "Update : EUR=:{'BID': 1.1934, 'ASK': 1.1937}\n",
+      "Update : EUR=:{'BID': 1.1936, 'ASK': 1.1937}\n"
+     ]
     }
    ],
    "source": [
     "# Define our Streaming Price object\n",
     "streams = rd.content.pricing.Definition(\n",
-    "    ['EUR=', 'GBP=', 'JPY=', 'CAD='],\n",
+    "    ['EUR=', 'GBP=', 'JPY=', 'BADRIC'],\n",
     "    fields=['BID', 'ASK']\n",
     ").get_stream()\n",
     "\n",
     "# Callback for if we wanted to handle invidiual Refresh for each item\n",
     "streams.on_refresh(handle_refresh)\n",
-    "# Callback for when we have received initial values for all items\n",
-    "streams.on_complete(create_dataframe)\n",
     "# Specify callback handler for any updates\n",
-    "streams.on_update(update_dataframe)\n",
+    "streams.on_update(handle_update)\n",
     "# Specify callback handler for any updates\n",
-    "streams.on_status(get_status)\n",
+    "streams.on_status(handle_status)\n",
     "\n",
     "# Send the requests to the server and open the streams for all items\n",
     "streams.open()"
@@ -249,9 +197,20 @@
   },
   {
    "cell_type": "code",
-   "execution_count": null,
+   "execution_count": 5,
    "metadata": {},
-   "outputs": [],
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "<StreamState.Closed: 1>"
+      ]
+     },
+     "execution_count": 5,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
    "source": [
     "streams.close()"
    ]
@@ -265,16 +224,18 @@
   },
   {
    "cell_type": "code",
-   "execution_count": null,
+   "execution_count": 6,
    "metadata": {},
    "outputs": [],
    "source": [
     "close_session()"
    ]
   },
   {
-   "cell_type": "markdown",
+   "cell_type": "code",
+   "execution_count": null,
    "metadata": {},
+   "outputs": [],
    "source": []
   }
  ],