Migrar datos a una colección de series temporales con agregación

Crear un campo de metadatos.

Si su colección no incluye un campo que permita identificar cada serie, transforme sus datos para definir uno. En este ejemplo, el campo metaData se convierte en el metaField de la colección de series temporales que cree.

La siguiente pipeline realiza las siguientes operaciones:

• Utiliza para agregar $addFields un metaData campo a la weather_data colección.

• Utiliza para incluir o excluir los campos restantes en el $project documento.

db.weather_data.aggregate([
{
   $addFields: {
      metaData: {
         "st": "$st",
         "position": "$position",
         "elevation": "$elevation",
         "callLetters": "$callLetters",
         "qualityControlProcess": "$qualityControlProcess",
         "type": "$type"
      }
   },
},
{
   $project: {
      _id: 1,
      ts: 1,
      metaData: 1,
      dataSource: 1,
      airTemperature: 1,
      dewPoint: 1,
      pressure: 1,
      wind: 1,
      visibility: 1,
      skyCondition: 1,
      sections: 1,
      precipitationEstimatedObservation: 1
   }
}
])

Crea tu colección de series de tiempo e inserta tus datos.

Agregue una $out etapa de agregación a su pipeline para crear una colección de series temporales e insertar sus datos en ella. El pipeline a continuación realiza las siguientes operaciones:

• Utiliza con $out la timeseries opción para crear una weathernew colección de series de tiempo en la mydatabase base de datos.

• Define el campo metaData como el metaField de la colección weathernew.

• Define el campo ts como el timeField de la colección weathernew.

  Nota

  El timeField de una colección de series de tiempo debe ser un tipo de fecha.

{
   $out: {
      db: "mydatabase",
      coll: "weathernew",
      timeseries: {
         timeField: "ts",
         metaField: "metaData",
         granularity: "seconds"
      }
   }
}

Para la sintaxis de la etapa de agregación,$out consulte. Para una explicación completa de las opciones de series temporales, consulte la Referencia de campos de series temporales.

Revise sus datos.

Después de ejecutar esta secuencia de agregación, puede usar para ver un documento en findOne() su weathernew colección de series de tiempo:

db.weathernew.findOne()

La operación devuelve el siguiente documento:

   {
      _id: ObjectId("5553a998e4b02cf7151190b8"),
      ts: ISODate("1984-03-05T13:00:00Z"),
      metaData: {
         st: "x+47600-047900",
         position: {
            type: "Point",
            coordinates: [ -47.9, 47.6 ]
         },
         elevation: 9999,
         callLetters: "VCSZ",
         qualityControlProcess: "V020",
         type: "FM-13"
      },
      dataSource: "4",
      airTemperature: { value: -3.1, quality: "1" },
      dewPoint: { value: 999.9, quality: "9" },
      pressure: { value: 1015.3, quality: "1" },
      wind: {
         direction: { angle: 999, quality: "9" },
         type: "9",
         speed: { rate: 999.9, quality: "9" }
      },
      visibility: {
         distance: { value: 999999, quality: "9" },
         variability: { value: "N", quality: "9" }
      },
      skyCondition: {
         ceilingHeight: { value: 99999, quality: "9", determination: "9" },
         cavok: "N"
      },
      sections: [ "AG1" ],
      precipitationEstimatedObservation: { discrepancy: "2", estimatedWaterDepth: 999 }
   }