View a markdown version of this page

讀取 Neptune 串流資料 - Amazon Neptune
在筆記本中檢視

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

讀取 Neptune 串流資料

下列範例示範如何從屬性圖形串流端點讀取記錄。您可以使用 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。

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 身分驗證的資料庫叢集。

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或 。

在圖形筆記本中檢視串流資料

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

%stream_viewer

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

%stream_viewer sparql --limit 20

如需詳細資訊，請參閱%stream_viewer 行魔法。

注意

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