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

# Lendo dados do stream de Neptune
<a name="streams-using-reading"></a>

Os exemplos a seguir mostram como ler registros do endpoint do fluxo do gráfico de propriedades. Você pode usar o AWS CLI, o AWS SDK para Python (Boto3),, ou. **awscurl** **curl**

------
#### [ AWS CLI ]

```
aws neptunedata get-propertygraph-stream \
  --endpoint-url https://{{your-neptune-endpoint}}:{{port}} \
  --iterator-type TRIM_HORIZON \
  --limit 10
```

Para ler de uma posição específica no fluxo, use os `--iterator-type` parâmetros `--commit-num` e:

```
aws neptunedata get-propertygraph-stream \
  --endpoint-url https://{{your-neptune-endpoint}}:{{port}} \
  --limit 10 \
  --commit-num 1 \
  --iterator-type AT_SEQUENCE_NUMBER
```

Para obter mais informações, consulte [get-propertygraph-stream](https://docs.aws.amazon.com/cli/latest/reference/neptunedata/get-propertygraph-stream.html) na Referência de comandos. AWS CLI 

------
#### [ SDK (Python) ]

```
import boto3
import json
from botocore.config import Config

client = boto3.client(
    'neptunedata',
    region_name='{{us-east-1}}',
    endpoint_url='https://{{your-neptune-endpoint}}:{{port}}',
    config=Config(read_timeout=65)
)

response = client.get_propertygraph_stream(
    limit=10,
    iteratorType='TRIM_HORIZON'
)

print(json.dumps(response['records'], indent=2, default=str))
```

Para paginar pelo stream, use o `commitNum` e `opNum` do `lastEventId` na resposta:

```
last_event = response['lastEventId']
next_response = client.get_propertygraph_stream(
    limit=10,
    commitNum=last_event['commitNum'],
    opNum=last_event['opNum'],
    iteratorType='AFTER_SEQUENCE_NUMBER'
)
```

------
#### [ awscurl ]

```
awscurl https://{{your-neptune-endpoint}}:{{port}}/propertygraph/stream?limit=10 \
  --region {{us-east-1}} \
  --service neptune-db
```

**nota**  
Este exemplo pressupõe que suas AWS credenciais estejam configuradas em seu ambiente. {{us-east-1}}Substitua pela região do seu cluster Neptune.

Para obter mais informações sobre como usar **awscurl** com a autenticação do IAM, consulte[Usando `awscurl` com credenciais temporárias para se conectar com segurança a um cluster de banco de dados com a autenticação IAM ativada](iam-auth-connect-command-line.md#iam-auth-connect-awscurl).

------
#### [ curl ]

```
curl https://{{your-neptune-endpoint}}:{{port}}/propertygraph/stream?limit=10
```

**nota**  
O uso **curl** sem assinatura SigV4 só funciona se a autenticação do IAM estiver desativada em seu cluster Neptune. Se a autenticação do IAM estiver ativada, use **awscurl** ou AWS CLI em vez disso.

------

Para gráficos SPARQL, `/propertygraph/stream` substitua por `/sparql/stream` nos exemplos anteriores. Ao usar o SDK AWS CLI ou, use `get-sparql-stream` or `client.get_sparql_stream()` em vez disso.

## Visualizando dados de fluxo em um caderno gráfico
<a name="streams-using-notebook"></a>

Se você usa cadernos [gráficos Neptune](graph-notebooks.md), a mágica de linha fornece uma interface visual para navegar pelos registros `%stream_viewer` do stream de forma interativa sem escrever código. Execute o seguinte em uma célula do notebook:

```
%stream_viewer
```

Opcionalmente, você pode especificar o idioma da consulta e o tamanho da página:

```
%stream_viewer sparql --limit 20
```

Para obter mais informações, consulte [A magia de linha `%stream_viewer`](notebooks-magics.md#notebooks-line-magics-stream-viewer).

**nota**  
A `%stream_viewer` magia é totalmente suportada somente nas versões 1.0.5.1 e anteriores do motor.