Chamando os Neptune Streams REST 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á.

Chamando os Neptune Streams REST API

Você acessa o Neptune Streams usando REST API um que envia uma solicitação para HTTP GET um dos seguintes endpoints locais:

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

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

nota

A partir da versão 1.1.0.0 do mecanismo, o endpoint de fluxos do Gremlin (https://Neptune-DNS:8182/gremlin/stream) está sendo descontinuado, junto com o formato de saída associado (GREMLIN_JSON). Ele ainda é compatível com versões anteriores, mas pode ser removido em versões futuras.

Somente uma HTTP GET operação é permitida.

O Neptune gzip suporta a compactação da resposta, desde que a solicitação HTTP inclua Accept-Encoding um cabeçalho que gzip especifique como um formato de compactação aceito (ou seja,). "Accept-Encoding: gzip"

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, necessário quando iteratorType é AT_SEQUENCE_NUMBER ouAFTER_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.

As operações que alteram os dados do SPARQL gráfico geralmente geram apenas um único registro de alteração por operação. No entanto, as operações que alteram dados de gráficos do Gremlin podem gerar vários registros de alterações por operação, como nos exemplos a seguir:

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