`$currentDate` (스트림 처리)

정의

$currentDate 표현식 Atlas Stream Processing 스트림 처리 공간의 시스템 시간을 반환합니다. 이렇게 하면 스트리밍 데이터 파이프라인 내에서 추가하는 시간 필드가 처리된 각 메시지에 대해 최신 상태로 유지됩니다.

$currentDate: $currentDate 표현식은 빈 객체 {}의 형식을 취합니다.

구문

$currentDate 표현식은 빈 객체 {}이며 내부 구문이 없습니다.

행동

$currentDate: {}를 ISODate 값을 허용하는 모든 표현식의 값으로 전달합니다.

예시

다음 예시는 주어진 스트림 프로세서의 각 출력 문서에 정확한 타임스탬프를 보장하기 위해 $currentDate 표현식을 기본적으로 사용하는 방법을 보여줍니다.

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

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

스트림 처리 파이프라인에서 $currentDate 표현식을 여러 번 사용하여 스트림 프로세서 내의 다양한 단계에 대한 여러 타임스탬프를 생성할 수 있습니다.

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

돌아가기

$convert

$meta