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.

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

Les exemples suivants montrent comment lire des enregistrements depuis le point de terminaison du flux du graphe de propriétés. Vous pouvez utiliser AWS CLI le AWS SDK pour 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
```

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` from `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. Remplacez {{us-east-1}} par la région de votre cluster Neptune.

Pour plus d'informations sur l'utilisation **awscurl** de l'authentification IAM, consultez[Utiliser `awscurl` avec des informations d'identification temporaires pour se connecter en toute sécurité à un cluster de base 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 à la AWS CLI place.

------

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

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

Si vous utilisez les [blocs-notes Neptune Graph](graph-notebooks.md), la magie des `%stream_viewer` lignes fournit une interface visuelle permettant de parcourir les enregistrements de flux de manière interactive sans écrire de code. Exécutez ce qui suit dans une cellule du bloc-notes :

```
%stream_viewer
```

Vous pouvez éventuellement spécifier la langue de requête et le format 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 1.0.5.1 et antérieures du moteur.