Herstellen einer Verbindung mit einer Neptune-DB-Instance über Python

Verwenden Sie nach Möglichkeit immer die neueste Version des Apache TinkerPop Python Gremlin-Clients, gremlinpython, die Ihre Engine-Version unterstützt. Neuere Versionen enthalten zahlreiche Fehlerbehebungen, die Stabilität, Leistung und Benutzerfreundlichkeit des Clients verbessern. Die zu gremlinpython verwendende Version entspricht in der Regel den TinkerPop Versionen, die in der Tabelle für den Java-Gremlin-Client beschrieben sind.

Anmerkung

Die gremlinpython 3.5.x-Versionen sind mit den TinkerPop 3.4.x-Versionen kompatibel, solange Sie in den Gremlin-Abfragen, die Sie schreiben, nur 3.4.x-Funktionen verwenden.

Der folgende Abschnitt führt Sie durch die Ausführung eines Python-Beispiels mit Herstellung einer Verbindung zu einer Amazon-Neptune-DB-Instance und Ausführung einer Gremlin-Traversierung.

Sie müssen diese Anweisungen für eine Amazon-EC2-Instance befolgen, die sich in derselben Virtual Private Cloud (VPC) wie Ihre Neptune-DB-Instance befindet.

Bevor Sie beginnen, führen Sie die folgenden Schritte aus:

• Laden Sie Python 3.6 oder höher von der Website Python.org herunter.

• Überprüfen Sie, ob Sie pip installiert haben. Haben Sie pip nicht installiert oder sind sich nicht sicher, lesen Sie Do I need to install pip? in der pip-Dokumenation.

• Wenn Ihre Python-Installation nicht bereits darüber verfügt, ist der Download von futures wie folgt möglich: pip install futures

Herstellen einer Verbindung mit Neptune über Python

1. Geben Sie Folgendes ein, um das gremlinpython-Paket zu installieren:

   pip install --user gremlinpython

2. Erstellen Sie eine Datei namens gremlinexample.py und öffnen Sie diese dann in einem Text-Editor.

3. Kopieren Sie Folgendes in die gremlinexample.py-Datei. Ersetzen Sie your-neptune-endpoint durch die Adresse Ihrer Neptune-DB-Instance.

   Informationen zum Ermitteln der Adresse Ihrer Neptune-DB-Instance finden Sie im Abschnitt Verbinden mit Amazo-Neptune-Endpunkten.

   from __future__  import print_function  # Python 2/3 compatibility
   
   from gremlin_python import statics
   from gremlin_python.structure.graph import Graph
   from gremlin_python.process.graph_traversal import __
   from gremlin_python.process.strategies import *
   from gremlin_python.driver.driver_remote_connection import DriverRemoteConnection
   
   graph = Graph()
   
   remoteConn = DriverRemoteConnection('wss://your-neptune-endpoint:8182/gremlin','g')
   g = graph.traversal().withRemote(remoteConn)
   
   print(g.V().limit(2).toList())
   remoteConn.close()

4. Geben Sie den folgenden Befehl ein, um das Beispiel auszuführen:

   python gremlinexample.py

   Die Gremlin-Abfrage am Ende dieses Beispiel gibt die Knoten (g.V().limit(2)) in einer Liste zurück. Diese Liste wird dann mit der Python-Standardfunktion print gedruckt.

   Anmerkung

   Der letzte Teil der Gremlin-Abfrage, toList(), ist für die Übermittlung der Traversierung zur Auswertung an den Server erforderlich. Wenn Sie diese oder eine gleichwertige Methode nicht einschließen, wird die Abfrage nicht an die Neptune-DB-Instance übermittelt.

   Die folgenden Methoden senden die Abfrage an die Neptune-DB-Instance:

   • toList()

   • toSet()

   • next()

   • nextTraverser()

   • iterate()

   Das vorherige Beispiel gibt die ersten beiden Knoten im Diagramm über die g.V().limit(2).toList()-Traversierung zurück. Um etwas anderes abzufragen, ersetzen Sie diese durch eine andere Gremlin-Traversierung mit einer der entsprechenden Ending-Methoden.