View a markdown version of this page

Formato de resposta da API de fluxos do Neptune - 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 da API de fluxos do Neptune

Uma resposta a uma solicitação de API REST dos fluxos do Neptune 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 registros de alterações do Gremlin ou do openCypher, NQUADS para registros de alterações do SPARQL.

  • 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 registro serializado do Gremlin, SPARQL ou de alteração. OpenCypher 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. Os valores válidos são:

      • ADD— Indica que um novo elemento (como vértice, aresta, propriedade ou triplo) foi adicionado ao gráfico.

      • REMOVE— Indica que um elemento existente foi removido do gráfico.

      Netuno expressa uma modificação em um elemento existente como um REMOVE registro seguido por um registro. ADD

    • 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 gera dados de alteração do SPARQL para a ú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
}