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

定義

$currentDate 式は、Atlas Stream Processing が評価されるたびに、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}