Format Respons Streaming API Neptunus - Amazon Neptune

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

Format Respons Streaming API Neptunus

Respons terhadap permintaan Neptunus REST API Streams memiliki bidang berikut:

  • lastEventId— Pengidentifikasi urutan dari perubahan terakhir dalam respons aliran. ID peristiwa disusun dari dua bidang: A commitNum mengidentifikasi transaksi yang mengubah grafik, dan opNum mengidentifikasi operasi tertentu dalam transaksi itu. Ini ditunjukkan dalam contoh berikut.

      "eventId": {
    "commitNum": 12,
    "opNum": 1
  }

  • lastTrxTimestamp— Waktu di mana komit untuk transaksi diminta, dalam milidetik dari zaman Unix.

  • format— Format serialisasi untuk catatan perubahan yang dikembalikan. Nilai yang mungkin adalah PG_JSON untuk Gremlin atau catatan openCypher perubahan, dan NQUADS untuk catatan SPARQL perubahan.

  • records— Array catatan aliran log perubahan serial yang disertakan dalam respons. Setiap record dalam records array berisi bidang-bidang ini:

    • commitTimestamp— Waktu di mana komit untuk transaksi diminta, dalam milidetik dari zaman Unix.

    • eventId— Pengidentifikasi urutan catatan perubahan aliran.

    • data— Gremlin serial,SPARQL, atau OpenCypher catatan perubahan. Format serialisasi setiap catatan dijelaskan secara lebih rinci di bagian selanjutnya,Format Serialisasi dalam Neptune Stream.

    • op— Operasi yang menciptakan perubahan.

    • isLastOp— Hanya hadir jika operasi ini adalah yang terakhir dalam transaksinya. Saat hadir, diatur ketrue. Berguna untuk memastikan bahwa seluruh transaksi dikonsumsi.

  • totalRecords— Jumlah total catatan dalam tanggapan.

Misalnya, respons berikut mengembalikan data perubahan Gremlin, untuk transaksi yang berisi lebih dari satu operasi:

{
  "lastEventId": {
    "commitNum": 12,
    "opNum": 1
  },
  "lastTrxTimestamp": 1560011610678,
  "format": "PG_JSON",
  "records": [
    {
      "commitTimestamp": 1560011610678,
      "eventId": {
        "commitNum": 1,
        "opNum": 1
      },
      "data": {
        "id": "d2b59bf8-0d0f-218b-f68b-2aa7b0b1904a",
        "type": "vl",
        "key": "label",
        "value": {
          "value": "vertex",
          "dataType": "String"
        }
      },
      "op": "ADD"
    }
  ],
  "totalRecords": 1
}

Respons berikut mengembalikan data SPARQL perubahan untuk operasi terakhir dalam transaksi (operasi diidentifikasi oleh EventId(97, 1) dalam nomor transaksi 97).

{
  "lastEventId": {
    "commitNum": 97,
    "opNum": 1
  },
  "lastTrxTimestamp": 1561489355102,
  "format": "NQUADS",
  "records": [
    {
      "commitTimestamp": 1561489355102,
      "eventId": {
        "commitNum": 97,
        "opNum": 1
      },
      "data": {
        "stmt": "<https://test.com/s> <https://test.com/p> <https://test.com/o> .\n"
      },
      "op": "ADD",
      "isLastOp": true
    }
  ],
  "totalRecords": 1
}