Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
I seguenti esempi mostrano come accedere ai dati del flusso di log delle modifiche in Amazon Neptune.
Argomenti
Change Log AT_SEQUENCE_NUMBER
L'esempio seguente mostra un change log AT_SEQUENCE_NUMBER
di Gremlin o openCypher.
curl -s "https://Neptune-DNS
:8182/propertygraph/stream?limit=1&commitNum=1&opNum=1&iteratorType=AT_SEQUENCE_NUMBER" |jq
{
"lastEventId": {
"commitNum": 1,
"opNum": 1
},
"lastTrxTimestamp": 1560011610678,
"format": "PG_JSON",
"records": [
{
"eventId": {
"commitNum": 1,
"opNum": 1
},
"commitTimestamp": 1560011610678,
"data": {
"id": "d2b59bf8-0d0f-218b-f68b-2aa7b0b1904a",
"type": "vl",
"key": "label",
"value": {
"value": "vertex",
"dataType": "String"
}
},
"op": "ADD",
"isLastOp": true
}
],
"totalRecords": 1
}
Questo esempio mostra un change log AT_SEQUENCE_NUMBER
di SPARQL.
curl -s "https://localhost:8182/sparql/stream?limit=1&commitNum=1&opNum=1&iteratorType=AT_SEQUENCE_NUMBER" |jq
{
"lastEventId": {
"commitNum": 1,
"opNum": 1
},
"lastTrxTimestamp": 1571252030566,
"format": "NQUADS",
"records": [
{
"eventId": {
"commitNum": 1,
"opNum": 1
},
"commitTimestamp": 1571252030566,
"data": {
"stmt": "<https://test.com/s> <https://test.com/p> <https://test.com/o> .\n"
},
"op": "ADD",
"isLastOp": true
}
],
"totalRecords": 1
}
Change Log AFTER_SEQUENCE_NUMBER
L'esempio seguente mostra un change log AFTER_SEQUENCE_NUMBER
di Gremlin o openCypher.
curl -s "https://Neptune-DNS
:8182/propertygraph/stream?limit=1&commitNum=1&opNum=1&iteratorType=AFTER_SEQUENCE_NUMBER" |jq
{
"lastEventId": {
"commitNum": 2,
"opNum": 1
},
"lastTrxTimestamp": 1560011633768,
"format": "PG_JSON",
"records": [
{
"commitTimestamp": 1560011633768,
"eventId": {
"commitNum": 2,
"opNum": 1
},
"data": {
"id": "d2b59bf8-0d0f-218b-f68b-2aa7b0b1904a",
"type": "vl",
"key": "label",
"value": {
"value": "vertex",
"dataType": "String"
}
},
"op": "REMOVE",
"isLastOp": true
}
],
"totalRecords": 1
}
Change Log TRIM_HORIZON
L'esempio seguente mostra un change log TRIM_HORIZON
di Gremlin o openCypher.
curl -s "https://Neptune-DNS
:8182/propertygraph/stream?limit=1&iteratorType=TRIM_HORIZON" |jq
{
"lastEventId": {
"commitNum": 1,
"opNum": 1
},
"lastTrxTimestamp": 1560011610678,
"format": "PG_JSON",
"records": [
{
"commitTimestamp": 1560011610678,
"eventId": {
"commitNum": 1,
"opNum": 1
},
"data": {
"id": "d2b59bf8-0d0f-218b-f68b-2aa7b0b1904a",
"type": "vl",
"key": "label",
"value": {
"value": "vertex",
"dataType": "String"
}
},
"op": "ADD",
"isLastOp": true
}
],
"totalRecords": 1
}
Change Log LATEST
L'esempio seguente mostra un change log LATEST
di Gremlin o openCypher. Notare che i parametri API limit
, commitNum
e opNum
sono completamente facoltativi.
curl -s "https://Neptune-DNS
:8182/propertygraph/stream?iteratorType=LATEST" | jq
{
"lastEventId": {
"commitNum": 21,
"opNum": 4
},
"lastTrxTimestamp": 1634710497743,
"format": "PG_JSON",
"records": [
{
"commitTimestamp": 1634710497743,
"eventId": {
"commitNum": 21,
"opNum": 4
},
"data": {
"id": "24be4e2b-53b9-b195-56ba-3f48fa2b60ac",
"type": "e",
"key": "label",
"value": {
"value": "created",
"dataType": "String"
},
"from": "4",
"to": "5"
},
"op": "REMOVE",
"isLastOp": true
}
],
"totalRecords": 1
}
Log delle modifiche di compressione
L'esempio seguente mostra un change log di compressione di Gremlin o openCypher.
curl -sH \
"Accept-Encoding: gzip" \
"https://Neptune-DNS
:8182/propertygraph/stream?limit=1&commitNum=1" \
-H "Accept-Encoding: gzip" \
-v |gunzip -|jq
> GET /propertygraph/stream?limit=1 HTTP/1.1
> Host: localhost:8182
> User-Agent: curl/7.64.0
> Accept: /
> Accept-Encoding: gzip
*> Accept-Encoding: gzip*
>
< HTTP/1.1 200 OK
< Content-Type: application/json; charset=UTF-8
< Connection: keep-alive
*< content-encoding: gzip*
< content-length: 191
<
{ [191 bytes data]
Connection #0 to host localhost left intact
{
"lastEventId": "1:1",
"lastTrxTimestamp": 1558942160603,
"format": "PG_JSON",
"records": [
{
"commitTimestamp": 1558942160603,
"eventId": "1:1",
"data": {
"id": "v1",
"type": "vl",
"key": "label",
"value": {
"value": "person",
"dataType": "String"
}
},
"op": "ADD",
"isLastOp": true
}
],
"totalRecords": 1
}