MongoDB
 sql >> Teknologi Basis Data >  >> NoSQL >> MongoDB

Agregasi Mongodb berdasarkan hari berdasarkan cap waktu unix

MongoDB 4.0 dan yang lebih baru

Gunakan $toDate

db.session_log.aggregate([
    { "$group": {
        "_id": {
            "$dateToString": {
                "format": "%Y-%m-%d",
                "date": {
                    "$toDate": { 
                        "$multiply": [1000, "$LASTLOGIN"]
                    }
                }
            }
        },
        "count": { "$sum": 1 }
    } }
])

atau $convert

db.session_log.aggregate([
    { "$group": {
        "_id": {
            "$dateToString": {
                "format": "%Y-%m-%d",
                "date": {
                    "$convert": { 
                        "input":  { 
                            "$multiply": [1000, "$LASTLOGIN"] 
                        }, 
                        "to": "date"
                    }
                }
            }
        },
        "count": { "$sum": 1 }
    } }
])

MongoDB>=3.0 dan <4.0:

db.session_log.aggregate([
    { "$group": {
        "_id": {
            "$dateToString": {
                "format": "%Y-%m-%d",
                "date": {
                    "$add": [
                        new Date(0), 
                        { "$multiply": [1000, "$LASTLOGIN"] }
                    ]
                }
            }
        },
        "count": { "$sum": 1 }
    } }
])

Anda perlu mengonversi LASTLOGIN bidang ke stempel waktu milidetik dengan mengalikan nilainya dengan 1000

{ "$multiply": [1000, "$LASTLOGIN"] }

, lalu ubah menjadi tanggal

"$add": [
    new Date(0),
    { "$multiply": [1000, "$LASTLOGIN"] }
]

dan ini dapat dilakukan di $project pipeline dengan menambahkan waktu milidetik Anda ke Date(0) zero nol-milidetik objek, lalu ekstrak $year , $month , $dayOfMonth bagian dari tanggal konversi yang kemudian dapat Anda gunakan di $group pipeline untuk mengelompokkan dokumen berdasarkan hari.

Dengan demikian Anda harus mengubah saluran agregasi Anda menjadi ini:

var project = {
    "$project":{ 
        "_id": 0,
        "y": {
            "$year": {
                "$add": [
                    new Date(0),
                    { "$multiply": [1000, "$LASTLOGIN"] }
                ]
            }
        },
        "m": {
            "$month": {
                "$add": [
                    new Date(0),
                    { "$multiply": [1000, "$LASTLOGIN"] }
                ]
            }
        }, 
        "d": {
            "$dayOfMonth": {
                "$add": [
                    new Date(0),
                    { "$multiply": [1000, "$LASTLOGIN"] }
                ]
            }
        }
    } 
},
group = {   
    "$group": { 
        "_id": { 
            "year": "$y", 
            "month": "$m", 
            "day": "$d"
        },  
        "count" : { "$sum" : 1 }
    }
};

Menjalankan alur agregasi:

db.session_log.aggregate([ project, group ])

akan memberikan hasil berikut (berdasarkan dokumen contoh):

{ "_id" : { "year" : 2014, "month" : 1, "day" : 3 }, "count" : 1 }

Peningkatannya adalah menjalankan hal di atas dalam satu saluran sebagai

var group = {   
    "$group": { 
        "_id": {    
            "year": {
                "$year": {
                    "$add": [
                        new Date(0),
                        { "$multiply": [1000, "$LASTLOGIN"] }
                    ]
                }
            },
            "mmonth": {
                "$month": {
                    "$add": [
                        new Date(0),
                        { "$multiply": [1000, "$LASTLOGIN"] }
                    ]
                }
            }, 
            "day": {
                "$dayOfMonth": {
                    "$add": [
                        new Date(0),
                        { "$multiply": [1000, "$LASTLOGIN"] }
                    ]
                }
            }
        },  
        "count" : { "$sum" : 1 }
    }
};

Menjalankan alur agregasi:

db.session_log.aggregate([ group ])


  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Tidak dapat membuat instance proxy... Tidak dapat menemukan konstruktor tanpa parameter

  2. Impor lebih dari 1 file json menggunakan mongoimport

  3. Perbarui objek bersarang di MongoDB jika ada, jika tidak tambahkan

  4. MongoDB:Cara mendapatkan presisi N desimal dalam kueri

  5. Gunakan hasil dari kueri sebelumnya di kueri lain di mongodb