Skip to content

Commit b947ad1

Browse files
author
Olivier Davant
committed
Tutorials updated for 1.0.0b16
1 parent e70f066 commit b947ad1

File tree

2 files changed

+46
-130
lines changed

2 files changed

+46
-130
lines changed

‎Tutorials/3.Delivery/3.1-Streaming/TUT_3.1.01-OMMStream-MarketPrice.ipynb‎

Lines changed: 39 additions & 123 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@
8181
{
8282
"data": {
8383
"text/plain": [
84-
"<refinitiv.data.session.platform.Definition object at 0x1203e90fc10 {session_name='rdp'}>"
84+
"<refinitiv.data.session.Definition object at 0x7ff067e56f10 {name='workspace'}>"
8585
]
8686
},
8787
"execution_count": 3,
@@ -130,7 +130,7 @@
130130
{
131131
"data": {
132132
"text/plain": [
133-
"<refinitiv.data.delivery.omm_stream.OMMStream object at 0x1203eb451f0>"
133+
"<refinitiv.data.delivery.omm_stream.OMMStream object at 0x7ff06aa475e0>"
134134
]
135135
},
136136
"execution_count": 5,
@@ -144,14 +144,14 @@
144144
" fields=['BID', 'ASK','OPEN_PRC','HST_CLOSE','TIMACT'], \n",
145145
" domain='MarketPrice').get_stream()\n",
146146
"\n",
147-
"# Refresh - the first full imaage we get back from the server\n",
148-
"stream.on_refresh(lambda stream, event : display_event(\"Refresh\", event))\n",
147+
"# Refresh - the first full image we get back from the server\n",
148+
"stream.on_refresh(lambda event, stream : display_event(\"Refresh\", event))\n",
149149
"# Update - as and when field values change, we receive updates from the server\n",
150-
"stream.on_update(lambda stream, event : display_event(\"Update\", event))\n",
150+
"stream.on_update(lambda event, stream : display_event(\"Update\", event))\n",
151151
"# Status - if data goes stale or item closes, we get a status message\n",
152-
"stream.on_status(lambda stream, event : display_event(\"Status\", event))\n",
152+
"stream.on_status(lambda event, stream : display_event(\"Status\", event))\n",
153153
"# Other errors\n",
154-
"stream.on_error(lambda stream, event : display_event(\"Error\", event))"
154+
"stream.on_error(lambda event, stream : display_event(\"Error\", event))"
155155
]
156156
},
157157
{
@@ -176,38 +176,39 @@
176176
"output_type": "stream",
177177
"text": [
178178
"----------------------------------------------------------\n",
179-
">>> Refresh event received at 10:26:05.938979\n",
179+
">>> Refresh event received at 17:51:55.032083\n",
180180
"{\n",
181-
" \"ID\": 1,\n",
181+
" \"ID\": 5,\n",
182182
" \"Type\": \"Refresh\",\n",
183183
" \"Key\": {\n",
184-
" \"Service\": \"ELEKTRON_DD\",\n",
184+
" \"Service\": \"IDN_RDFNTS_CF\",\n",
185185
" \"Name\": \"EUR=\"\n",
186186
" },\n",
187187
" \"State\": {\n",
188188
" \"Stream\": \"Open\",\n",
189-
" \"Data\": \"Ok\"\n",
189+
" \"Data\": \"Ok\",\n",
190+
" \"Text\": \"New Session Mounted\"\n",
190191
" },\n",
191192
" \"Qos\": {\n",
192193
" \"Timeliness\": \"Realtime\",\n",
193194
" \"Rate\": \"JitConflated\"\n",
194195
" },\n",
195-
" \"PermData\": \"AwEBUmw=\",\n",
196-
" \"SeqNumber\": 39550,\n",
196+
" \"PermData\": \"AwD+Umw=\",\n",
197+
" \"SeqNumber\": 9374,\n",
197198
" \"Fields\": {\n",
198-
" \"TIMACT\": \"10:26:00\",\n",
199-
" \"OPEN_PRC\": 1.1259,\n",
200-
" \"HST_CLOSE\": 1.1257,\n",
201-
" \"BID\": 1.127,\n",
202-
" \"ASK\": 1.1273\n",
199+
" \"BID\": 1.0585,\n",
200+
" \"ASK\": 1.0589,\n",
201+
" \"OPEN_PRC\": 1.0525,\n",
202+
" \"HST_CLOSE\": 1.0525,\n",
203+
" \"TIMACT\": \"15:51:00\"\n",
203204
" }\n",
204205
"}\n"
205206
]
206207
},
207208
{
208209
"data": {
209210
"text/plain": [
210-
"<OpenState.Opened: 1>"
211+
"<OpenState.Opened: 'Opened'>"
211212
]
212213
},
213214
"execution_count": 6,
@@ -219,111 +220,37 @@
219220
"output_type": "stream",
220221
"text": [
221222
"----------------------------------------------------------\n",
222-
">>> Update event received at 10:26:06.011530\n",
223+
">>> Update event received at 17:51:55.082900\n",
223224
"{\n",
224-
" \"ID\": 1,\n",
225+
" \"ID\": 5,\n",
225226
" \"Type\": \"Update\",\n",
226227
" \"UpdateType\": \"Unspecified\",\n",
227-
" \"DoNotConflate\": true,\n",
228228
" \"Key\": {\n",
229-
" \"Service\": \"ELEKTRON_DD\",\n",
229+
" \"Service\": \"IDN_RDFNTS_CF\",\n",
230230
" \"Name\": \"EUR=\"\n",
231231
" },\n",
232-
" \"SeqNumber\": 39566,\n",
232+
" \"SeqNumber\": 9390,\n",
233233
" \"Fields\": {\n",
234-
" \"BID\": 1.1272,\n",
235-
" \"ASK\": 1.1275,\n",
236-
" \"TIMACT\": \"10:26:00\"\n",
234+
" \"BID\": 1.0585,\n",
235+
" \"ASK\": 1.0589,\n",
236+
" \"TIMACT\": \"15:51:00\"\n",
237237
" }\n",
238238
"}\n",
239239
"----------------------------------------------------------\n",
240-
">>> Update event received at 10:26:07.000999\n",
240+
">>> Update event received at 17:51:56.105043\n",
241241
"{\n",
242-
" \"ID\": 1,\n",
242+
" \"ID\": 5,\n",
243243
" \"Type\": \"Update\",\n",
244244
" \"UpdateType\": \"Unspecified\",\n",
245-
" \"DoNotConflate\": true,\n",
246245
" \"Key\": {\n",
247-
" \"Service\": \"ELEKTRON_DD\",\n",
246+
" \"Service\": \"IDN_RDFNTS_CF\",\n",
248247
" \"Name\": \"EUR=\"\n",
249248
" },\n",
250-
" \"SeqNumber\": 39630,\n",
249+
" \"SeqNumber\": 9454,\n",
251250
" \"Fields\": {\n",
252-
" \"BID\": 1.127,\n",
253-
" \"ASK\": 1.1273,\n",
254-
" \"TIMACT\": \"10:26:00\"\n",
255-
" }\n",
256-
"}\n",
257-
"----------------------------------------------------------\n",
258-
">>> Update event received at 10:26:08.002936\n",
259-
"{\n",
260-
" \"ID\": 1,\n",
261-
" \"Type\": \"Update\",\n",
262-
" \"UpdateType\": \"Unspecified\",\n",
263-
" \"DoNotConflate\": true,\n",
264-
" \"Key\": {\n",
265-
" \"Service\": \"ELEKTRON_DD\",\n",
266-
" \"Name\": \"EUR=\"\n",
267-
" },\n",
268-
" \"SeqNumber\": 39694,\n",
269-
" \"Fields\": {\n",
270-
" \"BID\": 1.1272,\n",
271-
" \"ASK\": 1.1275,\n",
272-
" \"TIMACT\": \"10:26:00\"\n",
273-
" }\n",
274-
"}\n",
275-
"----------------------------------------------------------\n",
276-
">>> Update event received at 10:26:08.991996\n",
277-
"{\n",
278-
" \"ID\": 1,\n",
279-
" \"Type\": \"Update\",\n",
280-
" \"UpdateType\": \"Unspecified\",\n",
281-
" \"DoNotConflate\": true,\n",
282-
" \"Key\": {\n",
283-
" \"Service\": \"ELEKTRON_DD\",\n",
284-
" \"Name\": \"EUR=\"\n",
285-
" },\n",
286-
" \"SeqNumber\": 39758,\n",
287-
" \"Fields\": {\n",
288-
" \"BID\": 1.127,\n",
289-
" \"ASK\": 1.1273,\n",
290-
" \"TIMACT\": \"10:26:00\"\n",
291-
" }\n",
292-
"}\n",
293-
"----------------------------------------------------------\n",
294-
">>> Update event received at 10:26:09.652304\n",
295-
"{\n",
296-
" \"ID\": 1,\n",
297-
" \"Type\": \"Update\",\n",
298-
" \"UpdateType\": \"Unspecified\",\n",
299-
" \"DoNotConflate\": true,\n",
300-
" \"Key\": {\n",
301-
" \"Service\": \"ELEKTRON_DD\",\n",
302-
" \"Name\": \"EUR=\"\n",
303-
" },\n",
304-
" \"SeqNumber\": 39822,\n",
305-
" \"Fields\": {\n",
306-
" \"BID\": 1.127,\n",
307-
" \"ASK\": 1.1273,\n",
308-
" \"TIMACT\": \"10:26:00\"\n",
309-
" }\n",
310-
"}\n",
311-
"----------------------------------------------------------\n",
312-
">>> Update event received at 10:26:10.001258\n",
313-
"{\n",
314-
" \"ID\": 1,\n",
315-
" \"Type\": \"Update\",\n",
316-
" \"UpdateType\": \"Unspecified\",\n",
317-
" \"DoNotConflate\": true,\n",
318-
" \"Key\": {\n",
319-
" \"Service\": \"ELEKTRON_DD\",\n",
320-
" \"Name\": \"EUR=\"\n",
321-
" },\n",
322-
" \"SeqNumber\": 39886,\n",
323-
" \"Fields\": {\n",
324-
" \"BID\": 1.1272,\n",
325-
" \"ASK\": 1.1275,\n",
326-
" \"TIMACT\": \"10:26:00\"\n",
251+
" \"BID\": 1.0585,\n",
252+
" \"ASK\": 1.0589,\n",
253+
" \"TIMACT\": \"15:51:00\"\n",
327254
" }\n",
328255
"}\n"
329256
]
@@ -345,23 +272,12 @@
345272
},
346273
{
347274
"cell_type": "code",
348-
"execution_count": 7,
275+
"execution_count": null,
349276
"metadata": {
350277
"scrolled": true,
351278
"tags": []
352279
},
353-
"outputs": [
354-
{
355-
"data": {
356-
"text/plain": [
357-
"<OpenState.Closed: 3>"
358-
]
359-
},
360-
"execution_count": 7,
361-
"metadata": {},
362-
"output_type": "execute_result"
363-
}
364-
],
280+
"outputs": [],
365281
"source": [
366282
"stream.close()"
367283
]
@@ -392,9 +308,9 @@
392308
],
393309
"metadata": {
394310
"kernelspec": {
395-
"display_name": "RevData39",
311+
"display_name": "Python 3 (ipykernel)",
396312
"language": "python",
397-
"name": "rd39"
313+
"name": "python3"
398314
},
399315
"language_info": {
400316
"codemirror_mode": {
@@ -406,7 +322,7 @@
406322
"name": "python",
407323
"nbconvert_exporter": "python",
408324
"pygments_lexer": "ipython3",
409-
"version": "3.9.4"
325+
"version": "3.9.7"
410326
}
411327
},
412328
"nbformat": 4,

‎Tutorials/3.Delivery/3.1-Streaming/TUT_3.1.02-OMMStream-MarketByPrice.ipynb‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -150,13 +150,13 @@
150150
"stream = omm_stream.Definition(name=\"VOD.L\", domain='MarketByPrice').get_stream()\n",
151151
"\n",
152152
"# Refresh - the first full imaage we get back from the server\n",
153-
"stream.on_refresh(lambda stream, event : display_event(\"Refresh\", event))\n",
153+
"stream.on_refresh(lambda event, stream : display_event(\"Refresh\", event))\n",
154154
"# Update - as and when field values change, we receive updates from the server\n",
155-
"stream.on_update(lambda stream, event : display_event(\"Update\", event))\n",
155+
"stream.on_update(lambda event, stream : display_event(\"Update\", event))\n",
156156
"# Status - if data goes stale or item closes, we get a status message\n",
157-
"stream.on_status(lambda stream, event : display_event(\"Status\", event))\n",
157+
"stream.on_status(lambda event, stream : display_event(\"Status\", event))\n",
158158
"# Other errors\n",
159-
"stream.on_error(lambda stream, event : display_event(\"Error\", event))"
159+
"stream.on_error(lambda event, stream : display_event(\"Error\", event))"
160160
]
161161
},
162162
{
@@ -1058,9 +1058,9 @@
10581058
],
10591059
"metadata": {
10601060
"kernelspec": {
1061-
"display_name": "RevData39",
1061+
"display_name": "Python 3 (ipykernel)",
10621062
"language": "python",
1063-
"name": "rd39"
1063+
"name": "python3"
10641064
},
10651065
"language_info": {
10661066
"codemirror_mode": {
@@ -1072,7 +1072,7 @@
10721072
"name": "python",
10731073
"nbconvert_exporter": "python",
10741074
"pygments_lexer": "ipython3",
1075-
"version": "3.9.4"
1075+
"version": "3.9.7"
10761076
}
10771077
},
10781078
"nbformat": 4,

0 commit comments

Comments
 (0)