Usar os fluxos do Neptune

• Para um banco de dados gráfico do SPARQL:   https://Neptune-DNS:8182/sparql/stream.

• Para um banco de dados de grafos do Gremlin ou do openCypher: https://Neptune-DNS:8182/propertygraph/stream ou https://Neptune-DNS:8182/pg/stream.

Parâmetros

• limit: longo, opcional. Intervalo: de um a cem mil. Padrão: 10.

  Especifica o número máximo de registros a serem retornados. Há também um limite de tamanho de 10 MB na resposta que não pode ser modificado e que tem precedência sobre o número de registros especificado no parâmetro limit. A resposta incluirá um registro de violação de limite se o limite de 10 MB tiver sido atingido.

• iteratorType: string, opcional.

  Esse parâmetro pode ter um dos valores a seguir:

  • AT_SEQUENCE_NUMBER(padrão): indica que a leitura deve começar a partir do número de sequência de eventos especificado em conjunto pelos parâmetros commitNum e opNum.

  • AFTER_SEQUENCE_NUMBER: indica que a leitura deve começar logo após o número de sequência de eventos especificado em conjunto pelos parâmetros commitNum e opNum.

  • TRIM_HORIZON: indica que a leitura deve começar no último registro não truncado no sistema, que é o registro mais antigo não expirado (ainda não excluído) no fluxo de logs de alterações. Esse modo é útil durante a inicialização do aplicativo, quando você não tem um número inicial específico de sequência de eventos.

  • LATEST: indica que a leitura deve começar no registro mais recente no sistema, que é o registro mais recente não expirado (ainda não excluído) no fluxo de logs de alterações. Isso é útil quando há a necessidade de ler registros da parte superior atual dos fluxos para não processar registros antigos, como durante a recuperação de desastres ou uma atualização sem tempo de inatividade. Observe que, nesse modo, há no máximo apenas um registro exibido.

• commitNum: longo, obrigatório quando iteratorType é AT_SEQUENCE_NUMBER ou AFTER_SEQUENCE_NUMBER.

  O número de confirmação do registro inicial a ser lido no fluxo do log de alterações.

  Este parâmetro é ignorado quando iteratorType é TRIM_HORIZON ou LATEST.

• opNum: longo, opcional (o padrão é 1).

  O número de sequência da operação dentro da confirmação especificada da qual começar a ler nos dados do fluxo do log de alterações.

• INSERT: um vértice do Gremlin pode ter vários rótulos, e um elemento do Gremlin pode ter várias propriedades. Um registro de alteração separado é gerado para cada rótulo e propriedade quando um elemento é inserido.

• UPDATE: quando uma propriedade de elemento do Gremlin é alterada, dois registros de alteração são gerados: o primeiro para remover o valor anterior e o segundo para inserir o novo valor.

• DELETE: um registro de alteração separado é gerado para cada propriedade de elemento excluída. Por exemplo, quando uma borda do Gremlin com propriedades é excluída, um registro de alteração é gerado para cada uma das propriedades e, depois disso, é gerado um para a exclusão do rótulo da borda.

  Quando um vértice do Gremlin é excluído, todas as propriedades de borda de entrada e saída são excluídas primeiro, depois os rótulos da borda, depois as propriedades do vértice e, por fim, os rótulos do vértice. Cada uma dessas exclusões gera um registro de alteração.

• 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 de Gremlin, SPARQL ou 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.

  • 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.