/ /

Driver de sincronización de Kotlin

Data Formats

Docs Home

Librerías de clientes

Kotlin

Driver de sincronización de Kotlin

Data Formats

Colecciones de series de tiempo

Overview

En esta guía, puede aprender a utilizar el controlador Kotlin Sync para almacenar e interactuar con datos de series temporales.

Los datos de series de tiempo se componen de los siguientes componentes:

Cantidad medida
Marca de tiempo para la medición
Metadatos que describen la medición

La siguiente tabla describe situaciones de muestra para las que podría almacenar datos de series de tiempo:

Situación	Cantidad medida	Metadata
Registro de ventas mensuales por industria	Ingresos en USD	Empresa, país
Seguimiento de los cambios meteorológicos	Nivel de precipitación	Ubicación, tipo de sensor
Registro de fluctuaciones en los precios de la vivienda	Precio de alquiler mensual	Ubicación, moneda

Crear una colección de series de tiempo

Importante

Versión de servidor para colecciones de series temporales

Para crear e interactuar con colecciones de series temporales, debe estar conectado a una implementación que ejecute MongoDB Server 5.0 o posterior.

Puede crear una colección de series temporales para almacenar datos de series temporales. Para crear una colección de series temporales, pase los siguientes parámetros a createCollection() :

El nombre de la nueva colección a crear
A CreateCollectionOptions objeto con el TimeSeriesOptions establecido usando el método timeSeriesOptions()

Ejemplo

Este ejemplo crea la colección de series temporales october2024 en la base de datos fall_weather con la opción timeField establecida en el campo "timestamp":

val database = mongoClient.getDatabase("fall_weather")
val tsOptions = TimeSeriesOptions("timestamp")
val collectionOptions = CreateCollectionOptions().timeSeriesOptions(tsOptions)
database.createCollection("october2024", collectionOptions)

Para verificar que ha creado correctamente la colección de series de tiempo, ejecute el método listCollections() en la base de datos e imprima los resultados:

val results = database.listCollections()
val jsonSettings = JsonWriterSettings.builder().indent(true).build()
results.forEach { result ->
    println(result.toJson(jsonSettings))
}

 {
   "name": "october2024",
   "type": "timeseries",
   "options": {
     "timeseries": {
       "timeField": "temperature",
       "granularity": "seconds",
       "bucketMaxSpanSeconds": 3600
     }
   },
   "info": {
     "readOnly": false
   }
}
...

Almacenar datos de series temporales

Puede insertar datos en una colección de series de tiempo utilizando los métodos insertOne() o insertMany() y especificando la medición, la marca de tiempo y los metadatos en cada documento insertado.

Tip

Para obtener más información sobre cómo insertar documentos en una colección, consulte la Guía deinserción de documentos.

Ejemplo

Este ejemplo inserta datos de temperatura de la ciudad de Nueva York en la october2024 colección de series temporales creada en el ejemplo "Crear una colección de series temporales". Cada documento contiene los siguientes campos:

temperature, que almacena mediciones de temperatura en grados Fahrenheit
location, que almacena metadatos de ubicación
timestamp, que almacena el tiempo de recolección de mediciones

val collection = database.getCollection<Document>("october2024")
// Temperature data for October 1, 2024
val temperature1 = Document("temperature", 54)
                    .append("location", "New York City")
                    .append("timestamp", Date(1727755200000))
// Temperature data for October 2, 2024
val temperature2 = Document("temperature", 55)
                    .append("location", "New York City")
                    .append("timestamp", Date(1727841600000))
collection.insertMany(listOf(temperature1, temperature2))

Consulta de datos de series temporales

Puede utilizar la misma sintaxis y convenciones para consultar los datos almacenados en una colección de series temporales que para realizar operaciones de lectura o agregación en otras colecciones. Para obtener más información sobre estas operaciones, consulte la sección "Información adicional".

Información Adicional

Para conocer más sobre los conceptos mencionados en esta guía, consulta las siguientes entradas del manual de servidor de MongoDB:

Para obtener más información sobre cómo realizar operaciones de lectura, consulte Buscar documentos.

Para obtener más información sobre cómo realizar operaciones de agregación, consulte la guía Operaciones de agregación.

Documentación de la API

Para obtener más información sobre los métodos mencionados en esta guía, consulte la siguiente documentación de API:

Volver

BSON

JSON extendido