$currentDate (Procesamiento de flujo)

Definición

La expresión $currentDate devuelve la hora del sistema de tu espacio de trabajo de stream processing cada vez que Atlas Stream Processing la evalúa. Esto asegura que los campos de tiempo que añadís desde un pipeline de datos en transmisión se mantengan actualizados para cada mensaje procesado.

$currentDate

Una expresión $currentDate toma la forma de un objeto vacío {}.

Sintaxis

La expresión $currentDate es un objeto vacío {} y no tiene sintaxis interna.

Comportamiento

Pasa $currentDate: {} como el valor de cualquier expresión que acepte un ISODate value.

Ejemplos

El siguiente ejemplo muestra un uso básico de la expresión $currentDate para garantizar marcas de tiempo precisas para cada documento de salida de un determinado procesador de flujo.

{
  "$addFields": {
    "time1": {
      "$currentDate": {}
    }
  }
}

{
  "a": 1,
  "time1": ISODate("2025-01-24T11:57:22.033Z")
}

Puede utilizar la expresión $currentDate varias veces en su pipeline de Stream Processing para generar varias marcas de tiempo para distintas etapas dentro de un procesador de flujos.

{
  "$addFields": {
    "time1": {
      "$currentDate": {}
    }
  },
  "$group": {
    "_id": "$time1",
    "count": {
      "$count": {}
    }
  },
  "$addFields": {
    "time1": "$_id",
    "time2": {
      "$currentDate": {}
    }
  }
}

{
  "time1": ISODate("2025-01-24T11:57:22.033Z"),
  "time2": ISODate("2025-01-24T11:57:26.036Z"),
  "count": 1
}