`$currentDate` （ストリームプロセシング）

定義

$currentDate式は、Atlas Stream Processing が評価するたびにストリーム処理ワークスペースのシステム時間を返します。これにより、ストリーミングデータパイプライン内から追加する時間フィールドが、処理されたメッセージごとに最新の状態に保たれます。

$currentDate: $currentDate 式は、空のオブジェクト {} の形式を取ります。

構文

$currentDate式は空のオブジェクト{}であり、内部構文がありません。

動作

ISODate 値を受け入れる任意の式の値として $currentDate: {} を渡します。

例

次の例は、特定のストリームプロセッサからの各出力ドキュメントに正確なタイムスタンプを確保するための $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