Uso de flujos de Neptune

• Para una base de datos de gráficos SPARQL:   https://Neptune-DNS:8182/sparql/stream.

• Para una base de datos de gráficos de Gremlin u openCypher: https://Neptune-DNS:8182/propertygraph/stream o https://Neptune-DNS:8182/pg/stream.

Parámetros

• limit: largo, opcional. Rango: 1–100 000. Predeterminado: 10.

  Especifica el número máximo de registros que se van a devolver. También existe un límite de tamaño de 10 MB en la respuesta que no se puede modificar y que prevalece sobre el número de registros especificado en el parámetro limit. La respuesta incluye un registro de incumplimiento de umbral si se alcanzó el límite de 10 MB.

• iteratorType: cadena, opcional.

  Este parámetro puede tener uno de los siguientes valores:

  • AT_SEQUENCE_NUMBER (predeterminado): indica que la lectura debe comenzar con el número de secuencia de eventos especificado conjuntamente por los parámetros commitNum y opNum.

  • AFTER_SEQUENCE_NUMBER: indica que la lectura debe comenzar justo después del número de secuencia de eventos especificado conjuntamente por los parámetros commitNum y opNum.

  • TRIM_HORIZON: indica que la lectura debe comenzar en el último registro no recortado del sistema, que es el registro más antiguo que no ha caducado (aún no se ha eliminado) del flujo de registro de cambios. Este modo es útil durante el inicio de la aplicación, cuando no tiene un número secuencial de evento inicial específico.

  • LATEST: indica que la lectura debe comenzar en el registro más reciente del sistema, que es el último registro que no ha caducado (aún no se ha eliminado) del flujo de registro de cambios. Esto resulta útil cuando es necesario leer los registros de la parte superior actual de los flujos para no procesar registros antiguos, por ejemplo, durante una recuperación de desastres o una actualización sin tiempo de inactividad. Tenga en cuenta que, en este modo, solo se devuelve como máximo un registro.

• commitNum: largo, obligatorio cuando iteratorType es AT_SEQUENCE_NUMBER o AFTER_SEQUENCE_NUMBER.

  El número de confirmación del registro de inicio que se va a leer del flujo de registro de cambios.

  Este parámetro se omite cuando iteratorType es TRIM_HORIZON o LATEST.

• opNum: largo, opcional (el valor predeterminado es 1).

  El número secuencial de la operación dentro de la confirmación especificada desde la que empezar a leer en los datos del flujo de registro de cambios.

• INSERT: un vértice de Gremlin puede tener varias etiquetas y un elemento de Gremlin puede tener varias propiedades. Se genera un registro de cambio independiente para cada etiqueta y propiedad cuando se inserta un elemento.

• UPDATE: cuando se modifica una propiedad de un elemento de Gremlin, se generan dos registros de cambios: el primero para eliminar el valor anterior y el segundo para insertar el nuevo valor.

• DELETE: se genera un registro de cambios independiente para cada propiedad del elemento que se elimina. Por ejemplo, cuando se elimina un borde Gremlin con propiedades, se genera un registro de cambio para cada una de las propiedades y, a continuación, se genera uno para la eliminación de la etiqueta de borde.

  Cuando se elimina un vértice Gremlin, se eliminan primero todas las propiedades de borde de entrada y salida, después las etiquetas de borde, a continuación las propiedades de vértice y, por último, las etiquetas de vértice. Cada una de estas eliminaciones genera un registro de cambios.

• 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 registros de cambios de Gremlin u openCypher y NQUADS para registros de cambios de SPARQL.

• 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 serializado de Gremlin, SPARQL o change. 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.