Merge pull request #231 from Sharon-iguazio/master

MERGE demos/slots-stream/real-time-user-segmentation.ipynb changes from `development` to `master`
v3io · Apr 12, 2020 · d74c6d2 · d74c6d2
2 parents 8dd7536 + a93254f
commit d74c6d2
Showing 1 changed file with 1 addition and 17 deletions.
diff --git a/demos/slots-stream/real-time-user-segmentation.ipynb b/demos/slots-stream/real-time-user-segmentation.ipynb
@@ -221,23 +221,7 @@
     "# Delete the stream if it exists\n",
     "client.delete(backend=\"stream\", table=TABLE, if_missing=fpb.IGNORE)\n",
     "# Create a new stream\n",
-    "client.create(backend=\"stream\", table=TABLE, shards=SHARDS_COUNT, retention_hours=DURATION_HOURS)\n",
-    "\n",
-    "url = 'http://v3io-webapi:8081/users/' + os.getenv('V3IO_USERNAME') + '/examples/' + STREAM + '/'\n",
-    "headers = {\n",
-    "            \"Content-Type\": \"application/json\",\n",
-    "            \"X-v3io-function\": \"PutRecords\",\n",
-    "            \"X-v3io-session-key\": os.getenv('V3IO_ACCESS_KEY')\n",
-    "          }\n",
-    "\n",
-    "records = []\n",
-    "\n",
-    "def send_payload(records):\n",
-    "    if (len(records) > 0):\n",
-    "        payload = {\n",
-    "            \"Records\": records\n",
-    "        }\n",
-    "        requests.post(url, json=payload, headers=headers, verify=False)"
+    "client.create(backend=\"stream\", table=TABLE, shards=SHARDS_COUNT, retention_hours=DURATION_HOURS)"
    ]
   },
   {