Skip to content

Commit a93254f

Browse files
MERGE demos/slots-stream/real-time-user-segmentation.ipynb changes from development to master
1 parent 8dd7536 commit a93254f

File tree

1 file changed

+1
-17
lines changed

1 file changed

+1
-17
lines changed

demos/slots-stream/real-time-user-segmentation.ipynb

Lines changed: 1 addition & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -221,23 +221,7 @@
221221
"# Delete the stream if it exists\n",
222222
"client.delete(backend=\"stream\", table=TABLE, if_missing=fpb.IGNORE)\n",
223223
"# Create a new stream\n",
224-
"client.create(backend=\"stream\", table=TABLE, shards=SHARDS_COUNT, retention_hours=DURATION_HOURS)\n",
225-
"\n",
226-
"url = 'http://v3io-webapi:8081/users/' + os.getenv('V3IO_USERNAME') + '/examples/' + STREAM + '/'\n",
227-
"headers = {\n",
228-
" \"Content-Type\": \"application/json\",\n",
229-
" \"X-v3io-function\": \"PutRecords\",\n",
230-
" \"X-v3io-session-key\": os.getenv('V3IO_ACCESS_KEY')\n",
231-
" }\n",
232-
"\n",
233-
"records = []\n",
234-
"\n",
235-
"def send_payload(records):\n",
236-
" if (len(records) > 0):\n",
237-
" payload = {\n",
238-
" \"Records\": records\n",
239-
" }\n",
240-
" requests.post(url, json=payload, headers=headers, verify=False)"
224+
"client.create(backend=\"stream\", table=TABLE, shards=SHARDS_COUNT, retention_hours=DURATION_HOURS)"
241225
]
242226
},
243227
{

0 commit comments

Comments
 (0)