4.4.6.4. 更新イベント

サンプル customers コレクションにある更新の変更イベントの値には、そのコレクションの作成イベントと同じスキーマがあります。同様に、イベント値のペイロードは同じ構造を持ちます。ただし、イベント値ペイロードでは更新イベントに異なる値が含まれます。更新イベントには after の値はありません。その代わりに、以下の 2 つのフィールドがあります。

patch は、べき等更新操作の JSON 表現が含まれる文字列フィールドです。
filter は、更新の選択基準の JSON 表現が含まれる文字列フィールドです。filter 文字列には、シャード化コレクションの複数のシャードキーフィールドを含めることができます。

以下は、コネクターによって customers コレクションでの更新に生成されるイベントの変更イベント値の例になります。

{
    "schema": { ... },
    "payload": {
      "op": "u", 
      "ts_ms": 1465491461815, 
      "patch": "{\"$set\":{\"first_name\":\"Anne Marie\"}}", 
      "filter": "{\"_id\" : {\"$numberLong\" : \"1004\"}}", 
      "source": { 
        "version": "1.4.2.Final",
        "connector": "mongodb",
        "name": "fulfillment",
        "ts_ms": 1558965508000,
        "snapshot": true,
        "db": "inventory",
        "rs": "rs0",
        "collection": "customers",
        "ord": 6,
        "h": 1546547425148721999
      }
    }
  }

{
    "schema": { ... },
    "payload": {
      "op": "u",


      "ts_ms": 1465491461815,


      "patch": "{\"$set\":{\"first_name\":\"Anne Marie\"}}",


      "filter": "{\"_id\" : {\"$numberLong\" : \"1004\"}}",


      "source": {


        "version": "1.4.2.Final",
        "connector": "mongodb",
        "name": "fulfillment",
        "ts_ms": 1558965508000,
        "snapshot": true,
        "db": "inventory",
        "rs": "rs0",
        "collection": "customers",
        "ord": 6,
        "h": 1546547425148721999
      }
    }
  }

Copy to Clipboard

Toggle word wrap

Expand

表4.5 更新イベント値フィールドの説明
項目	フィールド名	説明
1	`op`	コネクターによってイベントが生成される原因となった操作の型を記述する必須文字列。この例では、`u` は操作によってドキュメントが更新されたことを示しています。
2	`ts_ms`	コネクターがイベントを処理した時間を表示する任意のフィールド。この時間は、Kafka Connect タスクを実行している JVM のシステムクロックを基にします。 `source` オブジェクトで、`ts_ms` は変更がデータベースに加えられた時間を示します。`payload.source.ts_ms` の値を `payload.ts_ms` の値と比較することにより、ソースデータベースの更新と Debezium との間の遅延を判断できます。
3	`patch`	ドキュメントへの実際の MongoDB のべき等変更の JSON 文字列表現が含まれます。この例では、更新で `first_name` フィールドを新しい値に変更されています。更新イベント値には `after` フィールドが含まれません。
4	`filter`	更新するドキュメントの特定に使用された MongoDB 選択基準の JSON 文字列表現が含まれます。
5	`source`	イベントのソースメタデータを記述する必須のフィールド。このフィールドには、同じコレクションの作成イベントと同じ情報が含まれますが、oplog の異なる位置からのイベントであるため、値は異なります。ソースメタデータには以下が含まれています。 Debezium バージョン。イベントを生成したコネクターの名前。生成されたイベントの namespace を形成し、コネクターが書き込む Kafka トピック名で使用される、MongoDB レプリカセットの論理名。更新されたドキュメントが含まれるコレクションおよびデータベースの名前。イベントがスナップショットの一部である場合。データベースで変更が加えられた時点のタイムスタンプおよびタイムスタンプ内のイベントの順序。 MongoDB 操作の一意の識別子。これは MongoDB のバージョンに依存します。これは、oplog イベントの `h` フィールド、または oplog イベントの `lsid` および `txnNumber` フィールドを表す `stxnid` という名前のフィールドです。

警告

Debezium 変更イベントでは、MongoDB は patch フィールドの内容を提供します。このフィールドの形式は、MongoDB データベースのバージョンによって異なります。したがって、新しい MongoDB データベースバージョンにアップグレードする場合は、形式が変更された可能性があるため注意してください。本書のサンプルは、MongoDB 3.4 から取得したため、ご使用のアプリケーションではイベントの形式が異なる場合があります。

注記

MongoDB の oplog では、更新イベントには変更されたドキュメントの前または後の状態は含まれません。そのため、Debezium コネクターがこの情報を提供することはできません。ただし、Debezium コネクターは作成および 読み取り イベントでドキュメントの開始状態を提供します。ストリームのダウンストリームのコンシューマーは、ドキュメントごとに最新状態を維持し、新しいイベントの状態を保存された状態に比較することで、ドキュメント状態を再構築できます。Debezium コネクターはこの状態を維持できません。

トップに戻る

4.4.6.4. 更新イベント

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

多様性を受け入れるオープンソースの強化

会社概要

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links