Datos de Time Series

Overview

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

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:

Crear una colección de series de tiempo

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() :

• Nombre de la nueva colección a crear

• CreateCollectionOptions objeto con el TimeSeriesOptions establecido usando el método timeSeriesOptions()

val database = mongoClient.getDatabase("fall_weather")
val tsOptions = TimeSeriesOptions("timestamp").metaField("location")
val collectionOptions = CreateCollectionOptions().timeSeriesOptions(tsOptions)
val createObservable = database.createCollection("october2024", collectionOptions)
Await.result(createObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

val listObservable = database.listCollections()
val list = Await.result(listObservable.toFuture(), Duration(10, TimeUnit.SECONDS))
val jsonSettings = JsonWriterSettings.builder().indent(true).build()
list.foreach(collection => {
  println(collection.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.

val collection = database.getCollection("october2024")
val temperatures = Seq(
  Document("timestamp" -> BsonDateTime(1727755200000L), "temperature" -> 54, "location" -> "New York City"),
  Document("timestamp" -> BsonDateTime(1727841600000L), "temperature" -> 55, "location" -> "New York City"),
)
val insertObservable = collection.insertMany(temperatures)
Await.result(insertObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

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:

• Time Series

• Crear y ejecutar un query en una colección de series de tiempo

• Establece la granularidad para los datos de series de tiempo

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

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