-
Notifications
You must be signed in to change notification settings - Fork 1
/
DBInit.js
24 lines (21 loc) · 805 Bytes
/
DBInit.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
conn = new Mongo();
db = conn.getDB("RFID");
for (i = 0; i < 4; i++){
db["raw_data_192.168.0.69"].aggregate([
{$sort:{measurement_uuid:1}},
{$match:{"data.AntennaPort" : {$mod:[4, i]}}},
{$project:{RSSI:"$data.RSSI",EPC:"$data.EPC", measurement_uuid:1}},
{$group:{_id: "$EPC", obs_by:{$push:{measurement_uuid:"$measurement_uuid", RSSI:"$RSSI"}}}},
{$out:"temp_1_1_" + i.toString()}],
{allowDiskUse:true});
db["temp"+ i.toString()].createIndex({_id: 1},{unique:true})
}
//Aufgabe 3
//for (i = 0; i < 4; i++){
//db["raw_data_192.168.0.69"].aggregate([
//{$match:{"data.AntennaPort" : {$mod:[4, i]}}},
//{$group:{_id: "$data.EPC", count:{$sum:1}}},
//{$out:"temp_3_1_" + i.toString()}],
//{allowDiskUse:true});
//db["temp"+ i.toString()].createIndex({_id: 1},{unique:true})
//}