Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Les exemples suivants montrent comment accéder aux données de flux des journaux de modifications dans Amazon Neptune.
Rubriques
Journal des modifications AT_SEQUENCE_NUMBER
L'exemple suivant montre un journal des modifications Gremlin ou openCypher AT_SEQUENCE_NUMBER.
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
}Celui-ci montre un exemple SPARQL de journal des modifications AT_SEQUENCE_NUMBER.
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
}Journal des modifications AFTER_SEQUENCE_NUMBER
L'exemple suivant montre un journal des modifications Gremlin ou openCypher AFTER_SEQUENCE_NUMBER.
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
}Journal des modifications TRIM_HORIZON
L'exemple suivant montre un journal des modifications Gremlin ou openCypher TRIM_HORIZON.
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
}Journal des modifications LATEST
L'exemple suivant montre un journal des modifications Gremlin ou openCypher LATEST. Notez que les paramètres d'API limit, commitNum et opNum sont totalement facultatifs.
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
}Journal des modifications Compression
L'exemple suivant montre un journal des modifications de compression Gremlin ou 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
}