$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

Pase $currentDate: {} como valor de cualquier expresión que acepte un Valor ISODate.

Ejemplos

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

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

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

Puede utilizar la expresión $currentDate varias veces en su canal de procesamiento de flujo para generar múltiples marcas de tiempo para varias etapas dentro de un procesador de flujo.

{
  "$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
}