quick_start/1_monitoring.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "%load_ext autoreload\n",
    "%autoreload 2"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {},
   "outputs": [
    {
     "name": "stderr",
     "output_type": "stream",
     "text": [
      "Failure while loading azureml_run_type_providers. Failed to load entrypoint automl = azureml.train.automl.run:AutoMLRun._from_run_dto with exception (azure-identity 1.9.0 (c:\\users\\janguy\\anaconda3\\envs\\dlresearch\\lib\\site-packages), Requirement.parse('azure-identity==1.7.0'), {'azureml-dataprep'}).\n",
      "Failure while loading azureml_run_type_providers. Failed to load entrypoint azureml.PipelineRun = azureml.pipeline.core.run:PipelineRun._from_dto with exception (azureml-core 1.39.0 (c:\\users\\janguy\\anaconda3\\envs\\dlresearch\\lib\\site-packages), Requirement.parse('azureml-core~=1.38.0')).\n",
      "Failure while loading azureml_run_type_providers. Failed to load entrypoint azureml.ReusedStepRun = azureml.pipeline.core.run:StepRun._from_reused_dto with exception (azureml-core 1.39.0 (c:\\users\\janguy\\anaconda3\\envs\\dlresearch\\lib\\site-packages), Requirement.parse('azureml-core~=1.38.0')).\n",
      "Failure while loading azureml_run_type_providers. Failed to load entrypoint azureml.StepRun = azureml.pipeline.core.run:StepRun._from_dto with exception (azureml-core 1.39.0 (c:\\users\\janguy\\anaconda3\\envs\\dlresearch\\lib\\site-packages), Requirement.parse('azureml-core~=1.38.0')).\n"
     ]
    }
   ],
   "source": [
    "from obs.collector import Online_Collector\n",
    "from obs.query import RT_Visualization\n",
    "from azureml.core import Workspace\n",
    "import pandas as pd\n",
    "\n",
    "ws = Workspace.from_config()\n"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Real time metrics logging and visualization\n",
    "#### You need to run this using your local computer or if you run with Azure ML Compute Instance, please do so from VSCode as Dash visualization requires access to localhost"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 9,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      ".create table streaming_test2 (['timestamp']: datetime, ['lr']: string, ['metric1']: real)\n"
     ]
    }
   ],
   "source": [
    "# Ingest streaming data  asynchronously with internal buffering mechanism to lower impact to main scoring thread\n",
    "streaming_table_name=\"streaming_test2\"\n",
    "streaming_collector = Online_Collector(streaming_table_name,ws=ws)\n",
    "\n",
    "import random\n",
    "streaming_collector.start_logging_daemon(buffer_time=2, batch_size=10)\n",
    "\n",
    "for run_id in [\"r000001\", \"r000002\", \"r000003\", \"r000004\", \"r000005\"]:\n",
    "    for i in range(200):\n",
    "        for lr in [\"0.001\", \"0.002\"]:\n",
    "            df = pd.DataFrame({ \"timestamp\":pd.to_datetime('now'), \"lr\":[lr],\"metric1\":[random.uniform(3,50)] })\n",
    "            streaming_collector.stream_collect_df_queue(df)\n",
    "# streaming_collector.stop_logging_daemon()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 16,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/html": [
       "\n",
       "        <iframe\n",
       "            width=\"100%\"\n",
       "            height=\"650\"\n",
       "            src=\"http://127.0.0.1:8050/\"\n",
       "            frameborder=\"0\"\n",
       "            allowfullscreen\n",
       "        ></iframe>\n",
       "        "
      ],
      "text/plain": [
       "<IPython.lib.display.IFrame at 0x21d1cf4b520>"
      ]
     },
     "metadata": {},
     "output_type": "display_data"
    }
   ],
   "source": [
    "from plotly.subplots import make_subplots\n",
    "rt_viz =RT_Visualization(streaming_table_name,ws)\n",
    "rt_viz.scatter(max_records=200, ago='15m',groupby='lr', y_metric='metric1',x_metric='timestamp')"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Model Monitoring"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "The deploy_model utility install AML CLI v2, create managed online endpoint, deploy the model. These steps are optional incase you want to supply your own names and objects. Check the function to see all paramters. The below just create everything."
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [],
   "source": [
    "from deployment.deploy_util import deploy_model,score_test\n",
    "\n",
    "scoring_uri, scoring_key = deploy_model(ws=ws)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "Once you have the model deployed with the collector object inside, you can just call it to simulate data creation. Data is collected to ADX table nIRIS_MODEL."
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 18,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "b'[\"virginica\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"virginica\", \"virginica\", \"virginica\", \"virginica\", \"setosa\"]'\n",
      "b'[\"setosa\", \"virginica\", \"setosa\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"versicolor\", \"setosa\", \"setosa\"]'\n",
      "b'[\"virginica\", \"setosa\", \"setosa\", \"setosa\", \"virginica\", \"versicolor\", \"versicolor\", \"virginica\", \"versicolor\", \"virginica\"]'\n",
      "b'[\"virginica\", \"virginica\", \"versicolor\", \"virginica\", \"versicolor\", \"setosa\", \"setosa\", \"versicolor\", \"virginica\", \"virginica\"]'\n",
      "b'[\"virginica\", \"virginica\", \"setosa\", \"versicolor\", \"versicolor\", \"virginica\", \"versicolor\", \"virginica\", \"versicolor\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"virginica\", \"setosa\", \"virginica\", \"setosa\", \"setosa\", \"versicolor\", \"setosa\", \"versicolor\", \"versicolor\"]'\n",
      "b'[\"virginica\", \"virginica\", \"setosa\", \"setosa\", \"versicolor\", \"versicolor\", \"setosa\", \"setosa\", \"virginica\", \"virginica\"]'\n",
      "b'[\"setosa\", \"versicolor\", \"setosa\", \"versicolor\", \"versicolor\", \"virginica\", \"versicolor\", \"setosa\", \"versicolor\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"setosa\", \"setosa\", \"versicolor\", \"virginica\", \"setosa\", \"setosa\", \"virginica\", \"virginica\", \"virginica\"]'\n",
      "b'[\"virginica\", \"versicolor\", \"setosa\", \"versicolor\", \"virginica\", \"virginica\", \"virginica\", \"virginica\", \"setosa\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"versicolor\", \"virginica\", \"versicolor\", \"virginica\", \"virginica\", \"versicolor\", \"versicolor\", \"virginica\", \"setosa\"]'\n",
      "b'[\"versicolor\", \"virginica\", \"versicolor\", \"virginica\", \"virginica\", \"setosa\", \"virginica\", \"virginica\", \"setosa\", \"virginica\"]'\n",
      "b'[\"versicolor\", \"versicolor\", \"virginica\", \"setosa\", \"versicolor\", \"virginica\", \"virginica\", \"versicolor\", \"versicolor\", \"virginica\"]'\n",
      "b'[\"setosa\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"setosa\", \"setosa\", \"versicolor\", \"virginica\", \"versicolor\"]'\n",
      "b'[\"setosa\", \"setosa\", \"virginica\", \"setosa\", \"virginica\", \"virginica\", \"virginica\", \"setosa\", \"versicolor\", \"versicolor\"]'\n",
      "b'[\"virginica\", \"setosa\", \"versicolor\", \"virginica\", \"virginica\", \"setosa\", \"setosa\", \"virginica\", \"virginica\", \"virginica\"]'\n",
      "b'[\"virginica\", \"versicolor\", \"virginica\", \"versicolor\", \"versicolor\", \"setosa\", \"virginica\", \"virginica\", \"virginica\", \"versicolor\"]'\n",
      "b'[\"setosa\", \"virginica\", \"virginica\", \"versicolor\", \"setosa\", \"versicolor\", \"versicolor\", \"versicolor\", \"virginica\", \"setosa\"]'\n",
      "b'[\"virginica\", \"virginica\", \"versicolor\", \"setosa\", \"setosa\", \"virginica\", \"virginica\", \"setosa\", \"versicolor\", \"virginica\"]'\n",
      "b'[\"virginica\", \"virginica\", \"setosa\", \"versicolor\", \"setosa\", \"virginica\", \"setosa\", \"setosa\", \"versicolor\", \"setosa\"]'\n",
      "b'[\"setosa\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"versicolor\", \"virginica\", \"virginica\", \"versicolor\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"versicolor\", \"versicolor\", \"setosa\", \"versicolor\", \"setosa\", \"setosa\", \"setosa\", \"virginica\", \"setosa\"]'\n",
      "b'[\"virginica\", \"setosa\", \"virginica\", \"setosa\", \"setosa\", \"virginica\", \"versicolor\", \"setosa\", \"versicolor\", \"virginica\"]'\n",
      "b'[\"virginica\", \"virginica\", \"setosa\", \"versicolor\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"versicolor\", \"setosa\"]'\n",
      "b'[\"setosa\", \"virginica\", \"versicolor\", \"virginica\", \"versicolor\", \"setosa\", \"versicolor\", \"virginica\", \"versicolor\", \"versicolor\"]'\n",
      "b'[\"setosa\", \"versicolor\", \"virginica\", \"setosa\", \"versicolor\", \"versicolor\", \"versicolor\", \"setosa\", \"setosa\", \"setosa\"]'\n",
      "b'[\"versicolor\", \"setosa\", \"virginica\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"setosa\", \"setosa\", \"setosa\"]'\n",
      "b'[\"setosa\", \"virginica\", \"setosa\", \"virginica\", \"virginica\", \"setosa\", \"virginica\", \"setosa\", \"virginica\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"versicolor\", \"virginica\", \"setosa\", \"versicolor\", \"versicolor\", \"versicolor\", \"virginica\", \"setosa\", \"virginica\"]'\n",
      "b'[\"setosa\", \"setosa\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"versicolor\", \"virginica\", \"virginica\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"versicolor\", \"virginica\", \"versicolor\", \"virginica\", \"versicolor\", \"setosa\", \"virginica\", \"virginica\", \"setosa\"]'\n",
      "b'[\"versicolor\", \"virginica\", \"virginica\", \"versicolor\", \"setosa\", \"setosa\", \"virginica\", \"setosa\", \"versicolor\", \"virginica\"]'\n",
      "b'[\"virginica\", \"virginica\", \"versicolor\", \"versicolor\", \"setosa\", \"virginica\", \"virginica\", \"versicolor\", \"virginica\", \"versicolor\"]'\n",
      "b'[\"versicolor\", \"virginica\", \"versicolor\", \"virginica\", \"virginica\", \"versicolor\", \"virginica\", \"versicolor\", \"virginica\", \"virginica\"]'\n"
     ]
    },
    {
     "ename": "KeyboardInterrupt",
     "evalue": "",
     "output_type": "error",
     "traceback": [
      "\u001b[1;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[1;31mKeyboardInterrupt\u001b[0m                         Traceback (most recent call last)",
      "\u001b[1;32m<ipython-input-18-91df89317985>\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m      4\u001b[0m \u001b[0mscoring_key\u001b[0m\u001b[1;33m=\u001b[0m\u001b[1;34m\"uPboOpl7zoiN5FVT2au3neWjnZCrp8oO\"\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      5\u001b[0m \u001b[1;32mfor\u001b[0m \u001b[0m_\u001b[0m \u001b[1;32min\u001b[0m \u001b[0mrange\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;36m200\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m----> 6\u001b[1;33m     \u001b[0mtime\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0msleep\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;36m3\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m      7\u001b[0m     \u001b[0mscore_test\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mscoring_uri\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mscoring_key\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;31mKeyboardInterrupt\u001b[0m: "
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\u001b[1;31m---------------------------------------------------------------------------\u001b[0m\n",
      "\u001b[1;31mConnectionResetError\u001b[0m                      Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    body=b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'},\n",
      "    retries=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    669\u001b[0m             \u001b[1;31m# Make the request on the httplib connection object.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 670\u001b[1;33m             httplib_response = self._make_request(\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._make_request\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool._make_request of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout_obj\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody\u001b[0m \u001b[1;34m= b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where timestamp> ago(15m)| sort by timestamp|take(200)\", \"properties\": \"{\\\\\"Options\\\\\": {\\\\\"norequesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip,deflate', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-ms-client-version': 'Kusto.Python.Client:3.1.2', 'x-ms-version': '2019-02-13', 'Content-Type': 'application/json; charset=utf-8', 'x-ms-client-request-id': 'KPC.execute;a04aa1b4-abb0-467b-9140-fbaaa98c6cf6', 'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsIng1dCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSIsImtpZCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSJ9.eyJhdWQiOiJodHRwczovL2t1c3RvLmt1c3RvLndpbmRvd3MubmV0IiwiaXNzIjoiaHR0cHM6Ly9zdHMud2luZG93cy5uZXQvNzJmOTg4YmYtODZmMS00MWFmLTkxYWItMmQ3Y2QwMTFkYjQ3LyIsImlhdCI6MTY1NTczMzk2NCwibmJmIjoxNjU1NzMzOTY0LCJleHAiOjE2NTU4MjA2NjQsImFpbyI6IkUyWmdZUEROWGxGeHRwVzF5RExvcjZQeDZWdW5BQT09IiwiYXBwaWQiOiJhZjg4M2FiZi04OWRkLTQ4ODktYmRiMy0xZWU4NGY2ODQ2NWUiLCJhcHBpZGFjciI6IjEiLCJpZHAiOiJodHRwczovL3N0cy53aW5kb3dzLm5ldC83MmY5ODhiZi04NmYxLTQxYWYtOTFhYi0yZDdjZDAxMWRiNDcvIiwiaWR0eXAiOiJhcHAiLCJvaWQiOiI2MWZjMmZhNy01YzYxLTQxN2YtYTIwOS1mYTBkZmZjMGI5NDgiLCJyaCI6IjAuQVFFQXY0ajVjdkdHcjBHUnF5MTgwQkhiUjNmcVJpY0NSMFZMZ01vOGwtYUE2TGNhQUFBLiIsInN1YiI6IjYxZmMyZmE3LTVjNjEtNDE3Zi1hMjA5LWZhMGRmZmMwYjk0OCIsInRpZCI6IjcyZjk4OGJmLTg2ZjEtNDFhZi05MWFiLTJkN2NkMDExZGI0NyIsInV0aSI6InU0ZDRObFJxOEVTSWVBNmVIaU5tQUEiLCJ2ZXIiOiIxLjAifQ.jEUvfS_Ee0ehGHD8DM6hneW1OQnwZKApVbGSRA_K93-HTd-6XqJYLoiIUtQkW_2RyE4s5b97AgIOOiJUXQWkISvwPrhpEx1QoaIar_ztvMsL0m6U3WqiEo0wrZrwT0clt-fZudLUJFrphEBHOrOhb7I4-dy0r_ZK0GSMXEZTn-Y_d4sZ2JCDWVdC32VEmALTpgmuJ-8_S5zsf5bcZRYbixld79eQn1KR9MDuPySyiFghb4ED1hveep_gbYInz6XC-G4kKgp3VxowhVMDR-CWKFvRdZhAJQWcbQTlKVaBZentbx0Q6C-7SPlJ5s5ScWggaEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mchunked\u001b[0m \u001b[1;34m= False\u001b[0m\n",
      "\u001b[0;32m    671\u001b[0m                 \u001b[0mconn\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    425\u001b[0m                     \u001b[1;31m# Otherwise it looks like a bug in the code.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 426\u001b[1;33m                     \u001b[0msix\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mraise_from\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36msix.raise_from\u001b[0m \u001b[1;34m= <function raise_from at 0x0000021D1758F040>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\n",
      "\u001b[0;32m    427\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[1;33m(\u001b[0m\u001b[0mSocketTimeout\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mBaseSSLError\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mSocketError\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\packages\\six.py\u001b[0m in \u001b[0;36mraise_from\u001b[1;34m(value=None, from_value=None)\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    420\u001b[0m                 \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 421\u001b[1;33m                     \u001b[0mhttplib_response\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mconn\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mgetresponse\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.getresponse\u001b[0m \u001b[1;34m= <bound method HTTPConnection.getresponse of <urllib3.connection.HTTPSConnection object at 0x0000021D1CF71280>>\u001b[0m\n",
      "\u001b[0;32m    422\u001b[0m                 \u001b[1;32mexcept\u001b[0m \u001b[0mBaseException\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mgetresponse\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1346\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1347\u001b[1;33m                 \u001b[0mresponse\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mbegin\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mresponse.begin\u001b[0m \u001b[1;34m= <bound method HTTPResponse.begin of <http.client.HTTPResponse object at 0x0000021D1B9EE580>>\u001b[0m\n",
      "\u001b[0;32m   1348\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mConnectionError\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mbegin\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    306\u001b[0m         \u001b[1;32mwhile\u001b[0m \u001b[1;32mTrue\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 307\u001b[1;33m             \u001b[0mversion\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mstatus\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mreason\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mversion\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mstatus\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mreason\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._read_status\u001b[0m \u001b[1;34m= <bound method HTTPResponse._read_status of <http.client.HTTPResponse object at 0x0000021D1B9EE580>>\u001b[0m\n",
      "\u001b[0;32m    308\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mstatus\u001b[0m \u001b[1;33m!=\u001b[0m \u001b[0mCONTINUE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36m_read_status\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    267\u001b[0m     \u001b[1;32mdef\u001b[0m \u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 268\u001b[1;33m         \u001b[0mline\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mstr\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mfp\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreadline\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0m_MAXLINE\u001b[0m \u001b[1;33m+\u001b[0m \u001b[1;36m1\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;34m\"iso-8859-1\"\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mstr\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.fp.readline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_MAXLINE\u001b[0m \u001b[1;34m= 65536\u001b[0m\n",
      "\u001b[0;32m    269\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[0mlen\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mline\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;33m>\u001b[0m \u001b[0m_MAXLINE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\socket.py\u001b[0m in \u001b[0;36mreadinto\u001b[1;34m(\n",
      "    self=<socket.SocketIO object>,\n",
      "    b=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    668\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 669\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sock\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mrecv_into\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mb\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sock.recv_into\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mb\u001b[0m \u001b[1;34m= <memory at 0x0000021D1B786580>\u001b[0m\n",
      "\u001b[0;32m    670\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mtimeout\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mrecv_into\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    buffer=<memory>,\n",
      "    nbytes=8192,\n",
      "    flags=0\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1240\u001b[0m                   self.__class__)\n",
      "\u001b[1;32m-> 1241\u001b[1;33m             \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mnbytes\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself.read\u001b[0m \u001b[1;34m= <bound method SSLSocket.read of <ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mnbytes\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1B786580>\u001b[0m\n",
      "\u001b[0;32m   1242\u001b[0m         \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mread\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    len=8192,\n",
      "    buffer=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1098\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mbuffer\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1099\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sslobj\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mlen\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sslobj.read\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mlen\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1B786580>\u001b[0m\n",
      "\u001b[0;32m   1100\u001b[0m             \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mConnectionResetError\u001b[0m: [WinError 10054] An existing connection was forcibly closed by the remote host\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mProtocolError\u001b[0m                             Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\adapters.py\u001b[0m in \u001b[0;36msend\u001b[1;34m(\n",
      "    self=<azure.kusto.data.client.HTTPAdapterWithSocketOptions object>,\n",
      "    request=<PreparedRequest [POST]>,\n",
      "    stream=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    verify=True,\n",
      "    cert=None,\n",
      "    proxies=OrderedDict()\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    438\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mchunked\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 439\u001b[1;33m                 resp = conn.urlopen(\n",
      "\u001b[0m        \u001b[0;36mresp\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.urlopen\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool.urlopen of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mmethod\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.method\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mbody\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.body\u001b[0m \u001b[1;34m= b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where timestamp> ago(15m)| sort by timestamp|take(200)\", \"properties\": \"{\\\\\"Options\\\\\": {\\\\\"norequesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mheaders\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.headers\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip,deflate', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-ms-client-version': 'Kusto.Python.Client:3.1.2', 'x-ms-version': '2019-02-13', 'Content-Type': 'application/json; charset=utf-8', 'x-ms-client-request-id': 'KPC.execute;a04aa1b4-abb0-467b-9140-fbaaa98c6cf6', 'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsIng1dCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSIsImtpZCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSJ9.eyJhdWQiOiJodHRwczovL2t1c3RvLmt1c3RvLndpbmRvd3MubmV0IiwiaXNzIjoiaHR0cHM6Ly9zdHMud2luZG93cy5uZXQvNzJmOTg4YmYtODZmMS00MWFmLTkxYWItMmQ3Y2QwMTFkYjQ3LyIsImlhdCI6MTY1NTczMzk2NCwibmJmIjoxNjU1NzMzOTY0LCJleHAiOjE2NTU4MjA2NjQsImFpbyI6IkUyWmdZUEROWGxGeHRwVzF5RExvcjZQeDZWdW5BQT09IiwiYXBwaWQiOiJhZjg4M2FiZi04OWRkLTQ4ODktYmRiMy0xZWU4NGY2ODQ2NWUiLCJhcHBpZGFjciI6IjEiLCJpZHAiOiJodHRwczovL3N0cy53aW5kb3dzLm5ldC83MmY5ODhiZi04NmYxLTQxYWYtOTFhYi0yZDdjZDAxMWRiNDcvIiwiaWR0eXAiOiJhcHAiLCJvaWQiOiI2MWZjMmZhNy01YzYxLTQxN2YtYTIwOS1mYTBkZmZjMGI5NDgiLCJyaCI6IjAuQVFFQXY0ajVjdkdHcjBHUnF5MTgwQkhiUjNmcVJpY0NSMFZMZ01vOGwtYUE2TGNhQUFBLiIsInN1YiI6IjYxZmMyZmE3LTVjNjEtNDE3Zi1hMjA5LWZhMGRmZmMwYjk0OCIsInRpZCI6IjcyZjk4OGJmLTg2ZjEtNDFhZi05MWFiLTJkN2NkMDExZGI0NyIsInV0aSI6InU0ZDRObFJxOEVTSWVBNmVIaU5tQUEiLCJ2ZXIiOiIxLjAifQ.jEUvfS_Ee0ehGHD8DM6hneW1OQnwZKApVbGSRA_K93-HTd-6XqJYLoiIUtQkW_2RyE4s5b97AgIOOiJUXQWkISvwPrhpEx1QoaIar_ztvMsL0m6U3WqiEo0wrZrwT0clt-fZudLUJFrphEBHOrOhb7I4-dy0r_ZK0GSMXEZTn-Y_d4sZ2JCDWVdC32VEmALTpgmuJ-8_S5zsf5bcZRYbixld79eQn1KR9MDuPySyiFghb4ED1hveep_gbYInz6XC-G4kKgp3VxowhVMDR-CWKFvRdZhAJQWcbQTlKVaBZentbx0Q6C-7SPlJ5s5ScWggaEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mredirect\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36massert_same_host\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mpreload_content\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mdecode_content\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mretries\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.max_retries\u001b[0m \u001b[1;34m= Retry(total=0, connect=None, read=False, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\n",
      "\u001b[0;32m    440\u001b[0m                     \u001b[0mmethod\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mrequest\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    body=b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'},\n",
      "    retries=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    725\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 726\u001b[1;33m             retries = retries.increment(\n",
      "\u001b[0m        \u001b[0;36mretries\u001b[0m \u001b[1;34m= Retry(total=0, connect=None, read=False, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mretries.increment\u001b[0m \u001b[1;34m= <bound method Retry.increment of Retry(total=0, connect=None, read=False, redirect=None, status=None)>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36merror\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_pool\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself\u001b[0m \u001b[1;34m= <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_stacktrace\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msys.exc_info\u001b[0m \u001b[1;34m= <built-in function exc_info>\u001b[0m\n",
      "\u001b[0;32m    727\u001b[0m                 \u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0murl\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merror\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_pool\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_stacktrace\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0msys\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mexc_info\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m[\u001b[0m\u001b[1;36m2\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\util\\retry.py\u001b[0m in \u001b[0;36mincrement\u001b[1;34m(\n",
      "    self=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    response=None,\n",
      "    error=ProtocolError('Connection aborted.', ConnectionR...y closed by the remote host', None, 10054, None)),\n",
      "    _pool=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    _stacktrace=<traceback object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    409\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mread\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mFalse\u001b[0m \u001b[1;32mor\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_is_method_retryable\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mmethod\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 410\u001b[1;33m                 \u001b[1;32mraise\u001b[0m \u001b[0msix\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreraise\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mtype\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0merror\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merror\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_stacktrace\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36msix.reraise\u001b[0m \u001b[1;34m= <function reraise at 0x0000021D17583F70>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mtype\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36merror\u001b[0m \u001b[1;34m= ProtocolError('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36m_stacktrace\u001b[0m \u001b[1;34m= <traceback object at 0x0000021D1E149140>\u001b[0m\n",
      "\u001b[0;32m    411\u001b[0m             \u001b[1;32melif\u001b[0m \u001b[0mread\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\packages\\six.py\u001b[0m in \u001b[0;36mreraise\u001b[1;34m(\n",
      "    tp=<class 'urllib3.exceptions.ProtocolError'>,\n",
      "    value=None,\n",
      "    tb=None\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    733\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mvalue\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m__traceback__\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mtb\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 734\u001b[1;33m                 \u001b[1;32mraise\u001b[0m \u001b[0mvalue\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mwith_traceback\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mtb\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mvalue.with_traceback\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtb\u001b[0m \u001b[1;34m= None\u001b[0m\n",
      "\u001b[0;32m    735\u001b[0m             \u001b[1;32mraise\u001b[0m \u001b[0mvalue\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    body=b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'},\n",
      "    retries=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    669\u001b[0m             \u001b[1;31m# Make the request on the httplib connection object.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 670\u001b[1;33m             httplib_response = self._make_request(\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._make_request\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool._make_request of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout_obj\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody\u001b[0m \u001b[1;34m= b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where timestamp> ago(15m)| sort by timestamp|take(200)\", \"properties\": \"{\\\\\"Options\\\\\": {\\\\\"norequesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip,deflate', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-ms-client-version': 'Kusto.Python.Client:3.1.2', 'x-ms-version': '2019-02-13', 'Content-Type': 'application/json; charset=utf-8', 'x-ms-client-request-id': 'KPC.execute;a04aa1b4-abb0-467b-9140-fbaaa98c6cf6', 'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsIng1dCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSIsImtpZCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSJ9.eyJhdWQiOiJodHRwczovL2t1c3RvLmt1c3RvLndpbmRvd3MubmV0IiwiaXNzIjoiaHR0cHM6Ly9zdHMud2luZG93cy5uZXQvNzJmOTg4YmYtODZmMS00MWFmLTkxYWItMmQ3Y2QwMTFkYjQ3LyIsImlhdCI6MTY1NTczMzk2NCwibmJmIjoxNjU1NzMzOTY0LCJleHAiOjE2NTU4MjA2NjQsImFpbyI6IkUyWmdZUEROWGxGeHRwVzF5RExvcjZQeDZWdW5BQT09IiwiYXBwaWQiOiJhZjg4M2FiZi04OWRkLTQ4ODktYmRiMy0xZWU4NGY2ODQ2NWUiLCJhcHBpZGFjciI6IjEiLCJpZHAiOiJodHRwczovL3N0cy53aW5kb3dzLm5ldC83MmY5ODhiZi04NmYxLTQxYWYtOTFhYi0yZDdjZDAxMWRiNDcvIiwiaWR0eXAiOiJhcHAiLCJvaWQiOiI2MWZjMmZhNy01YzYxLTQxN2YtYTIwOS1mYTBkZmZjMGI5NDgiLCJyaCI6IjAuQVFFQXY0ajVjdkdHcjBHUnF5MTgwQkhiUjNmcVJpY0NSMFZMZ01vOGwtYUE2TGNhQUFBLiIsInN1YiI6IjYxZmMyZmE3LTVjNjEtNDE3Zi1hMjA5LWZhMGRmZmMwYjk0OCIsInRpZCI6IjcyZjk4OGJmLTg2ZjEtNDFhZi05MWFiLTJkN2NkMDExZGI0NyIsInV0aSI6InU0ZDRObFJxOEVTSWVBNmVIaU5tQUEiLCJ2ZXIiOiIxLjAifQ.jEUvfS_Ee0ehGHD8DM6hneW1OQnwZKApVbGSRA_K93-HTd-6XqJYLoiIUtQkW_2RyE4s5b97AgIOOiJUXQWkISvwPrhpEx1QoaIar_ztvMsL0m6U3WqiEo0wrZrwT0clt-fZudLUJFrphEBHOrOhb7I4-dy0r_ZK0GSMXEZTn-Y_d4sZ2JCDWVdC32VEmALTpgmuJ-8_S5zsf5bcZRYbixld79eQn1KR9MDuPySyiFghb4ED1hveep_gbYInz6XC-G4kKgp3VxowhVMDR-CWKFvRdZhAJQWcbQTlKVaBZentbx0Q6C-7SPlJ5s5ScWggaEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mchunked\u001b[0m \u001b[1;34m= False\u001b[0m\n",
      "\u001b[0;32m    671\u001b[0m                 \u001b[0mconn\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    425\u001b[0m                     \u001b[1;31m# Otherwise it looks like a bug in the code.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 426\u001b[1;33m                     \u001b[0msix\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mraise_from\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36msix.raise_from\u001b[0m \u001b[1;34m= <function raise_from at 0x0000021D1758F040>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\n",
      "\u001b[0;32m    427\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[1;33m(\u001b[0m\u001b[0mSocketTimeout\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mBaseSSLError\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mSocketError\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\packages\\six.py\u001b[0m in \u001b[0;36mraise_from\u001b[1;34m(value=None, from_value=None)\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...aEIDpNjRRmOcYHZy2qxEmg', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    420\u001b[0m                 \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 421\u001b[1;33m                     \u001b[0mhttplib_response\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mconn\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mgetresponse\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.getresponse\u001b[0m \u001b[1;34m= <bound method HTTPConnection.getresponse of <urllib3.connection.HTTPSConnection object at 0x0000021D1CF71280>>\u001b[0m\n",
      "\u001b[0;32m    422\u001b[0m                 \u001b[1;32mexcept\u001b[0m \u001b[0mBaseException\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mgetresponse\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1346\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1347\u001b[1;33m                 \u001b[0mresponse\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mbegin\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mresponse.begin\u001b[0m \u001b[1;34m= <bound method HTTPResponse.begin of <http.client.HTTPResponse object at 0x0000021D1B9EE580>>\u001b[0m\n",
      "\u001b[0;32m   1348\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mConnectionError\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mbegin\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    306\u001b[0m         \u001b[1;32mwhile\u001b[0m \u001b[1;32mTrue\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 307\u001b[1;33m             \u001b[0mversion\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mstatus\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mreason\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mversion\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mstatus\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mreason\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._read_status\u001b[0m \u001b[1;34m= <bound method HTTPResponse._read_status of <http.client.HTTPResponse object at 0x0000021D1B9EE580>>\u001b[0m\n",
      "\u001b[0;32m    308\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mstatus\u001b[0m \u001b[1;33m!=\u001b[0m \u001b[0mCONTINUE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36m_read_status\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    267\u001b[0m     \u001b[1;32mdef\u001b[0m \u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 268\u001b[1;33m         \u001b[0mline\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mstr\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mfp\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreadline\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0m_MAXLINE\u001b[0m \u001b[1;33m+\u001b[0m \u001b[1;36m1\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;34m\"iso-8859-1\"\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mstr\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.fp.readline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_MAXLINE\u001b[0m \u001b[1;34m= 65536\u001b[0m\n",
      "\u001b[0;32m    269\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[0mlen\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mline\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;33m>\u001b[0m \u001b[0m_MAXLINE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\socket.py\u001b[0m in \u001b[0;36mreadinto\u001b[1;34m(\n",
      "    self=<socket.SocketIO object>,\n",
      "    b=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    668\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 669\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sock\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mrecv_into\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mb\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sock.recv_into\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mb\u001b[0m \u001b[1;34m= <memory at 0x0000021D1B786580>\u001b[0m\n",
      "\u001b[0;32m    670\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mtimeout\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mrecv_into\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    buffer=<memory>,\n",
      "    nbytes=8192,\n",
      "    flags=0\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1240\u001b[0m                   self.__class__)\n",
      "\u001b[1;32m-> 1241\u001b[1;33m             \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mnbytes\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself.read\u001b[0m \u001b[1;34m= <bound method SSLSocket.read of <ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mnbytes\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1B786580>\u001b[0m\n",
      "\u001b[0;32m   1242\u001b[0m         \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mread\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    len=8192,\n",
      "    buffer=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1098\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mbuffer\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1099\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sslobj\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mlen\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sslobj.read\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mlen\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1B786580>\u001b[0m\n",
      "\u001b[0;32m   1100\u001b[0m             \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mProtocolError\u001b[0m: ('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mConnectionError\u001b[0m                           Traceback (most recent call last)\n",
      "\u001b[1;31mConnectionError\u001b[0m: ('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))\n",
      "\n",
      "\u001b[1;31m---------------------------------------------------------------------------\u001b[0m\n",
      "\u001b[1;31mConnectionResetError\u001b[0m                      Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    body=b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'},\n",
      "    retries=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    669\u001b[0m             \u001b[1;31m# Make the request on the httplib connection object.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 670\u001b[1;33m             httplib_response = self._make_request(\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._make_request\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool._make_request of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout_obj\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody\u001b[0m \u001b[1;34m= b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where timestamp> ago(15m)| sort by timestamp|take(200)\", \"properties\": \"{\\\\\"Options\\\\\": {\\\\\"norequesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip,deflate', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-ms-client-version': 'Kusto.Python.Client:3.1.2', 'x-ms-version': '2019-02-13', 'Content-Type': 'application/json; charset=utf-8', 'x-ms-client-request-id': 'KPC.execute;c1ef8be3-5101-41af-9233-70140031e3d1', 'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsIng1dCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSIsImtpZCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSJ9.eyJhdWQiOiJodHRwczovL2t1c3RvLmt1c3RvLndpbmRvd3MubmV0IiwiaXNzIjoiaHR0cHM6Ly9zdHMud2luZG93cy5uZXQvNzJmOTg4YmYtODZmMS00MWFmLTkxYWItMmQ3Y2QwMTFkYjQ3LyIsImlhdCI6MTY1NTgyMjM5NywibmJmIjoxNjU1ODIyMzk3LCJleHAiOjE2NTU5MDkwOTcsImFpbyI6IkUyWmdZTmpOODlYb0xzTnZiNGI1VCtibmRGMDVBQUE9IiwiYXBwaWQiOiJhZjg4M2FiZi04OWRkLTQ4ODktYmRiMy0xZWU4NGY2ODQ2NWUiLCJhcHBpZGFjciI6IjEiLCJpZHAiOiJodHRwczovL3N0cy53aW5kb3dzLm5ldC83MmY5ODhiZi04NmYxLTQxYWYtOTFhYi0yZDdjZDAxMWRiNDcvIiwiaWR0eXAiOiJhcHAiLCJvaWQiOiI2MWZjMmZhNy01YzYxLTQxN2YtYTIwOS1mYTBkZmZjMGI5NDgiLCJyaCI6IjAuQVFFQXY0ajVjdkdHcjBHUnF5MTgwQkhiUjNmcVJpY0NSMFZMZ01vOGwtYUE2TGNhQUFBLiIsInN1YiI6IjYxZmMyZmE3LTVjNjEtNDE3Zi1hMjA5LWZhMGRmZmMwYjk0OCIsInRpZCI6IjcyZjk4OGJmLTg2ZjEtNDFhZi05MWFiLTJkN2NkMDExZGI0NyIsInV0aSI6Inc3UndSVjBNVEVxdGp0cUQ0MHlLQUEiLCJ2ZXIiOiIxLjAifQ.hRIwmHCFKK0U08RDdz4oiAK8gvMIuhnUkgsEbabw2NVojxj0sE0uHPYnu_Md6a9oJ7GmF1FlGX5HckiiGNkzQjTbSnIBAi_ntF0Qo6pgBw3sma5g-DbcUhd7dBiFxE-T2jp-fE7aYqpYrLDCczNAqEVpuMnJGXMiSJUxNz2FRDIw8bJ4BiSJBUNWFDjd9j5q4rTnDhfGHE-D2fiGES4LwoREZVIjsxSxE8a5v-nVcQ3VqjEo-bnXQACvqVJ31o3HiAe7VGt1uHj0PMW-nqMhYSw40ze9m9hbsRr6F7h1t4YZLs_pqKr65GXn2phAhhIkhHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mchunked\u001b[0m \u001b[1;34m= False\u001b[0m\n",
      "\u001b[0;32m    671\u001b[0m                 \u001b[0mconn\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    425\u001b[0m                     \u001b[1;31m# Otherwise it looks like a bug in the code.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 426\u001b[1;33m                     \u001b[0msix\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mraise_from\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36msix.raise_from\u001b[0m \u001b[1;34m= <function raise_from at 0x0000021D1758F040>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\n",
      "\u001b[0;32m    427\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[1;33m(\u001b[0m\u001b[0mSocketTimeout\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mBaseSSLError\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mSocketError\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\packages\\six.py\u001b[0m in \u001b[0;36mraise_from\u001b[1;34m(value=None, from_value=None)\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    420\u001b[0m                 \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 421\u001b[1;33m                     \u001b[0mhttplib_response\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mconn\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mgetresponse\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.getresponse\u001b[0m \u001b[1;34m= <bound method HTTPConnection.getresponse of <urllib3.connection.HTTPSConnection object at 0x0000021D1B971100>>\u001b[0m\n",
      "\u001b[0;32m    422\u001b[0m                 \u001b[1;32mexcept\u001b[0m \u001b[0mBaseException\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mgetresponse\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1346\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1347\u001b[1;33m                 \u001b[0mresponse\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mbegin\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mresponse.begin\u001b[0m \u001b[1;34m= <bound method HTTPResponse.begin of <http.client.HTTPResponse object at 0x0000021D1B9112B0>>\u001b[0m\n",
      "\u001b[0;32m   1348\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mConnectionError\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mbegin\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    306\u001b[0m         \u001b[1;32mwhile\u001b[0m \u001b[1;32mTrue\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 307\u001b[1;33m             \u001b[0mversion\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mstatus\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mreason\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mversion\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mstatus\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mreason\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._read_status\u001b[0m \u001b[1;34m= <bound method HTTPResponse._read_status of <http.client.HTTPResponse object at 0x0000021D1B9112B0>>\u001b[0m\n",
      "\u001b[0;32m    308\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mstatus\u001b[0m \u001b[1;33m!=\u001b[0m \u001b[0mCONTINUE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36m_read_status\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    267\u001b[0m     \u001b[1;32mdef\u001b[0m \u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 268\u001b[1;33m         \u001b[0mline\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mstr\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mfp\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreadline\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0m_MAXLINE\u001b[0m \u001b[1;33m+\u001b[0m \u001b[1;36m1\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;34m\"iso-8859-1\"\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mstr\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.fp.readline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_MAXLINE\u001b[0m \u001b[1;34m= 65536\u001b[0m\n",
      "\u001b[0;32m    269\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[0mlen\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mline\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;33m>\u001b[0m \u001b[0m_MAXLINE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\socket.py\u001b[0m in \u001b[0;36mreadinto\u001b[1;34m(\n",
      "    self=<socket.SocketIO object>,\n",
      "    b=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    668\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 669\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sock\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mrecv_into\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mb\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sock.recv_into\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mb\u001b[0m \u001b[1;34m= <memory at 0x0000021D1CEF3280>\u001b[0m\n",
      "\u001b[0;32m    670\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mtimeout\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mrecv_into\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    buffer=<memory>,\n",
      "    nbytes=8192,\n",
      "    flags=0\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1240\u001b[0m                   self.__class__)\n",
      "\u001b[1;32m-> 1241\u001b[1;33m             \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mnbytes\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself.read\u001b[0m \u001b[1;34m= <bound method SSLSocket.read of <ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mnbytes\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1CEF3280>\u001b[0m\n",
      "\u001b[0;32m   1242\u001b[0m         \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mread\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    len=8192,\n",
      "    buffer=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1098\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mbuffer\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1099\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sslobj\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mlen\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sslobj.read\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mlen\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1CEF3280>\u001b[0m\n",
      "\u001b[0;32m   1100\u001b[0m             \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mConnectionResetError\u001b[0m: [WinError 10054] An existing connection was forcibly closed by the remote host\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mProtocolError\u001b[0m                             Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\adapters.py\u001b[0m in \u001b[0;36msend\u001b[1;34m(\n",
      "    self=<azure.kusto.data.client.HTTPAdapterWithSocketOptions object>,\n",
      "    request=<PreparedRequest [POST]>,\n",
      "    stream=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    verify=True,\n",
      "    cert=None,\n",
      "    proxies=OrderedDict()\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    438\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mchunked\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 439\u001b[1;33m                 resp = conn.urlopen(\n",
      "\u001b[0m        \u001b[0;36mresp\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.urlopen\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool.urlopen of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mmethod\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.method\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mbody\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.body\u001b[0m \u001b[1;34m= b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where timestamp> ago(15m)| sort by timestamp|take(200)\", \"properties\": \"{\\\\\"Options\\\\\": {\\\\\"norequesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mheaders\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.headers\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip,deflate', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-ms-client-version': 'Kusto.Python.Client:3.1.2', 'x-ms-version': '2019-02-13', 'Content-Type': 'application/json; charset=utf-8', 'x-ms-client-request-id': 'KPC.execute;c1ef8be3-5101-41af-9233-70140031e3d1', 'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsIng1dCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSIsImtpZCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSJ9.eyJhdWQiOiJodHRwczovL2t1c3RvLmt1c3RvLndpbmRvd3MubmV0IiwiaXNzIjoiaHR0cHM6Ly9zdHMud2luZG93cy5uZXQvNzJmOTg4YmYtODZmMS00MWFmLTkxYWItMmQ3Y2QwMTFkYjQ3LyIsImlhdCI6MTY1NTgyMjM5NywibmJmIjoxNjU1ODIyMzk3LCJleHAiOjE2NTU5MDkwOTcsImFpbyI6IkUyWmdZTmpOODlYb0xzTnZiNGI1VCtibmRGMDVBQUE9IiwiYXBwaWQiOiJhZjg4M2FiZi04OWRkLTQ4ODktYmRiMy0xZWU4NGY2ODQ2NWUiLCJhcHBpZGFjciI6IjEiLCJpZHAiOiJodHRwczovL3N0cy53aW5kb3dzLm5ldC83MmY5ODhiZi04NmYxLTQxYWYtOTFhYi0yZDdjZDAxMWRiNDcvIiwiaWR0eXAiOiJhcHAiLCJvaWQiOiI2MWZjMmZhNy01YzYxLTQxN2YtYTIwOS1mYTBkZmZjMGI5NDgiLCJyaCI6IjAuQVFFQXY0ajVjdkdHcjBHUnF5MTgwQkhiUjNmcVJpY0NSMFZMZ01vOGwtYUE2TGNhQUFBLiIsInN1YiI6IjYxZmMyZmE3LTVjNjEtNDE3Zi1hMjA5LWZhMGRmZmMwYjk0OCIsInRpZCI6IjcyZjk4OGJmLTg2ZjEtNDFhZi05MWFiLTJkN2NkMDExZGI0NyIsInV0aSI6Inc3UndSVjBNVEVxdGp0cUQ0MHlLQUEiLCJ2ZXIiOiIxLjAifQ.hRIwmHCFKK0U08RDdz4oiAK8gvMIuhnUkgsEbabw2NVojxj0sE0uHPYnu_Md6a9oJ7GmF1FlGX5HckiiGNkzQjTbSnIBAi_ntF0Qo6pgBw3sma5g-DbcUhd7dBiFxE-T2jp-fE7aYqpYrLDCczNAqEVpuMnJGXMiSJUxNz2FRDIw8bJ4BiSJBUNWFDjd9j5q4rTnDhfGHE-D2fiGES4LwoREZVIjsxSxE8a5v-nVcQ3VqjEo-bnXQACvqVJ31o3HiAe7VGt1uHj0PMW-nqMhYSw40ze9m9hbsRr6F7h1t4YZLs_pqKr65GXn2phAhhIkhHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mredirect\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36massert_same_host\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mpreload_content\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mdecode_content\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mretries\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.max_retries\u001b[0m \u001b[1;34m= Retry(total=0, connect=None, read=False, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\n",
      "\u001b[0;32m    440\u001b[0m                     \u001b[0mmethod\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mrequest\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    body=b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'},\n",
      "    retries=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    725\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 726\u001b[1;33m             retries = retries.increment(\n",
      "\u001b[0m        \u001b[0;36mretries\u001b[0m \u001b[1;34m= Retry(total=0, connect=None, read=False, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mretries.increment\u001b[0m \u001b[1;34m= <bound method Retry.increment of Retry(total=0, connect=None, read=False, redirect=None, status=None)>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36merror\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_pool\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself\u001b[0m \u001b[1;34m= <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_stacktrace\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msys.exc_info\u001b[0m \u001b[1;34m= <built-in function exc_info>\u001b[0m\n",
      "\u001b[0;32m    727\u001b[0m                 \u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0murl\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merror\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_pool\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_stacktrace\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0msys\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mexc_info\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m[\u001b[0m\u001b[1;36m2\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\util\\retry.py\u001b[0m in \u001b[0;36mincrement\u001b[1;34m(\n",
      "    self=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    response=None,\n",
      "    error=ProtocolError('Connection aborted.', ConnectionR...y closed by the remote host', None, 10054, None)),\n",
      "    _pool=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    _stacktrace=<traceback object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    409\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mread\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mFalse\u001b[0m \u001b[1;32mor\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_is_method_retryable\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mmethod\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 410\u001b[1;33m                 \u001b[1;32mraise\u001b[0m \u001b[0msix\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreraise\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mtype\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0merror\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merror\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_stacktrace\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36msix.reraise\u001b[0m \u001b[1;34m= <function reraise at 0x0000021D17583F70>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mtype\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36merror\u001b[0m \u001b[1;34m= ProtocolError('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36m_stacktrace\u001b[0m \u001b[1;34m= <traceback object at 0x0000021D1B8F8740>\u001b[0m\n",
      "\u001b[0;32m    411\u001b[0m             \u001b[1;32melif\u001b[0m \u001b[0mread\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\packages\\six.py\u001b[0m in \u001b[0;36mreraise\u001b[1;34m(\n",
      "    tp=<class 'urllib3.exceptions.ProtocolError'>,\n",
      "    value=None,\n",
      "    tb=None\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    733\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mvalue\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m__traceback__\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mtb\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 734\u001b[1;33m                 \u001b[1;32mraise\u001b[0m \u001b[0mvalue\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mwith_traceback\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mtb\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mvalue.with_traceback\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtb\u001b[0m \u001b[1;34m= None\u001b[0m\n",
      "\u001b[0;32m    735\u001b[0m             \u001b[1;32mraise\u001b[0m \u001b[0mvalue\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    body=b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'},\n",
      "    retries=Retry(total=0, connect=None, read=False, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    669\u001b[0m             \u001b[1;31m# Make the request on the httplib connection object.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 670\u001b[1;33m             httplib_response = self._make_request(\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._make_request\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool._make_request of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71850>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/v2/rest/query'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout_obj\u001b[0m \u001b[1;34m= Timeout(connect=3630, read=3630, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody\u001b[0m \u001b[1;34m= b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where timestamp> ago(15m)| sort by timestamp|take(200)\", \"properties\": \"{\\\\\"Options\\\\\": {\\\\\"norequesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip,deflate', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-ms-client-version': 'Kusto.Python.Client:3.1.2', 'x-ms-version': '2019-02-13', 'Content-Type': 'application/json; charset=utf-8', 'x-ms-client-request-id': 'KPC.execute;c1ef8be3-5101-41af-9233-70140031e3d1', 'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJSUzI1NiIsIng1dCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSIsImtpZCI6IjJaUXBKM1VwYmpBWVhZR2FYRUpsOGxWMFRPSSJ9.eyJhdWQiOiJodHRwczovL2t1c3RvLmt1c3RvLndpbmRvd3MubmV0IiwiaXNzIjoiaHR0cHM6Ly9zdHMud2luZG93cy5uZXQvNzJmOTg4YmYtODZmMS00MWFmLTkxYWItMmQ3Y2QwMTFkYjQ3LyIsImlhdCI6MTY1NTgyMjM5NywibmJmIjoxNjU1ODIyMzk3LCJleHAiOjE2NTU5MDkwOTcsImFpbyI6IkUyWmdZTmpOODlYb0xzTnZiNGI1VCtibmRGMDVBQUE9IiwiYXBwaWQiOiJhZjg4M2FiZi04OWRkLTQ4ODktYmRiMy0xZWU4NGY2ODQ2NWUiLCJhcHBpZGFjciI6IjEiLCJpZHAiOiJodHRwczovL3N0cy53aW5kb3dzLm5ldC83MmY5ODhiZi04NmYxLTQxYWYtOTFhYi0yZDdjZDAxMWRiNDcvIiwiaWR0eXAiOiJhcHAiLCJvaWQiOiI2MWZjMmZhNy01YzYxLTQxN2YtYTIwOS1mYTBkZmZjMGI5NDgiLCJyaCI6IjAuQVFFQXY0ajVjdkdHcjBHUnF5MTgwQkhiUjNmcVJpY0NSMFZMZ01vOGwtYUE2TGNhQUFBLiIsInN1YiI6IjYxZmMyZmE3LTVjNjEtNDE3Zi1hMjA5LWZhMGRmZmMwYjk0OCIsInRpZCI6IjcyZjk4OGJmLTg2ZjEtNDFhZi05MWFiLTJkN2NkMDExZGI0NyIsInV0aSI6Inc3UndSVjBNVEVxdGp0cUQ0MHlLQUEiLCJ2ZXIiOiIxLjAifQ.hRIwmHCFKK0U08RDdz4oiAK8gvMIuhnUkgsEbabw2NVojxj0sE0uHPYnu_Md6a9oJ7GmF1FlGX5HckiiGNkzQjTbSnIBAi_ntF0Qo6pgBw3sma5g-DbcUhd7dBiFxE-T2jp-fE7aYqpYrLDCczNAqEVpuMnJGXMiSJUxNz2FRDIw8bJ4BiSJBUNWFDjd9j5q4rTnDhfGHE-D2fiGES4LwoREZVIjsxSxE8a5v-nVcQ3VqjEo-bnXQACvqVJ31o3HiAe7VGt1uHj0PMW-nqMhYSw40ze9m9hbsRr6F7h1t4YZLs_pqKr65GXn2phAhhIkhHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mchunked\u001b[0m \u001b[1;34m= False\u001b[0m\n",
      "\u001b[0;32m    671\u001b[0m                 \u001b[0mconn\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    425\u001b[0m                     \u001b[1;31m# Otherwise it looks like a bug in the code.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 426\u001b[1;33m                     \u001b[0msix\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mraise_from\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36msix.raise_from\u001b[0m \u001b[1;34m= <function raise_from at 0x0000021D1758F040>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\n",
      "\u001b[0;32m    427\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[1;33m(\u001b[0m\u001b[0mSocketTimeout\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mBaseSSLError\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mSocketError\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\packages\\six.py\u001b[0m in \u001b[0;36mraise_from\u001b[1;34m(value=None, from_value=None)\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/v2/rest/query',\n",
      "    timeout=Timeout(connect=3630, read=3630, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': b'{\"db\": \"db01\", \"csl\": \"streaming_test2|where t...equesttimeout\\\\\": true}, \\\\\"Parameters\\\\\": {}}\"}', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...hHtfsbTv0WLBRXDSp5r5yQ', 'Content-Length': '176'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    420\u001b[0m                 \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 421\u001b[1;33m                     \u001b[0mhttplib_response\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mconn\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mgetresponse\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.getresponse\u001b[0m \u001b[1;34m= <bound method HTTPConnection.getresponse of <urllib3.connection.HTTPSConnection object at 0x0000021D1B971100>>\u001b[0m\n",
      "\u001b[0;32m    422\u001b[0m                 \u001b[1;32mexcept\u001b[0m \u001b[0mBaseException\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mgetresponse\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1346\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1347\u001b[1;33m                 \u001b[0mresponse\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mbegin\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mresponse.begin\u001b[0m \u001b[1;34m= <bound method HTTPResponse.begin of <http.client.HTTPResponse object at 0x0000021D1B9112B0>>\u001b[0m\n",
      "\u001b[0;32m   1348\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mConnectionError\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36mbegin\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    306\u001b[0m         \u001b[1;32mwhile\u001b[0m \u001b[1;32mTrue\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 307\u001b[1;33m             \u001b[0mversion\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mstatus\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mreason\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mversion\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mstatus\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mreason\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._read_status\u001b[0m \u001b[1;34m= <bound method HTTPResponse._read_status of <http.client.HTTPResponse object at 0x0000021D1B9112B0>>\u001b[0m\n",
      "\u001b[0;32m    308\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mstatus\u001b[0m \u001b[1;33m!=\u001b[0m \u001b[0mCONTINUE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\http\\client.py\u001b[0m in \u001b[0;36m_read_status\u001b[1;34m(\n",
      "    self=<http.client.HTTPResponse object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    267\u001b[0m     \u001b[1;32mdef\u001b[0m \u001b[0m_read_status\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 268\u001b[1;33m         \u001b[0mline\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mstr\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mfp\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreadline\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0m_MAXLINE\u001b[0m \u001b[1;33m+\u001b[0m \u001b[1;36m1\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;34m\"iso-8859-1\"\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mstr\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.fp.readline\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_MAXLINE\u001b[0m \u001b[1;34m= 65536\u001b[0m\n",
      "\u001b[0;32m    269\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[0mlen\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mline\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;33m>\u001b[0m \u001b[0m_MAXLINE\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\socket.py\u001b[0m in \u001b[0;36mreadinto\u001b[1;34m(\n",
      "    self=<socket.SocketIO object>,\n",
      "    b=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    668\u001b[0m             \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 669\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sock\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mrecv_into\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mb\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sock.recv_into\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mb\u001b[0m \u001b[1;34m= <memory at 0x0000021D1CEF3280>\u001b[0m\n",
      "\u001b[0;32m    670\u001b[0m             \u001b[1;32mexcept\u001b[0m \u001b[0mtimeout\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mrecv_into\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    buffer=<memory>,\n",
      "    nbytes=8192,\n",
      "    flags=0\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1240\u001b[0m                   self.__class__)\n",
      "\u001b[1;32m-> 1241\u001b[1;33m             \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mnbytes\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself.read\u001b[0m \u001b[1;34m= <bound method SSLSocket.read of <ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mnbytes\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1CEF3280>\u001b[0m\n",
      "\u001b[0;32m   1242\u001b[0m         \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\ssl.py\u001b[0m in \u001b[0;36mread\u001b[1;34m(\n",
      "    self=<ssl.SSLSocket [closed] fd=-1, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0>,\n",
      "    len=8192,\n",
      "    buffer=<memory>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1098\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[0mbuffer\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1099\u001b[1;33m                 \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_sslobj\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mread\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mlen\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mbuffer\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._sslobj.read\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mlen\u001b[0m \u001b[1;34m= 8192\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbuffer\u001b[0m \u001b[1;34m= <memory at 0x0000021D1CEF3280>\u001b[0m\n",
      "\u001b[0;32m   1100\u001b[0m             \u001b[1;32melse\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mProtocolError\u001b[0m: ('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mConnectionError\u001b[0m                           Traceback (most recent call last)\n",
      "\u001b[1;31mConnectionError\u001b[0m: ('Connection aborted.', ConnectionResetError(10054, 'An existing connection was forcibly closed by the remote host', None, 10054, None))\n",
      "\n",
      "\u001b[1;31m---------------------------------------------------------------------------\u001b[0m\n",
      "\u001b[1;31mgaierror\u001b[0m                                  Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connection.py\u001b[0m in \u001b[0;36m_new_conn\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    158\u001b[0m         \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 159\u001b[1;33m             conn = connection.create_connection(\n",
      "\u001b[0m        \u001b[0;36mconn\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mconnection.create_connection\u001b[0m \u001b[1;34m= <function create_connection at 0x0000021D17590A60>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._dns_host\u001b[0m \u001b[1;34m= 'login.microsoftonline.com'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.port\u001b[0m \u001b[1;34m= 443\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.timeout\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mextra_kw\u001b[0m \u001b[1;34m= {'socket_options': [(6, 1, 1)]}\u001b[0m\n",
      "\u001b[0;32m    160\u001b[0m                 \u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_dns_host\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mport\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mtimeout\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mextra_kw\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\util\\connection.py\u001b[0m in \u001b[0;36mcreate_connection\u001b[1;34m(\n",
      "    address=('login.microsoftonline.com', 443),\n",
      "    timeout=None,\n",
      "    source_address=None,\n",
      "    socket_options=[(6, 1, 1)]\n",
      ")\u001b[0m\n",
      "\u001b[0;32m     60\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m---> 61\u001b[1;33m     \u001b[1;32mfor\u001b[0m \u001b[0mres\u001b[0m \u001b[1;32min\u001b[0m \u001b[0msocket\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mgetaddrinfo\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mhost\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mport\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mfamily\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0msocket\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mSOCK_STREAM\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mres\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msocket.getaddrinfo\u001b[0m \u001b[1;34m= <function getaddrinfo at 0x0000021D0589B5E0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mhost\u001b[0m \u001b[1;34m= 'login.microsoftonline.com'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mport\u001b[0m \u001b[1;34m= 443\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mfamily\u001b[0m \u001b[1;34m= <AddressFamily.AF_UNSPEC: 0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msocket.SOCK_STREAM\u001b[0m \u001b[1;34m= <SocketKind.SOCK_STREAM: 1>\u001b[0m\n",
      "\u001b[0;32m     62\u001b[0m         \u001b[0maf\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0msocktype\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mproto\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mcanonname\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0msa\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mres\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\socket.py\u001b[0m in \u001b[0;36mgetaddrinfo\u001b[1;34m(\n",
      "    host='login.microsoftonline.com',\n",
      "    port=443,\n",
      "    family=<AddressFamily.AF_UNSPEC: 0>,\n",
      "    type=<SocketKind.SOCK_STREAM: 1>,\n",
      "    proto=0,\n",
      "    flags=0\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    917\u001b[0m     \u001b[0maddrlist\u001b[0m \u001b[1;33m=\u001b[0m \u001b[1;33m[\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 918\u001b[1;33m     \u001b[1;32mfor\u001b[0m \u001b[0mres\u001b[0m \u001b[1;32min\u001b[0m \u001b[0m_socket\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mgetaddrinfo\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mhost\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mport\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mfamily\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mtype\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mproto\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mflags\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mres\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_socket.getaddrinfo\u001b[0m \u001b[1;34m= <built-in function getaddrinfo>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mhost\u001b[0m \u001b[1;34m= 'login.microsoftonline.com'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mport\u001b[0m \u001b[1;34m= 443\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mfamily\u001b[0m \u001b[1;34m= <AddressFamily.AF_UNSPEC: 0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtype\u001b[0m \u001b[1;34m= <SocketKind.SOCK_STREAM: 1>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mproto\u001b[0m \u001b[1;34m= 0\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mflags\u001b[0m \u001b[1;34m= 0\u001b[0m\n",
      "\u001b[0;32m    919\u001b[0m         \u001b[0maf\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0msocktype\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mproto\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mcanonname\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0msa\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mres\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mgaierror\u001b[0m: [Errno 11001] getaddrinfo failed\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mNewConnectionError\u001b[0m                        Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    body='client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&g...=https%3A%2F%2Fkusto.kusto.windows.net%2F.default',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...ntent-Type': 'application/x-www-form-urlencoded'},\n",
      "    retries=Retry(total=0, connect=None, read=None, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=None, read=None, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    669\u001b[0m             \u001b[1;31m# Make the request on the httplib connection object.\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 670\u001b[1;33m             httplib_response = self._make_request(\n",
      "\u001b[0m        \u001b[0;36mhttplib_response\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._make_request\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool._make_request of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71EE0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=None, read=None, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout_obj\u001b[0m \u001b[1;34m= Timeout(connect=None, read=None, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody\u001b[0m \u001b[1;34m= 'client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&grant_type=client_credentials&client_info=1&client_secret=wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg&scope=https%3A%2F%2Fkusto.kusto.windows.net%2F.default'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip, deflate, br', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'Cookie': 'esctx=AQABAAAAAAD--DLA3VO7QrddgJg7Wevrnujt5j_FOB4oRSHknMyX7J6GFIE3edbb9G2hS1pB6sc3MlRSA4U3KwWIvUYnzNZA5Kg07P7_Cs1Aef__zfk3eCmZTxYR65gXP7IxzA8jK2LB-tJMBrKa_o5JHhXqkElV7u3diRnpyjFSYzZPu_afV6kAJSy1md2HOiKhw8O2fuEgAA; fpc=AkwleLwuLZ1Bl2dDeUDup0aWzle4AQAAAGnQQ9oOAAAA; stsservicecookie=estsfd; x-ms-gateway-slice=estsfd', 'Content-Length': '200', 'Content-Type': 'application/x-www-form-urlencoded'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mchunked\u001b[0m \u001b[1;34m= False\u001b[0m\n",
      "\u001b[0;32m    671\u001b[0m                 \u001b[0mconn\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_make_request\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>,\n",
      "    method='POST',\n",
      "    url='/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    timeout=Timeout(connect=None, read=None, total=None),\n",
      "    chunked=False,\n",
      "    **httplib_request_kw={'body': 'client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&g...=https%3A%2F%2Fkusto.kusto.windows.net%2F.default', 'headers': {'User-Agent': 'python-requests/2.26.0', 'Accept...ntent-Type': 'application/x-www-form-urlencoded'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    380\u001b[0m         \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 381\u001b[1;33m             \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_validate_conn\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mconn\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._validate_conn\u001b[0m \u001b[1;34m= <bound method HTTPSConnectionPool._validate_conn of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71EE0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn\u001b[0m \u001b[1;34m= <urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>\u001b[0m\n",
      "\u001b[0;32m    382\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[1;33m(\u001b[0m\u001b[0mSocketTimeout\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mBaseSSLError\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36m_validate_conn\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    conn=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    977\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mgetattr\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mconn\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;34m\"sock\"\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m  \u001b[1;31m# AppEngine might not have  `.sock`\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 978\u001b[1;33m             \u001b[0mconn\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mconnect\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mconn.connect\u001b[0m \u001b[1;34m= <bound method HTTPSConnection.connect of <urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>>\u001b[0m\n",
      "\u001b[0;32m    979\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connection.py\u001b[0m in \u001b[0;36mconnect\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    308\u001b[0m         \u001b[1;31m# Add certificate verification\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 309\u001b[1;33m         \u001b[0mconn\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_new_conn\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mconn\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._new_conn\u001b[0m \u001b[1;34m= <bound method HTTPConnection._new_conn of <urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>>\u001b[0m\n",
      "\u001b[0;32m    310\u001b[0m         \u001b[0mhostname\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mhost\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connection.py\u001b[0m in \u001b[0;36m_new_conn\u001b[1;34m(\n",
      "    self=<urllib3.connection.HTTPSConnection object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    170\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[0mSocketError\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 171\u001b[1;33m             raise NewConnectionError(\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36mNewConnectionError\u001b[0m \u001b[1;34m= <class 'urllib3.exceptions.NewConnectionError'>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself\u001b[0m \u001b[1;34m= <urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\n",
      "\u001b[0;32m    172\u001b[0m                 \u001b[0mself\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;34m\"Failed to establish a new connection: %s\"\u001b[0m \u001b[1;33m%\u001b[0m \u001b[0me\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mNewConnectionError\u001b[0m: <urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>: Failed to establish a new connection: [Errno 11001] getaddrinfo failed\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mMaxRetryError\u001b[0m                             Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\adapters.py\u001b[0m in \u001b[0;36msend\u001b[1;34m(\n",
      "    self=<requests.adapters.HTTPAdapter object>,\n",
      "    request=<PreparedRequest [POST]>,\n",
      "    stream=False,\n",
      "    timeout=Timeout(connect=None, read=None, total=None),\n",
      "    verify=True,\n",
      "    cert=None,\n",
      "    proxies={}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    438\u001b[0m             \u001b[1;32mif\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[0mchunked\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 439\u001b[1;33m                 resp = conn.urlopen(\n",
      "\u001b[0m        \u001b[0;36mresp\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mconn.urlopen\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool.urlopen of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71EE0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mmethod\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.method\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mbody\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.body\u001b[0m \u001b[1;34m= 'client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&grant_type=client_credentials&client_info=1&client_secret=wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg&scope=https%3A%2F%2Fkusto.kusto.windows.net%2F.default'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mheaders\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest.headers\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip, deflate, br', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'Cookie': 'esctx=AQABAAAAAAD--DLA3VO7QrddgJg7Wevrnujt5j_FOB4oRSHknMyX7J6GFIE3edbb9G2hS1pB6sc3MlRSA4U3KwWIvUYnzNZA5Kg07P7_Cs1Aef__zfk3eCmZTxYR65gXP7IxzA8jK2LB-tJMBrKa_o5JHhXqkElV7u3diRnpyjFSYzZPu_afV6kAJSy1md2HOiKhw8O2fuEgAA; fpc=AkwleLwuLZ1Bl2dDeUDup0aWzle4AQAAAGnQQ9oOAAAA; stsservicecookie=estsfd; x-ms-gateway-slice=estsfd', 'Content-Length': '200', 'Content-Type': 'application/x-www-form-urlencoded'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mredirect\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36massert_same_host\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mpreload_content\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mdecode_content\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mretries\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.max_retries\u001b[0m \u001b[1;34m= Retry(total=1, connect=None, read=None, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=None, read=None, total=None)\u001b[0m\n",
      "\u001b[0;32m    440\u001b[0m                     \u001b[0mmethod\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mrequest\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    body='client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&g...=https%3A%2F%2Fkusto.kusto.windows.net%2F.default',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...ntent-Type': 'application/x-www-form-urlencoded'},\n",
      "    retries=Retry(total=0, connect=None, read=None, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=None, read=None, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    753\u001b[0m             )\n",
      "\u001b[1;32m--> 754\u001b[1;33m             return self.urlopen(\n",
      "\u001b[0m        \u001b[0;36mself.urlopen\u001b[0m \u001b[1;34m= <bound method HTTPConnectionPool.urlopen of <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71EE0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody\u001b[0m \u001b[1;34m= 'client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&grant_type=client_credentials&client_info=1&client_secret=wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg&scope=https%3A%2F%2Fkusto.kusto.windows.net%2F.default'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'User-Agent': 'python-requests/2.26.0', 'Accept-Encoding': 'gzip, deflate, br', 'Accept': 'application/json', 'Connection': 'keep-alive', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'Cookie': 'esctx=AQABAAAAAAD--DLA3VO7QrddgJg7Wevrnujt5j_FOB4oRSHknMyX7J6GFIE3edbb9G2hS1pB6sc3MlRSA4U3KwWIvUYnzNZA5Kg07P7_Cs1Aef__zfk3eCmZTxYR65gXP7IxzA8jK2LB-tJMBrKa_o5JHhXqkElV7u3diRnpyjFSYzZPu_afV6kAJSy1md2HOiKhw8O2fuEgAA; fpc=AkwleLwuLZ1Bl2dDeUDup0aWzle4AQAAAGnQQ9oOAAAA; stsservicecookie=estsfd; x-ms-gateway-slice=estsfd', 'Content-Length': '200', 'Content-Type': 'application/x-www-form-urlencoded'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mretries\u001b[0m \u001b[1;34m= Retry(total=0, connect=None, read=None, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mredirect\u001b[0m \u001b[1;34m= False\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36massert_same_host\u001b[0m \u001b[1;34m= False\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtimeout\u001b[0m \u001b[1;34m= Timeout(connect=None, read=None, total=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mpool_timeout\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrelease_conn\u001b[0m \u001b[1;34m= False\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mchunked\u001b[0m \u001b[1;34m= False\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mbody_pos\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mresponse_kw\u001b[0m \u001b[1;34m= {'preload_content': False, 'decode_content': False}\u001b[0m\n",
      "\u001b[0;32m    755\u001b[0m                 \u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\connectionpool.py\u001b[0m in \u001b[0;36murlopen\u001b[1;34m(\n",
      "    self=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    method='POST',\n",
      "    url='/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    body='client_id=af883abf-89dd-4889-bdb3-1ee84f68465e&g...=https%3A%2F%2Fkusto.kusto.windows.net%2F.default',\n",
      "    headers={'User-Agent': 'python-requests/2.26.0', 'Accept...ntent-Type': 'application/x-www-form-urlencoded'},\n",
      "    retries=Retry(total=0, connect=None, read=None, redirect=None, status=None),\n",
      "    redirect=False,\n",
      "    assert_same_host=False,\n",
      "    timeout=Timeout(connect=None, read=None, total=None),\n",
      "    pool_timeout=None,\n",
      "    release_conn=False,\n",
      "    chunked=False,\n",
      "    body_pos=None,\n",
      "    **response_kw={'decode_content': False, 'preload_content': False}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    725\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 726\u001b[1;33m             retries = retries.increment(\n",
      "\u001b[0m        \u001b[0;36mretries\u001b[0m \u001b[1;34m= Retry(total=0, connect=None, read=None, redirect=None, status=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mretries.increment\u001b[0m \u001b[1;34m= <bound method Retry.increment of Retry(total=0, connect=None, read=None, redirect=None, status=None)>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mmethod\u001b[0m \u001b[1;34m= 'POST'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36merror\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_pool\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself\u001b[0m \u001b[1;34m= <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71EE0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_stacktrace\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msys.exc_info\u001b[0m \u001b[1;34m= <built-in function exc_info>\u001b[0m\n",
      "\u001b[0;32m    727\u001b[0m                 \u001b[0mmethod\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0murl\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merror\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_pool\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0m_stacktrace\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0msys\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mexc_info\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m[\u001b[0m\u001b[1;36m2\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\urllib3\\util\\retry.py\u001b[0m in \u001b[0;36mincrement\u001b[1;34m(\n",
      "    self=Retry(total=0, connect=None, read=None, redirect=None, status=None),\n",
      "    method='POST',\n",
      "    url='/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    response=None,\n",
      "    error=NewConnectionError('<urllib3.connection.HTTPSCon...ew connection: [Errno 11001] getaddrinfo failed'),\n",
      "    _pool=<urllib3.connectionpool.HTTPSConnectionPool object>,\n",
      "    _stacktrace=<traceback object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    445\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[0mnew_retry\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mis_exhausted\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 446\u001b[1;33m             \u001b[1;32mraise\u001b[0m \u001b[0mMaxRetryError\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0m_pool\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0murl\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merror\u001b[0m \u001b[1;32mor\u001b[0m \u001b[0mResponseError\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mcause\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36mMaxRetryError\u001b[0m \u001b[1;34m= <class 'urllib3.exceptions.MaxRetryError'>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36m_pool\u001b[0m \u001b[1;34m= <urllib3.connectionpool.HTTPSConnectionPool object at 0x0000021D1CF71EE0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= '/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36merror\u001b[0m \u001b[1;34m= NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>: Failed to establish a new connection: [Errno 11001] getaddrinfo failed')\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mResponseError\u001b[0m \u001b[1;34m= <class 'urllib3.exceptions.ResponseError'>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mcause\u001b[0m \u001b[1;34m= 'unknown'\u001b[0m\n",
      "\u001b[0;32m    447\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mMaxRetryError\u001b[0m: HTTPSConnectionPool(host='login.microsoftonline.com', port=443): Max retries exceeded with url: /72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token (Caused by NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>: Failed to establish a new connection: [Errno 11001] getaddrinfo failed'))\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mConnectionError\u001b[0m                           Traceback (most recent call last)\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\azure\\kusto\\data\\security.py\u001b[0m in \u001b[0;36macquire_authorization_header\u001b[1;34m(\n",
      "    self=<azure.kusto.data.security._AadHelper object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m     67\u001b[0m         \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m---> 68\u001b[1;33m             \u001b[1;32mreturn\u001b[0m \u001b[0m_get_header_from_dict\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mtoken_provider\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mget_token\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36m_get_header_from_dict\u001b[0m \u001b[1;34m= <function _get_header_from_dict at 0x0000021D17541EE0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.token_provider.get_token\u001b[0m \u001b[1;34m= <bound method TokenProviderBase.get_token of <azure.kusto.data._token_providers.ApplicationKeyTokenProvider object at 0x0000021D1CFA4640>>\u001b[0m\n",
      "\u001b[0;32m     69\u001b[0m         \u001b[1;32mexcept\u001b[0m \u001b[0mException\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0merror\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\azure\\kusto\\data\\_token_providers.py\u001b[0m in \u001b[0;36mget_token\u001b[1;34m(\n",
      "    self=<azure.kusto.data._token_providers.ApplicationKeyTokenProvider object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    122\u001b[0m             \u001b[1;32mwith\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_lock\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 123\u001b[1;33m                 \u001b[0mtoken\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_get_token_impl\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mtoken\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._get_token_impl\u001b[0m \u001b[1;34m= <bound method ApplicationKeyTokenProvider._get_token_impl of <azure.kusto.data._token_providers.ApplicationKeyTokenProvider object at 0x0000021D1CFA4640>>\u001b[0m\n",
      "\u001b[0;32m    124\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\azure\\kusto\\data\\_token_providers.py\u001b[0m in \u001b[0;36m_get_token_impl\u001b[1;34m(\n",
      "    self=<azure.kusto.data._token_providers.ApplicationKeyTokenProvider object>\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    552\u001b[0m     \u001b[1;32mdef\u001b[0m \u001b[0m_get_token_impl\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m)\u001b[0m \u001b[1;33m->\u001b[0m \u001b[0mOptional\u001b[0m\u001b[1;33m[\u001b[0m\u001b[0mdict\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 553\u001b[1;33m         \u001b[0mtoken\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_msal_client\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0macquire_token_for_client\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mscopes\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_scopes\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mtoken\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._msal_client.acquire_token_for_client\u001b[0m \u001b[1;34m= <bound method ConfidentialClientApplication.acquire_token_for_client of <msal.application.ConfidentialClientApplication object at 0x0000021D1CF20AF0>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mscopes\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._scopes\u001b[0m \u001b[1;34m= ['https://kusto.kusto.windows.net/.default']\u001b[0m\n",
      "\u001b[0;32m    554\u001b[0m         \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_valid_token_or_throw\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mtoken\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\application.py\u001b[0m in \u001b[0;36macquire_token_for_client\u001b[1;34m(\n",
      "    self=<msal.application.ConfidentialClientApplication object>,\n",
      "    scopes=['https://kusto.kusto.windows.net/.default'],\n",
      "    claims_challenge=None,\n",
      "    **kwargs={}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m   1588\u001b[0m         \u001b[0mclient\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_regional_client\u001b[0m \u001b[1;32mor\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mclient\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m-> 1589\u001b[1;33m         response = _clean_up(client.obtain_token_for_client(\n",
      "\u001b[0m        \u001b[0;36mresponse\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_clean_up\u001b[0m \u001b[1;34m= <function _clean_up at 0x0000021D17A823A0>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mclient.obtain_token_for_client\u001b[0m \u001b[1;34m= <bound method Client.obtain_token_for_client of <msal.application._ClientWithCcsRoutingInfo object at 0x0000021D1CF62610>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mscope\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mscopes\u001b[0m \u001b[1;34m= ['https://kusto.kusto.windows.net/.default']\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mheaders\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mtelemetry_context.generate_headers\u001b[0m \u001b[1;34m= <bound method _TelemetryContext.generate_headers of <msal.telemetry._TelemetryContext object at 0x0000021D1BB03A30>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mdata\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mdict\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs.pop\u001b[0m \u001b[1;34m= <built-in method pop of dict object at 0x0000021D1CDF1C80>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mclaims\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36m_merge_claims_challenge_and_capabilities\u001b[0m \u001b[1;34m= <function _merge_claims_challenge_and_capabilities at 0x0000021D17A7C670>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._client_capabilities\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mclaims_challenge\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {}\u001b[0m\n",
      "\u001b[0;32m   1590\u001b[0m             \u001b[0mscope\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mscopes\u001b[0m\u001b[1;33m,\u001b[0m  \u001b[1;31m# This grant flow requires no scope decoration\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\oauth2cli\\oauth2.py\u001b[0m in \u001b[0;36mobtain_token_for_client\u001b[1;34m(\n",
      "    self=<msal.application._ClientWithCcsRoutingInfo object>,\n",
      "    scope=['https://kusto.kusto.windows.net/.default'],\n",
      "    **kwargs={'headers': {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    734\u001b[0m         \u001b[0mdata\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mupdate\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mscope\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mscope\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 735\u001b[1;33m         \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_obtain_token\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;34m\"client_credentials\"\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mdata\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mdata\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself._obtain_token\u001b[0m \u001b[1;34m= <bound method Client._obtain_token of <msal.application._ClientWithCcsRoutingInfo object at 0x0000021D1CF62610>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mdata\u001b[0m \u001b[1;34m= {'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'headers': {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}}\u001b[0m\n",
      "\u001b[0;32m    736\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\oauth2cli\\oidc.py\u001b[0m in \u001b[0;36m_obtain_token\u001b[1;34m(\n",
      "    self=<msal.application._ClientWithCcsRoutingInfo object>,\n",
      "    grant_type='client_credentials',\n",
      "    *args=(),\n",
      "    **kwargs={'data': {'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']}, 'headers': {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    114\u001b[0m         \"\"\"\n",
      "\u001b[1;32m--> 115\u001b[1;33m         \u001b[0mret\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0msuper\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mClient\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_obtain_token\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mgrant_type\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m*\u001b[0m\u001b[0margs\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mret\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msuper\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mClient\u001b[0m \u001b[1;34m= <class 'msal.oauth2cli.oidc.Client'>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._obtain_token\u001b[0m \u001b[1;34m= <bound method Client._obtain_token of <msal.application._ClientWithCcsRoutingInfo object at 0x0000021D1CF62610>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mgrant_type\u001b[0m \u001b[1;34m= 'client_credentials'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36margs\u001b[0m \u001b[1;34m= ()\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'data': {'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']}, 'headers': {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}}\u001b[0m\n",
      "\u001b[0;32m    116\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[1;34m\"id_token\"\u001b[0m \u001b[1;32min\u001b[0m \u001b[0mret\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\oauth2cli\\oauth2.py\u001b[0m in \u001b[0;36m_obtain_token\u001b[1;34m(\n",
      "    self=<msal.application._ClientWithCcsRoutingInfo object>,\n",
      "    grant_type='client_credentials',\n",
      "    params=None,\n",
      "    data={'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']},\n",
      "    also_save_rt=False,\n",
      "    on_obtaining_tokens=None,\n",
      "    *args=(),\n",
      "    **kwargs={'headers': {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    753\u001b[0m         \u001b[0m_data\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mdata\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcopy\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m)\u001b[0m  \u001b[1;31m# to prevent side effect\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 754\u001b[1;33m         resp = super(Client, self)._obtain_token(\n",
      "\u001b[0m        \u001b[0;36mresp\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36msuper\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mClient\u001b[0m \u001b[1;34m= <class 'msal.oauth2cli.oauth2.Client'>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._obtain_token\u001b[0m \u001b[1;34m= <bound method Client._obtain_token of <msal.application._ClientWithCcsRoutingInfo object at 0x0000021D1CF62610>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mgrant_type\u001b[0m \u001b[1;34m= 'client_credentials'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mparams\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36m_data\u001b[0m \u001b[1;34m= {'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36margs\u001b[0m \u001b[1;34m= ()\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'headers': {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}}\u001b[0m\n",
      "\u001b[0;32m    755\u001b[0m             grant_type, params, _data, *args, **kwargs)\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\oauth2cli\\oauth2.py\u001b[0m in \u001b[0;36m_obtain_token\u001b[1;34m(\n",
      "    self=<msal.application._ClientWithCcsRoutingInfo object>,\n",
      "    grant_type='client_credentials',\n",
      "    params=None,\n",
      "    data={'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']},\n",
      "    headers={'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'},\n",
      "    post=None,\n",
      "    **kwargs={}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    234\u001b[0m             \u001b[1;32mraise\u001b[0m \u001b[0mValueError\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;34m\"token_endpoint not found in configuration\"\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 235\u001b[1;33m         resp = (post or self._http_client.post)(\n",
      "\u001b[0m        \u001b[0;36mresp\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mpost\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself._http_client.post\u001b[0m \u001b[1;34m= <function Session.post at 0x0000021D1B6E2280>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.configuration\u001b[0m \u001b[1;34m= {'authorization_endpoint': 'https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/authorize', 'token_endpoint': 'https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token', 'device_authorization_endpoint': 'https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/devicecode'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mheaders\u001b[0m \u001b[1;34m= {'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36m_headers\u001b[0m \u001b[1;34m= {'Accept': 'application/json', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mparams\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mdata\u001b[0m \u001b[1;34m= {'claims': None, 'scope': ['https://kusto.kusto.windows.net/.default']}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36m_data\u001b[0m \u001b[1;34m= {'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'grant_type': 'client_credentials', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'scope': 'https://kusto.kusto.windows.net/.default'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {}\u001b[0m\n",
      "\u001b[0;32m    236\u001b[0m             \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mconfiguration\u001b[0m\u001b[1;33m[\u001b[0m\u001b[1;34m\"token_endpoint\"\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\individual_cache.py\u001b[0m in \u001b[0;36mwrapper\u001b[1;34m(\n",
      "    *args=('https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',),\n",
      "    **kwargs={'data': {'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'grant_type': 'client_credentials', 'scope': 'https://kusto.kusto.windows.net/.default'}, 'headers': {'Accept': 'application/json', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-cpu': 'x64', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'x-client-os': 'win32', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-ms-lib-capability': 'retry-after, h429'}, 'params': None}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    268\u001b[0m                 \u001b[1;32mpass\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 269\u001b[1;33m             \u001b[0mvalue\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mfunction\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m*\u001b[0m\u001b[0margs\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mvalue\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mfunction\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36margs\u001b[0m \u001b[1;34m= ('https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'headers': {'Accept': 'application/json', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}, 'params': None, 'data': {'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'grant_type': 'client_credentials', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'scope': 'https://kusto.kusto.windows.net/.default'}}\u001b[0m\n",
      "\u001b[0;32m    270\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\msal\\individual_cache.py\u001b[0m in \u001b[0;36mwrapper\u001b[1;34m(\n",
      "    *args=('https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',),\n",
      "    **kwargs={'data': {'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'grant_type': 'client_credentials', 'scope': 'https://kusto.kusto.windows.net/.default'}, 'headers': {'Accept': 'application/json', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-cpu': 'x64', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'x-client-os': 'win32', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-ms-lib-capability': 'retry-after, h429'}, 'params': None}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    268\u001b[0m                 \u001b[1;32mpass\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 269\u001b[1;33m             \u001b[0mvalue\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mfunction\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;33m*\u001b[0m\u001b[0margs\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mvalue\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[1;36mglobal\u001b[0m \u001b[0;36mfunction\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36margs\u001b[0m \u001b[1;34m= ('https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'headers': {'Accept': 'application/json', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}, 'params': None, 'data': {'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'grant_type': 'client_credentials', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'scope': 'https://kusto.kusto.windows.net/.default'}}\u001b[0m\n",
      "\u001b[0;32m    270\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\sessions.py\u001b[0m in \u001b[0;36mpost\u001b[1;34m(\n",
      "    self=<requests.sessions.Session object>,\n",
      "    url='https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    data={'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'grant_type': 'client_credentials', 'scope': 'https://kusto.kusto.windows.net/.default'},\n",
      "    json=None,\n",
      "    **kwargs={'headers': {'Accept': 'application/json', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-cpu': 'x64', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'x-client-os': 'win32', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-ms-lib-capability': 'retry-after, h429'}, 'params': None}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    589\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 590\u001b[1;33m         \u001b[1;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mrequest\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;34m'POST'\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0murl\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mdata\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mdata\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mjson\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mjson\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mself.request\u001b[0m \u001b[1;34m= functools.partial(<bound method Session.request of <requests.sessions.Session object at 0x0000021D1CF12610>>, timeout=None)\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36murl\u001b[0m \u001b[1;34m= 'https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token'\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mdata\u001b[0m \u001b[1;34m= {'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'grant_type': 'client_credentials', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'scope': 'https://kusto.kusto.windows.net/.default'}\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mjson\u001b[0m \u001b[1;34m= None\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'headers': {'Accept': 'application/json', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-client-os': 'win32', 'x-client-cpu': 'x64', 'x-ms-lib-capability': 'retry-after, h429', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||'}, 'params': None}\u001b[0m\n",
      "\u001b[0;32m    591\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\sessions.py\u001b[0m in \u001b[0;36mrequest\u001b[1;34m(\n",
      "    self=<requests.sessions.Session object>,\n",
      "    method='POST',\n",
      "    url='https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token',\n",
      "    params=None,\n",
      "    data={'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'client_info': 1, 'client_secret': 'wJN8Q~pJX-SZoetNbPb1rUbETrJ0lYW.UYeCbaVg', 'grant_type': 'client_credentials', 'scope': 'https://kusto.kusto.windows.net/.default'},\n",
      "    headers={'Accept': 'application/json', 'client-request-id': '9af2eb4a-b7f5-4275-bf1b-1794afaa4173', 'x-client-cpu': 'x64', 'x-client-current-telemetry': '4|730,0|', 'x-client-last-telemetry': '4|84|||', 'x-client-os': 'win32', 'x-client-sku': 'MSAL.Python', 'x-client-ver': '1.15.0', 'x-ms-lib-capability': 'retry-after, h429'},\n",
      "    cookies=None,\n",
      "    files=None,\n",
      "    auth=None,\n",
      "    timeout=None,\n",
      "    allow_redirects=True,\n",
      "    proxies={},\n",
      "    hooks=None,\n",
      "    stream=None,\n",
      "    verify=None,\n",
      "    cert=None,\n",
      "    json=None\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    541\u001b[0m         \u001b[0msend_kwargs\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mupdate\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0msettings\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 542\u001b[1;33m         \u001b[0mresp\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mself\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0msend\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mprep\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0msend_kwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mresp\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mself.send\u001b[0m \u001b[1;34m= <bound method Session.send of <requests.sessions.Session object at 0x0000021D1CF12610>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mprep\u001b[0m \u001b[1;34m= <PreparedRequest [POST]>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36msend_kwargs\u001b[0m \u001b[1;34m= {'timeout': None, 'allow_redirects': True, 'verify': True, 'proxies': {}, 'stream': False, 'cert': None}\u001b[0m\n",
      "\u001b[0;32m    543\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\sessions.py\u001b[0m in \u001b[0;36msend\u001b[1;34m(\n",
      "    self=<requests.sessions.Session object>,\n",
      "    request=<PreparedRequest [POST]>,\n",
      "    **kwargs={'cert': None, 'proxies': {}, 'stream': False, 'timeout': None, 'verify': True}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    654\u001b[0m         \u001b[1;31m# Send the request\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 655\u001b[1;33m         \u001b[0mr\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0madapter\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0msend\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mrequest\u001b[0m\u001b[1;33m,\u001b[0m \u001b[1;33m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[0;36mr\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36madapter.send\u001b[0m \u001b[1;34m= <bound method HTTPAdapter.send of <requests.adapters.HTTPAdapter object at 0x0000021D1CF62910>>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest\u001b[0m \u001b[1;34m= <PreparedRequest [POST]>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mkwargs\u001b[0m \u001b[1;34m= {'timeout': None, 'verify': True, 'proxies': {}, 'stream': False, 'cert': None}\u001b[0m\n",
      "\u001b[0;32m    656\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;32mc:\\Users\\janguy\\Anaconda3\\envs\\dlresearch\\lib\\site-packages\\requests\\adapters.py\u001b[0m in \u001b[0;36msend\u001b[1;34m(\n",
      "    self=<requests.adapters.HTTPAdapter object>,\n",
      "    request=<PreparedRequest [POST]>,\n",
      "    stream=False,\n",
      "    timeout=Timeout(connect=None, read=None, total=None),\n",
      "    verify=True,\n",
      "    cert=None,\n",
      "    proxies={}\n",
      ")\u001b[0m\n",
      "\u001b[0;32m    515\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32m--> 516\u001b[1;33m             \u001b[1;32mraise\u001b[0m \u001b[0mConnectionError\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0me\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mrequest\u001b[0m\u001b[1;33m=\u001b[0m\u001b[0mrequest\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[0m        \u001b[1;36mglobal\u001b[0m \u001b[0;36mConnectionError\u001b[0m \u001b[1;34m= <class 'requests.exceptions.ConnectionError'>\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36me\u001b[0m \u001b[1;34m= \u001b[1;36mundefined\u001b[0m\u001b[0m\u001b[1;34m\n",
      "        \u001b[0m\u001b[0;36mrequest\u001b[0m \u001b[1;34m= <PreparedRequest [POST]>\u001b[0m\n",
      "\u001b[0;32m    517\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\n",
      "\u001b[1;31mConnectionError\u001b[0m: HTTPSConnectionPool(host='login.microsoftonline.com', port=443): Max retries exceeded with url: /72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token (Caused by NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>: Failed to establish a new connection: [Errno 11001] getaddrinfo failed'))\n",
      "\n",
      "During handling of the above exception, another exception occurred:\n",
      "\n",
      "\u001b[1;31mKustoAuthenticationError\u001b[0m                  Traceback (most recent call last)\n",
      "\u001b[1;31mKustoAuthenticationError\u001b[0m: KustoAuthenticationError('ApplicationKeyTokenProvider', 'ConnectionError(MaxRetryError(\"HTTPSConnectionPool(host='login.microsoftonline.com', port=443): Max retries exceeded with url: /72f988bf-86f1-41af-91ab-2d7cd011db47/oauth2/v2.0/token (Caused by NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x0000021D1CF2E820>: Failed to establish a new connection: [Errno 11001] getaddrinfo failed'))\"))', '{'authority': 'https://login.microsoftonline.com/72f988bf-86f1-41af-91ab-2d7cd011db47', 'client_id': 'af883abf-89dd-4889-bdb3-1ee84f68465e', 'kusto_uri': 'https://adx02.westus2.kusto.windows.net'}')\n",
      "\n"
     ]
    }
   ],
   "source": [
    "import time\n",
    "#If you run this without running deployment, the look up scoring_uri and scoring key from Azure ML Studio\n",
    "scoring_uri= \"\"\n",
    "scoring_key=\"\"\n",
    "for _ in range(200):\n",
    "    time.sleep(3)\n",
    "    score_test(scoring_uri, scoring_key)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "### Monitoring Dashboard"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "\n",
    "Review https://docs.microsoft.com/en-us/azure/data-explorer/azure-data-explorer-dashboards#to-create-new-dashboard-from-a-file for instruction on how to import the dashboard.\n"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "Go to ADX Dashboard and import the quick_start/ADX_dashboards/databoard_Model_Monitoring.json to create a monitoring dashboard for your model.\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": [
    "# from obs import KV_ADX_URI, KV_ADX_DB\n",
    "# for dashboard_file in [\"ADX dashboards/dashboard-drift_detection.json\", \"ADX dashboards/dashboard-Model_Monitoring.json\"]:\n",
    "#     with open(dashboard_file, \"r+\") as temp_file:\n",
    "#         dashboard_content = temp_file.readlines()\n",
    "#         dashboard_content= dashboard_content[0]\n",
    "#         kv = ws.get_default_keyvault()\n",
    "#         cluster_uri = kv.get_secret(KV_ADX_URI)\n",
    "#         cluster_db = kv.get_secret(KV_ADX_DB)\n",
    "#         dashboard_content.replace(\"db01\", cluster_db)\n",
    "#         dashboard_content.replace(\"https://adx02.westus2.kusto.windows.net\", cluster_uri)\n",
    "#         temp_file.write(dashboard_content)"
   ]
  }
 ],
 "metadata": {
  "interpreter": {
   "hash": "8858a4df92b06e9052bc306608e3218c33233584bc6448961c72d65ba55843de"
  },
  "kernelspec": {
   "display_name": "Python 3.8.5 ('dlresearch')",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.8.5"
  },
  "orig_nbformat": 4
 },
 "nbformat": 4,
 "nbformat_minor": 2
}