Formato de resposta do Neptune Streams API - Amazon Neptune

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Formato de resposta do Neptune Streams API

Uma resposta a uma solicitação do Neptune REST API Streams tem os seguintes campos:

  • lastEventId: identificador da sequência da última alteração na resposta do fluxo. Um ID de evento é composto de dois campos: um commitNum identifica uma transação que alterou o gráfico, e um opNum identifica uma operação específica dentro dessa transação. Isso é mostrado no exemplo a seguir.

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

  • lastTrxTimestamp: a hora em que a confirmação da transação foi solicitada, em milissegundos a partir da época do Unix.

  • format: o formato da serialização dos registros de alterações que estão sendo gerados. Os valores possíveis são PG_JSON para Gremlin ou registros de openCypher alterações e NQUADS para registros de SPARQL alterações.

  • records: uma matriz de registros serializados do fluxo de logs de alterações incluídos na resposta. Cada registro na matriz records contém os seguintes campos:

    • commitTimestamp: a hora em que a confirmação da transação foi solicitada, em milissegundos a partir da época do Unix.

    • eventId: o identificador da sequência da registro de alteração do fluxo.

    • data— O Gremlin serializadoSPARQL, ou OpenCypher registro de alteração. Os formatos de serialização de cada registro são descritos em mais detalhes na próxima seção, Formatos de serialização nos fluxos do Neptune.

    • op: a operação que criou a alteração.

    • isLastOp: presente somente se essa operação for a última da transação. Quando presente, está definido como true. Útil para garantir que uma transação inteira seja consumida.

  • totalRecords: o número total de registros na resposta.

Por exemplo, a seguinte resposta exibe dados de alteração do Gremlin para uma transação que contém mais de uma operação:

{
  "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
}

A resposta a seguir retorna dados de SPARQL alteração da última operação em uma transação (a operação identificada por EventId(97, 1) na transação número 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
}