Chiamando i Neptune Streams REST API - Amazon Neptune

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Chiamando i Neptune Streams REST API

Si accede a Neptune Streams utilizzando REST API un che invia HTTP GET una richiesta a uno dei seguenti endpoint locali:

  • Per un DB a grafoSPARQL:. https://Neptune-DNS:8182/sparql/stream

  • Per un Gremlin o un DB openCypher grafico: https://Neptune-DNS:8182/propertygraph/stream o. https://Neptune-DNS:8182/pg/stream

Nota

A partire dal rilascio 1.1.0.0 del motore, l'endpoint del flusso Gremlin (https://Neptune-DNS:8182/gremlin/stream) è diventato obsoleto, insieme al formato di output associato (GREMLIN_JSON). È ancora supportato per la compatibilità con le versioni precedenti, ma potrebbe essere rimosso nei rilasci futuri.

È consentita solo un'HTTPGEToperazione.

Neptune gzip supporta la compressione della risposta, a condizione che HTTP la richiesta includa Accept-Encoding un'intestazione che gzip specifichi come formato di compressione accettato (ovvero,). "Accept-Encoding: gzip"

Parametri

  • limit: long, facoltativo. Intervallo: 1-100.000. Impostazione predefinita: 10

    Specifica il numero massimo di record da restituire. Esiste anche un limite di dimensioni di 10 MB per la risposta che non può essere modificato e che ha la precedenza sul numero di record specificato nel parametro limit. La risposta include un record che supera la soglia se il limite di 10 MB è stato raggiunto.

  • iteratorType: stringa, facoltativo.

    Questo parametro può accettare uno dei seguenti valori:

    • AT_SEQUENCE_NUMBER: (valore predefinito) indica che la lettura deve iniziare dal numero di sequenza di eventi specificato congiuntamente dai parametri commitNum e opNum.

    • AFTER_SEQUENCE_NUMBER: indica che la lettura deve iniziare immediatamente dopo il numero di sequenza di eventi specificato congiuntamente dai parametri commitNum e opNum.

    • TRIM_HORIZON: indica che la lettura deve iniziare dall'ultimo record non tagliato nel sistema, ovvero il record più vecchio non scaduto (non ancora eliminato) nel flusso di log delle modifiche. Questa modalità è utile durante l'avvio dell'applicazione, quando non si dispone di un numero di sequenza dell'evento di avvio specifico.

    • LATEST: indica che la lettura deve iniziare dal record più recente non tagliato nel sistema, ovvero il record più recente non scaduto (non ancora eliminato) nel flusso di log delle modifiche. Questa modalità è utile quando è necessario leggere i record dalla parte superiore del flusso per non elaborare i record più vecchi, ad esempio durante un ripristino di emergenza o un aggiornamento senza tempi di inattività. Notare che in questa modalità viene restituito al massimo un solo record.

  • commitNum— lungo, richiesto quando è o. iteratorType AT_SEQUENCE_NUMBER AFTER_SEQUENCE_NUMBER

    Il numero di commit del record iniziale da leggere dal flusso change-log.

    Questo parametro viene ignorato quando iteratorType è TRIM_HORIZON o LATEST.

  • opNum: long, facoltativo (il valore predefinito è 1).

    Il numero di sequenza dell'operazione all'interno del commit specificato da cui iniziare la lettura nei dati del flusso change-log.

Le operazioni che modificano i dati del SPARQL grafico generalmente generano un solo record di modifica per operazione. Tuttavia, le operazioni che modificano i dati del grafo Gremlin possono generare più record di modifica per operazione, come negli esempi seguenti:

  • INSERT: un vertice Gremlin può avere più etichette e un elemento Gremlin può avere più proprietà. Un record di modifica separato viene generato per ogni etichetta e proprietà quando si inserisce un elemento.

  • UPDATE: quando la proprietà di un elemento Gremlin viene modificata, vengono generati due record di modifica: il primo per la rimozione del valore precedente e il secondo per l'inserimento del nuovo valore.

  • DELETE: viene generato un record di modifica separato per ogni proprietà dell'elemento che viene eliminata. Ad esempio, quando un edge Gremlin con proprietà viene eliminato, viene generato un record di modifica per ciascuna delle proprietà e successivamente ne viene generato uno per l'eliminazione dell'etichetta edge.

    Quando un vertice Gremlin viene eliminato, vengono eliminate per prime tutte le proprietà edge in entrata e in uscita, quindi le etichette edge, le proprietà dei vertici e infine le etichette dei vertici. Ognuna di queste eliminazioni genera un record di modifica.