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

자세한 내용은 AWS CLI 명령 참조의 get-propertygraph-stream을 참조하세요.

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에서의 commitNum 및를 사용합니다opNum.

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

IAM 인증과 awscurl 함께를 사용하는 방법에 대한 자세한 내용은 섹션을 참조하세요임시 보안 인증 정보와 awscurl을 사용하여 IAM 인증이 활성화된 상태에서 DB 클러스터에 안전하게 연결.

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