Memanggil Neptune Streams REST API - Amazon Neptune

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Memanggil Neptune Streams REST API

Anda mengakses Neptune Streaming menggunakan REST API yang mengirimkan permintaan HTTP GET ke salah satu titik akhir lokal berikut:

  • Untuk DB grafik SPARQL:   https://Neptune-DNS:8182/sparql/stream.

  • Untuk grafik Gremlin atau OpenCypher DB: atau. https://Neptune-DNS:8182/propertygraph/stream https://Neptune-DNS:8182/pg/stream

catatan

Pada rilis engine 1.1.0.0, titik akhir aliran Gremlin (https://Neptune-DNS:8182/gremlin/stream) tidak digunakan lagi, bersama dengan format keluaran terkait (). GREMLIN_JSON Ini masih didukung untuk kompatibilitas mundur tetapi dapat dihapus di rilis mendatang.

Hanya HTTP operasi GET diperbolehkan.

Neptune mendukung kompresi gzip respon, asalkan permintaan HTTP mencakup Header Accept-Encoding yang menentukan gzip sebagai format kompresi yang diterima (yaitu, "Accept-Encoding: gzip").

Parameter

  • limit- panjang, opsional. Kisaran: 1—100.000. Default: 10.

    Menentukan angka maksimum catatan yang akan dikembalikan. Ada juga batas ukuran 10 MB pada respon yang tidak dapat diubah dan yang diutamakan daripada jumlah catatan yang ditentukan dalam parameter limit. Respon mencakup catatan pelanggaran ambang batas jika batas 10 MB tercapai.

  • iteratorType— String, opsional.

    Parameter ini dapat berupa salah satu nilai berikut:

    • AT_SEQUENCE_NUMBER(default) - Menunjukkan bahwa pembacaan harus dimulai dari nomor urutan acara yang ditentukan bersama oleh opNum parameter commitNum dan.

    • AFTER_SEQUENCE_NUMBER— Menunjukkan bahwa pembacaan harus dimulai tepat setelah nomor urut acara yang ditentukan bersama oleh opNum parameter commitNum dan.

    • TRIM_HORIZON— Menunjukkan bahwa pembacaan harus dimulai pada catatan terakhir yang belum dipangkas dalam sistem, yang merupakan catatan tertua yang belum kedaluwarsa (belum dihapus) dalam aliran log perubahan. Mode ini berguna selama startup aplikasi, ketika Anda tidak memiliki nomor urutan acara awal tertentu.

    • LATEST— Menunjukkan bahwa pembacaan harus dimulai pada catatan terbaru dalam sistem, yang merupakan catatan terbaru yang belum kedaluwarsa (belum dihapus) dalam aliran log perubahan. Ini berguna ketika ada kebutuhan untuk membaca catatan dari atas aliran saat ini agar tidak memproses catatan yang lebih lama, seperti selama pemulihan bencana atau peningkatan zero-downtime. Perhatikan bahwa dalam mode ini, paling banyak hanya ada satu catatan yang dikembalikan.

  • commitNum— panjang, diperlukan ketika AT_SEQUENCE_NUMBER IteratorType adalah atau. AFTER_SEQUENCE_NUMBER

    Jumlah commit dari catatan awal yang akan dibaca dari stream log perubahan.

    Parameter ini diabaikan ketika iteratorType adalah TRIM_HORIZON atauLATEST.

  • opNum— panjang, opsional (defaultnya adalah1).

    Nomor urut operasi dalam commit yang ditentukan untuk mulai dibaca dari dalam data stream log perubahan.

Operasi yang mengubah data grafik SPARQL umumnya hanya menghasilkan catatan perubahan tunggal per operasi. Namun, operasi yang mengubah data grafik Gremlin dapat menghasilkan beberapa catatan perubahan per operasi, seperti dalam contoh berikut:

  • INSERT— Sebuah simpul Gremlin dapat memiliki beberapa label, dan elemen Gremlin dapat memiliki beberapa properti. Sebuah catatan perubahan terpisah yang dihasilkan untuk setiap label dan properti ketika elemen dimasukkan.

  • UPDATE— Ketika properti elemen Gremlin diubah, dua catatan perubahan dihasilkan: yang pertama untuk menghapus nilai sebelumnya, dan yang kedua untuk memasukkan nilai baru.

  • DELETE— Catatan perubahan terpisah dihasilkan untuk setiap properti elemen yang dihapus. Misalnya, ketika edge Gremlin dengan properti dihapus, satu catatan perubahan dihasilkan untuk masing-masing properti, dan setelah itu, satu dihasilkan untuk penghapusan label edge.

    Ketika vertex Gremlin dihapus, semua properti edge masuk dan keluar dihapus terlebih dahulu, selanjutnya label edge, selanjutnya properti vertex, dan terakhir label vertex. Setiap penghapusan ini menghasilkan catatan perubahan.