

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

# Lettura dei dati del flusso di Neptune
<a name="streams-using-reading"></a>

I seguenti esempi mostrano come leggere i record dall'endpoint del flusso del grafico delle proprietà. Puoi usare AWS CLI, l' AWS SDK for 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
```

Per leggere da una posizione specifica nello stream, usa i parametri and: `--commit-num` `--iterator-type`

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

Per ulteriori informazioni, vedere [get-propertygraph-stream](https://docs.aws.amazon.com/cli/latest/reference/neptunedata/get-propertygraph-stream.html) nel Command Reference. 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))
```

Per eseguire l'impaginazione all'interno dello stream, utilizzate il comando e da nella risposta`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**  
Questo esempio presuppone che le tue AWS credenziali siano configurate nel tuo ambiente. Sostituisci {{us-east-1}} con la regione del tuo cluster Neptune.

Per ulteriori informazioni sull'utilizzo **awscurl** con l'autenticazione IAM, consulta. [Utilizzo di `awscurl` con credenziali temporanee per connettersi in modo sicuro a un cluster DB con autenticazione IAM abilitata](iam-auth-connect-command-line.md#iam-auth-connect-awscurl)

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

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

**Nota**  
L'utilizzo **curl** senza firma SigV4 funziona solo se l'autenticazione IAM è disabilitata sul cluster Neptune. Se l'autenticazione IAM è abilitata, usa **awscurl** o invece. AWS CLI 

------

Per i grafici SPARQL, sostituiscili `/propertygraph/stream` con `/sparql/stream` negli esempi precedenti. Quando usi AWS CLI o SDK, usa or invece. `get-sparql-stream` `client.get_sparql_stream()`

## Visualizzazione dei dati di flusso in un taccuino grafico
<a name="streams-using-notebook"></a>

Se utilizzi i taccuini [grafici Neptune](graph-notebooks.md), line magic fornisce un'interfaccia visiva per `%stream_viewer` sfogliare i record di streaming in modo interattivo senza scrivere codice. Esegui quanto segue in una cella del notebook:

```
%stream_viewer
```

Facoltativamente, puoi specificare la lingua di interrogazione e le dimensioni della pagina:

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

Per ulteriori informazioni, consulta [Comando magic di riga `%stream_viewer`](notebooks-magics.md#notebooks-line-magics-stream-viewer).

**Nota**  
The `%stream_viewer` magic è completamente supportato solo nelle versioni del motore 1.0.5.1 e precedenti.