

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

# 讀取 Neptune 串流資料
<a name="streams-using-reading"></a>

下列範例示範如何從屬性圖形串流端點讀取記錄。您可以使用 AWS CLI、適用於 Python 的 AWS SDK (Boto3)**awscurl**、 或 **curl**。

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

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

若要從串流中的特定位置讀取，請使用 `--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
```

如需詳細資訊，請參閱《 AWS CLI 命令參考》中的 [get-propertygraph-stream](https://docs.aws.amazon.com/cli/latest/reference/neptunedata/get-propertygraph-stream.html)。

------
#### [ 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))
```

若要透過串流分頁，請在回應`lastEventId`中使用`opNum`來自 的 `commitNum`和 ：

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

**注意**  
此範例假設您的 AWS 登入資料已在您的環境中設定。將 {{us-east-1}} 取代為 Neptune 叢集的區域。

如需使用 **awscurl**搭配 IAM 身分驗證的詳細資訊，請參閱 [使用 `awscurl` 搭配臨時憑證，安全地連線至啟用 IAM 身分驗證的資料庫叢集](iam-auth-connect-command-line.md#iam-auth-connect-awscurl)。

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

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

**注意**  
只有在 Neptune 叢集上停用 IAM 身分驗證時，才能使用**curl**無 SigV4 簽署。如果已啟用 IAM 身分驗證，請 AWS CLI 改用 **awscurl**或 。

------

對於 SPARQL 圖形，`/sparql/stream`請在上述範例中將 取代`/propertygraph/stream`為 。使用 AWS CLI 或 SDK 時，請`client.get_sparql_stream()`改用 `get-sparql-stream`或 。

## 在圖形筆記本中檢視串流資料
<a name="streams-using-notebook"></a>

如果您使用 [Neptune 圖形筆記本](graph-notebooks.md)，`%stream_viewer`行魔法會提供視覺化界面，以互動方式瀏覽串流記錄，而無需撰寫程式碼。在筆記本儲存格中執行下列項目：

```
%stream_viewer
```

您可以選擇性地指定查詢語言和頁面大小：

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

如需詳細資訊，請參閱[`%stream_viewer` 行魔法](notebooks-magics.md#notebooks-line-magics-stream-viewer)。

**注意**  
只有引擎版本 1.0.5.1 和更早版本才完全支援魔`%stream_viewer`術。