View a markdown version of this page

neptune.read () - Amazon Neptune
Bewährte Methoden für neptune.read ()

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

neptune.read ()

Neptune unterstützt ein CALL Verfahren neptune.read zum Lesen von Daten aus Amazon S3 und zum Ausführen einer OpenCypher-Abfrage (Lesen, Einfügen, Aktualisieren) unter Verwendung der Daten. Die Prozedur gibt jede Zeile in der Datei als deklarierte Ergebnisvariablenzeile zurück. Es verwendet die IAM-Anmeldeinformationen des Anrufers, um auf die Daten in Amazon S3 zuzugreifen. Informationen Verwaltung der Berechtigungen für neptune.read () zum Einrichten der Berechtigungen finden Sie unter. Die AWS Region des Amazon S3-Buckets muss sich in derselben Region befinden, in der sich die Instance befindet. Derzeit werden regionsübergreifende Lesevorgänge nicht unterstützt.

Syntax 

CALL neptune.read(
  {
    source: "string",
    format: "parquet/csv",
    concurrency: 10
  }
)
YIELD row
...
Eingaben

  • Quelle (erforderlich) — Amazon S3-URI für ein einzelnes Objekt. Das Amazon S3-Präfix für mehrere Objekte wird nicht unterstützt.

  • Format (erforderlich) — parquet und csv werden unterstützt.

  • Parallelität (optional) — Geben Sie eine Ganzzahl von 0 oder größer ein. Standard: 0 Gibt die Anzahl der Threads an, die zum Lesen der Datei verwendet werden sollen. Wenn der Wert 0 ist, wird die maximale Anzahl von Threads verwendet, die für die Ressource zulässig ist. Für Parquet wird empfohlen, eine bestimmte Anzahl von Zeilengruppen festzulegen.

Outputs

Der Befehl neptune.read gibt Folgendes zurück:

  • row — Typ: MAP

    • Jede Zeile in der Datei, wobei die Schlüssel die Spalten sind und die Werte die Daten sind, die in jeder Spalte gefunden wurden.

    • Sie können wie mit einer Eigenschaft access (row.col) auf die Daten jeder Spalte zugreifen.

Bewährte Methoden für neptune.read ()

Neptune S3-Lesevorgänge können speicherintensiv sein. Bitte verwenden Sie Instance-Typen, die sich gut für Produktions-Workloads eignen, wie unter Auswahl der Instance-Typen für Amazon Neptune beschrieben.

Die Speicherauslastung und die Leistung von neptune.read() Anfragen werden durch eine Vielzahl von Faktoren wie Dateigröße, Anzahl der Spalten, Anzahl der Zeilen und Dateiformat beeinflusst. Je nach Struktur können kleine Dateien (z. B. CSV-Dateien mit 100 MB oder weniger, Parquet-Dateien mit 20 MB oder weniger) auf den meisten produktionstauglichen Instance-Typen zuverlässig funktionieren, wohingegen größere Dateien viel Speicher benötigen, den kleinere Instance-Typen nicht bieten können.

Beim Testen dieser Funktion wird empfohlen, mit kleinen Dateien zu beginnen und diese schrittweise zu skalieren, um sicherzustellen, dass Ihre Leselast an Ihre Instance-Größe angepasst werden kann. Wenn Sie feststellen, dass neptune.read() Anfragen zu Ausnahmen aufgrund von Speichermangel oder Instanzneustarts führen, sollten Sie erwägen, Ihre Dateien in kleinere Abschnitte aufzuteilen, die Dateikomplexität zu reduzieren oder ein Upgrade auf größere Instance-Typen durchzuführen.