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 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

  • source (erforderlich) — Amazon S3 S3-URI zu einem einzelnen Objekt. Das Amazon S3 S3-Präfix für mehrere Objekte wird nicht unterstützt.

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

  • Parallelität (optional) — Typ: Ganzzahl 0 oder höher. 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 von der Ressource zulässig ist. Für Parquet wird empfohlen, die Einstellung auf eine bestimmte Anzahl von Zeilengruppen festzulegen.

Outputs

neptune.read gibt zurück:

  • row - Typ: MAP

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

    • Sie können auf die Daten jeder Spalte wie bei einer Eigenschaft access (row.col) 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 Instance-Typen für Amazon Neptune auswählen beschrieben.

Die Speichernutzung 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 funktionieren kleine Dateien (z. B. CSV-Dateien mit 100 MB oder weniger, Parquet-Dateien mit 20 MB oder weniger) möglicherweise zuverlässig auf den meisten produktionsgeeigneten Instance-Typen, wohingegen größere Dateien möglicherweise viel Speicherplatz benötigen, den kleinere Instance-Typen nicht bereitstellen können.

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