Modelo de Datos de Desplazamiento de Mongo

Lista de Colección

MongoOffset

Esta colección rastrea las últimas entradas de diario que han sido procesadas por un event procesador para una etiqueta dada y eventProcessorId.

Diagrama de Visión General

A continuación se presenta un diagrama que muestra la colección mongoOffset en su totalidad:

bar

Descripción General de la Colección

MongoOffset

Campos

A continuación se presentan los campos para la colección mongoOffset:

Field Description Example

_id

PK - We set this value at the application level to be a complex type referencing the tag and eventProcessorId

{"tag" : "tag-0", "eventProcessorId" : "IpfProcessingDataEventProcessor"}

offset

Stores the latest offset value as a MongoDB ObjectID

{"objectId" : "644a63481ddeb960823f6cac"}

Ejemplo de Registro

{
    "_id": {
        "tag": "tag-0",
        "eventProcessorId": "IpfProcessingDataEventProcessor"
    },
    "offset": {
        "objectId": "644a63481ddeb960823f6cac",
        "_class": "com.iconsolutions.akka.persistence.mongodb. MongoDBReadJournal$ObjectIdOffset"
    },
    "_class": "com.iconsolutions.ipf.core.platform.journal.mongo. MongoOffset"
}

Índices

A continuación se presentan los índices para la colección mongoOffset:

Index Name Fields Description

_id_

_id (ascending)

Complex type consisting of the tag and eventProcessorId