读取 Neptune 流数据

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

有关更多信息，请参阅《命令参考》中的 get-propertygraph-stream。 AWS CLI

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

要对直播进行分页，请在响应opNumlastEventId中使用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 https://your-neptune-endpoint:port/propertygraph/stream?limit=10 \
  --region us-east-1 \
  --service neptune-db

有关awscurl与 IAM 身份验证配合使用的更多信息，请参阅使用带有临时证书的 awscurl 安全地连接到启用 IAM 身份验证的数据库集群。

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