Utilizzo di Python per connettersi a un'istanza database Neptune

Per connettersi a Neptune tramite Python

1. Installare il pacchetto gremlinpython immettendo quanto segue:

   pip install --user gremlinpython

2. Creare un file denominato gremlinexample.py, quindi aprirlo in un editor di testo.

3. Copiare quanto segue nel file gremlinexample.py. Sostituiscilo your-neptune-endpoint con l'indirizzo del tuo cluster Neptune DB e your-neptune-port con la porta del tuo cluster Neptune DB (impostazione predefinita: 8182).

   Per informazioni su come trovare l'indirizzo dell'istanza database Neptune, consulta la sezione Connessione agli endpoint Amazon Neptune.

   L'esempio seguente mostra come connettersi con Gremlin Python.

   import boto3
   import os
   from botocore.auth import SigV4Auth
   from botocore.awsrequest import AWSRequest
   from gremlin_python.driver.driver_remote_connection import DriverRemoteConnection
   from gremlin_python.process.anonymous_traversal import traversal
   
   database_url = "wss://your-neptune-endpoint:your-neptune-port/gremlin"
   
   remoteConn = DriverRemoteConnection(database_url, "g")
   
   g = traversal().withRemote(remoteConn)
   
   print(g.inject(1).toList())
   remoteConn.close()

4. Immettere il comando seguente per eseguire l'esempio:

   python gremlinexample.py

   La query Gremlin alla fine di questo esempio restituisce i vertici (g.V().limit(2)) in un elenco. Questo elenco viene quindi stampato con la funzione Python standard print.

   Nota

   La parte finale della query Gremlin, toList() è obbligatoria per inviare l'attraversamento al server per la valutazione. Se non includi quel metodo o un altro metodo equivalente, la query non viene inviata all'istanza database Neptune.

   Di seguito sono riportati alcuni esempi di metodi che inviano la query all'istanza DB di Neptune:

   • toList()

   • toSet()

   • next()

   • iterate()

   Questi passaggi del terminale si comportano diversamente in modalità script e in modalità bytecode. Per l'elenco canonico delle fasi del terminale e i dettagli su come influiscono sulle transazioni, vedere. Test del codice Gremlin nel contesto in cui verrà implementato

   Usalo iterate() quando non hai bisogno dei risultati delle tue query (ad esempio mutazioni) in quanto consente di risparmiare sui costi di serializzazione.

   L'esempio precedente restituisce i primi due vertici del grafo utilizzando l'attraversamento g.V().limit(2).toList(). Per eseguire query per qualcos'altro, sostituirla con un altro attraversamento Gremlin con uno dei metodi finali appropriati.