Skip to main content

Striim Cloud 4.1.0 documentation

Mongo Cosmos DB Reader example output

Initial load

When Mode is InitialLoad, the Operation Name is reported as SELECT, even though it is actually an insert.

JsonNodeEvent{
   data:{
      "_id":{
         "$oid":"620365482b7622580d9e6e43"
      },
      "state":4,
      "name":"Willard",
      "last_name":"Valek",
      "email":"wvalek3@vk.com",
      "gender":"Male",
      "ip_address":"67.76.188.26",
      "ttl":-1
   } metadata:{
      "CollectionName":"collection1",
      "OperationName":"SELECT",
      "DatabaseName":"testDB",
      "NameSpace":"testDB.collection1",
      "id":{
         "$oid":"620365482b7622580d9e6e43"
      },
      "TimeStamp":1644429967516
   } userdata:null
   } removedfields:null
};
Incremental - insert
JsonNodeEvent {
   data:{
      "id":"updated",
      "type":2,
      "name":"Alex"
   } metadata:{
      "CollectionName":"container1",
      "OperationName":"INSERT",
      "DatabaseName":"testDB",
      "DocumentKey":{
         "id":"updated",
         "type":2
      },
      "NameSpace":"testDB.container1",
      "TimeStamp":1646819481
   } userdata:null
   } removedfields:null
};
Incremental - delete

Note that this includes the IsDeleted field discussed in Cosmos DB setup for Mongo Cosmos DB Reader.

JsonNodeEvent {
   data:{
      "id":"updated",
      "type":2,
      "name":"Alex",
      "IsDeleted":"Yes"
   } metadata:{
      "CollectionName":"container1",
      "OperationName":"DELETE",
      "DatabaseName":"testDB",
      "DocumentKey":{
         "id":"updated",
         "type":2
      },
      "NameSpace":"testDB.container1",
      "TimeStamp":1646819488
   } userdata:null
   } removedfields:null
};