

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.

# Lectura de datos de la corriente de Neptune
<a name="streams-using-reading"></a>

Los siguientes ejemplos muestran cómo leer los registros del punto final del flujo del gráfico de propiedades. Puede usar el AWS CLI, el AWS SDK para Python (Boto3), o. **awscurl** **curl**

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

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

Para leer desde una posición específica de la transmisión, usa los parámetros `--commit-num` y`--iterator-type`:

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

Para obtener más información, consulte [get-propertygraph-stream](https://docs.aws.amazon.com/cli/latest/reference/neptunedata/get-propertygraph-stream.html) en la Referencia 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 por la secuencia, usa las letras y desde la respuesta: `commitNum` `opNum` `lastEventId`

```
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**  
En este ejemplo se supone que sus AWS credenciales están configuradas en su entorno. {{us-east-1}}Sustitúyala por la región de tu cúmulo de Neptuno.

Para obtener más información sobre el uso **awscurl** con la autenticación de IAM, consulte. [Uso de `awscurl` con credenciales temporales para conectarse de forma segura a un clúster de base de datos con la autenticación de IAM habilitada](iam-auth-connect-command-line.md#iam-auth-connect-awscurl)

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

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

**nota**  
El uso **curl** sin firma SigV4 solo funciona si la autenticación de IAM está deshabilitada en el clúster de Neptune. Si la autenticación de IAM está habilitada, utilice **awscurl** o en su lugar. AWS CLI 

------

Para los gráficos de SPARQL, `/propertygraph/stream` sustitúyalos por `/sparql/stream` en los ejemplos anteriores. Cuando utilice el AWS CLI o el SDK, utilice `get-sparql-stream` o `client.get_sparql_stream()` en su lugar.

## Visualización de los datos de la transmisión en un cuaderno gráfico
<a name="streams-using-notebook"></a>

Si utilizas [libretas gráficas de Neptune](graph-notebooks.md), la magia de `%stream_viewer` líneas proporciona una interfaz visual para navegar por los registros de las transmisiones de forma interactiva sin necesidad de escribir código. Ejecute lo siguiente en una celda de bloc de notas:

```
%stream_viewer
```

Si lo desea, puede especificar el idioma de la consulta y el tamaño de la página:

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

Para obtener más información, consulte [El comando mágico de línea `%stream_viewer`](notebooks-magics.md#notebooks-line-magics-stream-viewer).

**nota**  
La `%stream_viewer` magia solo es totalmente compatible con las versiones de motor 1.0.5.1 y anteriores.