Refactored asyncio functions to allow synchronous calls in Jupyter No…

…tebooks.
PrediktorAS · Aug 12, 2024 · 788beb1 · 788beb1
1 parent 579cad3
commit 788beb1
Show file tree

Hide file tree

Showing 3 changed files with 140 additions and 295 deletions.
diff --git a/notebooks/Exploring_API_Functions_Authentication.ipynb b/notebooks/Exploring_API_Functions_Authentication.ipynb
@@ -270,9 +270,9 @@
    "outputs": [],
    "source": [
     "# 1 day raw historical data\n",
-    "one_day_raw_historical_data = await opc_data.get_raw_historical_values_async(\n",
-    "    start_time = datetime.datetime(2023, 11, 13, 00, 00),\n",
-    "    end_time = datetime.datetime(2023, 11, 13, 23, 59),\n",
+    "one_day_raw_historical_data = opc_data.get_raw_historical_values(\n",
+    "    start_time = datetime.datetime(2024, 7, 13, 00, 00),\n",
+    "    end_time = datetime.datetime(2024, 7, 13, 23, 59),\n",
     "    variable_list=string_sets_for_first_park.variables_as_list([\"DCPower\"])\n",
     ")\n",
     "one_day_raw_historical_data"
@@ -285,9 +285,9 @@
    "outputs": [],
    "source": [
     "# 1 day aggregated historical data\n",
-    "one_day_historical_data = await opc_data.get_historical_aggregated_values_async(\n",
-    "    start_time = datetime.datetime(2023, 11, 13, 00, 00),\n",
-    "    end_time = datetime.datetime(2023, 11, 13, 23, 59),\n",
+    "one_day_historical_data = opc_data.get_historical_aggregated_values(\n",
+    "    start_time=(datetime.datetime.now() - datetime.timedelta(30)),\n",
+    "    end_time=(datetime.datetime.now() - datetime.timedelta(29)),\n",
     "    pro_interval=60*1000,\n",
     "    agg_name=\"Average\",\n",
     "    variable_list=string_sets_for_first_park.variables_as_list([\"DCPower\"])\n",

diff --git a/notebooks/api_performance_testing.ipynb b/notebooks/api_performance_testing.ipynb
@@ -483,7 +483,6 @@
     "                \"ReadValueIds\": variables,\n",
     "                \"AggregateName\": agg_name\n",
     "            }\n",
-    "            print(body)\n",
     "\n",
     "            for attempt in range(max_retries):\n",
     "                try:\n",
@@ -558,7 +557,7 @@
     "    agg_name=agg_name,\n",
     "    variable_list=variable_list,\n",
     "    max_data_points=10000,\n",
-    "    max_concurrent_requests=40\n",
+    "    max_concurrent_requests=35\n",
     ")\n",
     "one_day_historical_data"
    ]