Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

# Lecture des données du flux Neptune
<a name="streams-using-reading"></a>

Les exemples suivants montrent comment lire des enregistrements à partir du point de terminaison du flux de graphes de propriétés. Vous pouvez utiliser le AWS CLI, le AWS SDK pour Python (Boto3), **awscurl** ou. **curl**

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

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

Pour lire à partir d'une position spécifique dans le flux, utilisez les `--iterator-type` paramètres `--commit-num` et :

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

Pour plus d'informations, consultez [ get-propertygraph-stream ](https://docs.aws.amazon.com/cli/latest/reference/neptunedata/get-propertygraph-stream.html) dans la référence des commandes. 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))
```

Pour paginer dans le flux, utilisez le `commitNum` et `opNum` depuis le `lastEventId` dans la réponse :

```
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
```

**Note**  
Cet exemple suppose que vos AWS informations d'identification sont configurées dans votre environnement. {{us-east-1}}Remplacez-la par la région de votre amas Neptune.

Pour plus d'informations sur l'utilisation **awscurl** de l'authentification IAM, consultez[Utilisation de `awscurl` avec des informations d'identification temporaires pour se connecter en toute sécurité à un cluster de bases de données avec l'authentification IAM activée](iam-auth-connect-command-line.md#iam-auth-connect-awscurl).

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

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

**Note**  
L'utilisation **curl** sans signature Sigv4 ne fonctionne que si l'authentification IAM est désactivée sur votre cluster Neptune. Si l'authentification IAM est activée, utilisez **awscurl** ou AWS CLI plutôt.

------

Pour les graphes SPARQL, remplacez `/propertygraph/stream` par `/sparql/stream` dans les exemples précédents. Lorsque vous utilisez le SDK AWS CLI or, utilisez `get-sparql-stream` ou à la `client.get_sparql_stream()` place.

## Affichage des données des flux dans un bloc-notes graphique
<a name="streams-using-notebook"></a>

Si vous utilisez des blocs-notes [ Neptune Graph](graph-notebooks.md), `%stream_viewer` Line Magic fournit une interface visuelle permettant de parcourir les enregistrements de flux de manière interactive sans écrire de code. Exécutez les opérations suivantes dans une cellule de bloc-notes :

```
%stream_viewer
```

Vous pouvez éventuellement spécifier la langue de la requête et la taille de page :

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

Pour de plus amples informations, veuillez consulter [La magie linéaire `%stream_viewer`](notebooks-magics.md#notebooks-line-magics-stream-viewer).

**Note**  
La `%stream_viewer` magie n'est entièrement prise en charge que sur les versions de moteur 1.0.5.1 et antérieures.