Neptune Streams API レスポンス形式 - Amazon Neptune

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Neptune Streams API レスポンス形式

Neptune Streams REST APIリクエストへのレスポンスには、次のフィールドがあります。

  • lastEventId - ストリームレスポンスの最後の変更のシーケンス識別子。イベント ID は 2 つのフィールドで構成されます。commitNum はグラフを変更したトランザクションを識別し、opNum はそのトランザクション内の特定のオペレーションを識別します。以下の例ではこれを示しています。

      "eventId": {
    "commitNum": 12,
    "opNum": 1
  }

  • lastTrxTimestamp - トランザクションのコミットがリクエストされた時間 (Unix エポックからのミリ秒単位)。

  • format - 返される変更レコードのシリアル化形式。指定できる値は、Gremlin または openCypher 変更レコードPG_JSONの場合は 、SPARQL 変更レコードNQUADSの場合は です。

  • records - レスポンスに含まれるシリアル化された変更ログストリームレコードの配列。records 配列内の各レコードには、次のフィールドが含まれます。

    • commitTimestamp - トランザクションのコミットがリクエストされた時間 (Unix エポックからのミリ秒単位)。

    • eventId - ストリームレスポンスの最後の変更のシーケンス識別子。

    • data – シリアル化された Gremlin、SPARQL、または OpenCypher の変更レコード。各レコードのシリアル化形式については、次のセクション Neptune Streams のシリアル化形式 で詳しく説明します。

    • op — 変更を作成した操作。

    • isLastOp - この操作がトランザクションの最後の操作である場合にのみ表示されます。存在する場合は、true に設定されます。トランザクション全体が確実に消費されるようにする場合に便利です。

  • totalRecords - レスポンスのレコードの総数。

例えば、次のレスポンスは、複数の操作を含むトランザクションの Gremlin 変更データを返します。

{
  "lastEventId": {
    "commitNum": 12,
    "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"
    }
  ],
  "totalRecords": 1
}

次のレスポンスは、トランザクションの最後のオペレーション (トランザクション番号 97 EventId(97, 1)で によって識別されるオペレーション) の SPARQL 変更データを返します。

{
  "lastEventId": {
    "commitNum": 97,
    "opNum": 1
  },
  "lastTrxTimestamp": 1561489355102,
  "format": "NQUADS",
  "records": [
    {
      "commitTimestamp": 1561489355102,
      "eventId": {
        "commitNum": 97,
        "opNum": 1
      },
      "data": {
        "stmt": "<https://test.com/s> <https://test.com/p> <https://test.com/o> .\n"
      },
      "op": "ADD",
      "isLastOp": true
    }
  ],
  "totalRecords": 1
}