|
330 | 330 | "metadata": {}, |
331 | 331 | "outputs": [], |
332 | 332 | "source": [ |
333 | | - "def _create_dummy_triple():\n", |
334 | | - " data = dict()\n", |
335 | | - " data[\"s\"] = \"http://example.com/resources/foo\"\n", |
336 | | - " data[\"p\"] = uuid.uuid4()\n", |
337 | | - " data[\"o\"] = random.randint(0, 1000)\n", |
338 | | - " return data\n", |
339 | | - "\n", |
340 | | - "data = [_create_dummy_triple(), _create_dummy_triple(), _create_dummy_triple()]\n", |
| 333 | + "def _create_dummy_triple(s: str = \"foo\"):\n", |
| 334 | + " return {\n", |
| 335 | + " \"s\": s,\n", |
| 336 | + " \"p\": str(uuid.uuid4()),\n", |
| 337 | + " \"o\": random.randint(0, 1000),\n", |
| 338 | + " }\n", |
| 339 | + "\n", |
| 340 | + "label = f\"foo_{uuid.uuid4()}\"\n", |
| 341 | + "data = [_create_dummy_triple(label), _create_dummy_triple(label), _create_dummy_triple(label)]\n", |
341 | 342 | "df = pd.DataFrame(data)\n", |
342 | 343 | "res = wr.neptune.to_rdf_graph(client, df)\n", |
343 | | - "query = \"\"\"\n", |
344 | | - " PREFIX foo: <http://example.com/resources/>\n", |
345 | | - " SELECT ?o WHERE { <foo:foo> <\" + str(data[0]['p']) + \"> ?o .}\"\"\"\n", |
| 344 | + "\n", |
| 345 | + "query = f\"SELECT ?p ?o WHERE {{ <{label}> ?p ?o .}}\"\n", |
346 | 346 | "df = wr.neptune.execute_sparql(client, query)\n", |
347 | 347 | "display(df)" |
348 | 348 | ] |
|
363 | 363 | "metadata": {}, |
364 | 364 | "outputs": [], |
365 | 365 | "source": [ |
366 | | - "def _create_dummy_quad():\n", |
367 | | - " data = _create_dummy_triple()\n", |
| 366 | + "def _create_dummy_quad(s: str):\n", |
| 367 | + " data = _create_dummy_triple(s)\n", |
368 | 368 | " data[\"g\"] = \"bar\"\n", |
369 | 369 | " return data\n", |
370 | | - " \n", |
371 | | - "data = [_create_dummy_quad(), _create_dummy_quad(), _create_dummy_quad()]\n", |
| 370 | + "\n", |
| 371 | + "label = f\"foo_{uuid.uuid4()}\"\n", |
| 372 | + "query = f\"SELECT ?p ?o FROM <bar> WHERE {{ <{label}> ?p ?o .}}\"\n", |
| 373 | + "\n", |
| 374 | + "data = [_create_dummy_quad(label), _create_dummy_quad(label), _create_dummy_quad(label)]\n", |
372 | 375 | "df = pd.DataFrame(data)\n", |
373 | 376 | "res = wr.neptune.to_rdf_graph(client, df)\n", |
374 | | - "query = \"\"\"\n", |
375 | | - " PREFIX foo: <http://example.com/resources/>\n", |
376 | | - " SELECT ?o WHERE { <foo:foo> <\" + str(data[0]['p']) + \"> ?o .}\"\"\"\n", |
377 | 377 | "df = wr.neptune.execute_sparql(client, query)\n", |
378 | 378 | "display(df)" |
379 | 379 | ] |
|
0 commit comments