|
20 | 20 | "from datashield import DSSession, DSLoginBuilder, DSError\n", |
21 | 21 | "import pandas as pd\n", |
22 | 22 | "\n", |
23 | | - "url = 'https://opal-demo.obiba.org'\n", |
24 | | - "builder = DSLoginBuilder().add('server1', url, 'dsuser', 'P@ssw0rd').add('server2', url, 'dsuser', 'P@ssw0rd')\n", |
| 23 | + "url = \"https://opal-demo.obiba.org\"\n", |
| 24 | + "builder = DSLoginBuilder().add(\"server1\", url, \"dsuser\", \"P@ssw0rd\").add(\"server2\", url, \"dsuser\", \"P@ssw0rd\")\n", |
25 | 25 | "logins = builder.build()\n", |
26 | 26 | "\n", |
27 | 27 | "session = DSSession(logins)\n", |
|
143 | 143 | ], |
144 | 144 | "source": [ |
145 | 145 | "pkgs = session.packages()\n", |
146 | | - "pd.DataFrame.from_records(pkgs['server1'])" |
| 146 | + "pd.DataFrame.from_records(pkgs[\"server1\"])" |
147 | 147 | ] |
148 | 148 | }, |
149 | 149 | { |
|
297 | 297 | } |
298 | 298 | ], |
299 | 299 | "source": [ |
300 | | - "methods = session.methods(type='aggregate')\n", |
301 | | - "pd.DataFrame.from_records(methods['server1'])" |
| 300 | + "methods = session.methods(type=\"aggregate\")\n", |
| 301 | + "pd.DataFrame.from_records(methods[\"server1\"])" |
302 | 302 | ] |
303 | 303 | }, |
304 | 304 | { |
|
386 | 386 | "metadata": {}, |
387 | 387 | "outputs": [], |
388 | 388 | "source": [ |
389 | | - "#session.resources()" |
| 389 | + "# session.resources()" |
390 | 390 | ] |
391 | 391 | }, |
392 | 392 | { |
|
415 | 415 | } |
416 | 416 | ], |
417 | 417 | "source": [ |
418 | | - "session.assign_resource('client', resources = { 'server1': 'RSRC.CNSIM1', 'server2': 'RSRC.CNSIM1' })\n", |
| 418 | + "session.assign_resource(\"client\", resources={\"server1\": \"RSRC.CNSIM1\", \"server2\": \"RSRC.CNSIM1\"})\n", |
419 | 419 | "session.ls()" |
420 | 420 | ] |
421 | 421 | }, |
|
459 | 459 | } |
460 | 460 | ], |
461 | 461 | "source": [ |
462 | | - "session.assign_expr('df', 'as.resource.data.frame(client, strict = TRUE)')\n", |
| 462 | + "session.assign_expr(\"df\", \"as.resource.data.frame(client, strict = TRUE)\")\n", |
463 | 463 | "session.ls()" |
464 | 464 | ] |
465 | 465 | }, |
|
555 | 555 | } |
556 | 556 | ], |
557 | 557 | "source": [ |
558 | | - "session.aggregate('meanDS(df$LAB_GLUC_ADJUSTED)')" |
| 558 | + "session.aggregate(\"meanDS(df$LAB_GLUC_ADJUSTED)\")" |
559 | 559 | ] |
560 | 560 | }, |
561 | 561 | { |
|
576 | 576 | } |
577 | 577 | ], |
578 | 578 | "source": [ |
579 | | - "session.assign_table('df2', tables = { 'server1': 'CNSIM.CNSIM1', 'server2': 'CNSIM.CNSIM2' })\n", |
| 579 | + "session.assign_table(\"df2\", tables={\"server1\": \"CNSIM.CNSIM1\", \"server2\": \"CNSIM.CNSIM2\"})\n", |
580 | 580 | "session.ls()" |
581 | 581 | ] |
582 | 582 | }, |
|
1038 | 1038 | ], |
1039 | 1039 | "source": [ |
1040 | 1040 | "numints = 20\n", |
1041 | | - "densityGrid = session.aggregate(f'densityGridDS(df2$LAB_TSC, df2$LAB_HDL, limits=FALSE, x.min=NULL, x.max=NULL, y.min=NULL, y.max=NULL, numints = {numints})')\n", |
1042 | | - "densityGrid['server1']" |
| 1041 | + "densityGrid = session.aggregate(\n", |
| 1042 | + " f\"densityGridDS(df2$LAB_TSC, df2$LAB_HDL, limits=FALSE, x.min=NULL, x.max=NULL, y.min=NULL, y.max=NULL, numints = {numints})\"\n", |
| 1043 | + ")\n", |
| 1044 | + "densityGrid[\"server1\"]" |
1043 | 1045 | ] |
1044 | 1046 | }, |
1045 | 1047 | { |
|
1061 | 1063 | ], |
1062 | 1064 | "source": [ |
1063 | 1065 | "import matplotlib.pyplot as plt\n", |
1064 | | - "plt.imshow(densityGrid['server1'], aspect='auto')\n", |
1065 | | - "plt.title( \"2-D Heat Map (server 1)\" )\n", |
| 1066 | + "\n", |
| 1067 | + "plt.imshow(densityGrid[\"server1\"], aspect=\"auto\")\n", |
| 1068 | + "plt.title(\"2-D Heat Map (server 1)\")\n", |
1066 | 1069 | "plt.show()" |
1067 | 1070 | ] |
1068 | 1071 | }, |
|
1184 | 1187 | } |
1185 | 1188 | ], |
1186 | 1189 | "source": [ |
1187 | | - "data = session.aggregate('histogramDS2(df2$LAB_GLUC_ADJUSTED, num.breaks=20, min=0, max=20, method.indicator=1, k=3, noise=0.25)')\n", |
1188 | | - "data['server1']" |
| 1190 | + "data = session.aggregate(\n", |
| 1191 | + " \"histogramDS2(df2$LAB_GLUC_ADJUSTED, num.breaks=20, min=0, max=20, method.indicator=1, k=3, noise=0.25)\"\n", |
| 1192 | + ")\n", |
| 1193 | + "data[\"server1\"]" |
1189 | 1194 | ] |
1190 | 1195 | }, |
1191 | 1196 | { |
|
1206 | 1211 | } |
1207 | 1212 | ], |
1208 | 1213 | "source": [ |
1209 | | - "breaks = data['server1']['value'][0]['value'][0]['value']\n", |
1210 | | - "counts = data['server1']['value'][0]['value'][1]['value']\n", |
| 1214 | + "breaks = data[\"server1\"][\"value\"][0][\"value\"][0][\"value\"]\n", |
| 1215 | + "counts = data[\"server1\"][\"value\"][0][\"value\"][1][\"value\"]\n", |
1211 | 1216 | "\n", |
1212 | | - "plt.bar(breaks[1:], counts, width=1, edgecolor='black', linewidth=0.5, color='lightgrey')\n", |
1213 | | - "plt.xlabel('LAB_GLUC_ADJUSTED')\n", |
1214 | | - "plt.ylabel('Frequency')\n", |
1215 | | - "plt.title('Histogram (server 1)')\n", |
| 1217 | + "plt.bar(breaks[1:], counts, width=1, edgecolor=\"black\", linewidth=0.5, color=\"lightgrey\")\n", |
| 1218 | + "plt.xlabel(\"LAB_GLUC_ADJUSTED\")\n", |
| 1219 | + "plt.ylabel(\"Frequency\")\n", |
| 1220 | + "plt.title(\"Histogram (server 1)\")\n", |
1216 | 1221 | "plt.show()" |
1217 | 1222 | ] |
1218 | 1223 | }, |
|
1236 | 1241 | ], |
1237 | 1242 | "source": [ |
1238 | 1243 | "try:\n", |
1239 | | - " session.aggregate('heatmapPlotDS(df2$LAB_TSC, df2$LAB_HDL, 3, 0.25, \"xxx\")')\n", |
1240 | | - "except DSError as e:\n", |
1241 | | - " print(session.get_errors()['server1'])\n", |
1242 | | - " print(session.get_errors()['server1'].is_client_error())\n", |
1243 | | - " print(session.get_errors()['server1'].is_server_error())" |
| 1244 | + " session.aggregate('heatmapPlotDS(df2$LAB_TSC, df2$LAB_HDL, 3, 0.25, \"xxx\")')\n", |
| 1245 | + "except DSError:\n", |
| 1246 | + " print(session.get_errors()[\"server1\"])\n", |
| 1247 | + " print(session.get_errors()[\"server1\"].is_client_error())\n", |
| 1248 | + " print(session.get_errors()[\"server1\"].is_server_error())" |
1244 | 1249 | ] |
1245 | 1250 | }, |
1246 | 1251 | { |
|
0 commit comments