Formato de respuesta de Neptune Streams API - Amazon Neptune

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Formato de respuesta de Neptune Streams API

La respuesta a una REST API solicitud de Neptune Streams tiene los siguientes campos:

  • lastEventId: identificador de secuencia del último cambio en la respuesta del flujo. Un ID de evento se compone de dos campos: commitNum identifica una transacción que ha cambiado el gráfico y opNum identifica una operación específica dentro de dicha transacción. Esto se muestra en el siguiente ejemplo.

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

  • lastTrxTimestamp: la hora a la que se solicitó la confirmación de la transacción, en milisegundos a partir de la fecha de inicio de Unix.

  • format: formato de serialización de los registros de cambios que se devuelven. Los valores posibles son PG_JSON para Gremlin o registros de openCypher cambios y NQUADS para SPARQL registros de cambios.

  • records: una matriz de registros de flujos de registro de cambios serializados incluidos en la respuesta. Cada registro de la matriz de records contiene los siguientes campos:

    • commitTimestamp: la hora a la que se solicitó la confirmación de la transacción, en milisegundos a partir de la fecha de inicio de Unix.

    • eventId: el identificador de secuencia del registro de cambios del flujo.

    • data— El registro de cambios o Gremlin serializado. SPARQL OpenCypher Los formatos de serialización de cada registro se describen con más detalle en la siguiente sección, Formatos de serialización en flujos de Neptune.

    • op: la operación que creó el cambio.

    • isLastOp: solo está presente si esta operación es la última de su transacción. Cuando está presente, se establece en true. Es útil para garantizar que se realice una transacción completa.

  • totalRecords: el número total de registros de la respuesta.

Por ejemplo, la siguiente respuesta devuelve los datos de cambios de Gremlin para una transacción que contiene más de una operación:

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

La siguiente respuesta devuelve los datos de SPARQL cambio de la última operación de una transacción (la operación identificada con el número de transacción EventId(97, 1) 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
}