$currentDate (Processamento de Stream)

Definição

A expressão $currentDate retorna a hora do sistema da instância de processamento de fluxo cada vez que o Atlas Stream Processing a avalia. Isso garante que os campos de tempo que você adiciona em um pipeline de dados de streaming permaneçam atualizados para cada mensagem processada.

$currentDate

Uma expressão $currentDate assume a forma de um objeto vazio {}.

Sintaxe

A expressão $currentDate é um objeto vazio {} e não possui sintaxe interna.

Comportamento

Passe $currentDate: {} como o valor de qualquer expressão que aceite umvalor ISODate .

Exemplos

O exemplo a seguir demonstra um uso básico da expressão $currentDate para garantir timestamps precisos para cada documento de saída de um processador de stream específico.

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

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

Você pode usar a expressão $currentDate várias vezes em seu pipeline de processamento de fluxo para gerar múltiplos timestamps para diferentes estágios dentro de um processador de fluxo.

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