Updated script to use new analytics database
This commit is contained in:
parent
10f2df3480
commit
09e969405a
1 changed files with 5 additions and 4 deletions
|
@ -13,6 +13,7 @@
|
||||||
// TODO: Convert this to a node script so it can use proper libraries (e.g. slugify)
|
// TODO: Convert this to a node script so it can use proper libraries (e.g. slugify)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
logDB = new Mongo("localhost").getDB("analytics")
|
||||||
var scriptStartTime = new Date();
|
var scriptStartTime = new Date();
|
||||||
var analyticsStringCache = {};
|
var analyticsStringCache = {};
|
||||||
|
|
||||||
|
@ -151,7 +152,7 @@ function getLevelFunnelData(startDay, eventFunnel) {
|
||||||
|
|
||||||
var startObj = objectIdWithTimestamp(ISODate(startDay + "T00:00:00.000Z"));
|
var startObj = objectIdWithTimestamp(ISODate(startDay + "T00:00:00.000Z"));
|
||||||
var queryParams = {$and: [{_id: {$gte: startObj}},{"event": {$in: eventFunnel}}]};
|
var queryParams = {$and: [{_id: {$gte: startObj}},{"event": {$in: eventFunnel}}]};
|
||||||
var cursor = db['analytics.log.events'].find(queryParams);
|
var cursor = logDB['log'].find(queryParams);
|
||||||
|
|
||||||
// Map ordering: level, user, event, day
|
// Map ordering: level, user, event, day
|
||||||
var userDataMap = {};
|
var userDataMap = {};
|
||||||
|
@ -223,7 +224,7 @@ function getLevelDropCounts(startDay, events) {
|
||||||
|
|
||||||
var startObj = objectIdWithTimestamp(ISODate(startDay + "T00:00:00.000Z"));
|
var startObj = objectIdWithTimestamp(ISODate(startDay + "T00:00:00.000Z"));
|
||||||
var queryParams = {$and: [{_id: {$gte: startObj}},{"event": {$in: events}}]};
|
var queryParams = {$and: [{_id: {$gte: startObj}},{"event": {$in: events}}]};
|
||||||
var cursor = db['analytics.log.events'].find(queryParams);
|
var cursor = logDB['log'].find(queryParams);
|
||||||
|
|
||||||
var userProgression = {};
|
var userProgression = {};
|
||||||
while (cursor.hasNext()) {
|
while (cursor.hasNext()) {
|
||||||
|
@ -265,7 +266,7 @@ function getLevelHelpCounts(startDay, events) {
|
||||||
|
|
||||||
var startObj = objectIdWithTimestamp(ISODate(startDay + "T00:00:00.000Z"));
|
var startObj = objectIdWithTimestamp(ISODate(startDay + "T00:00:00.000Z"));
|
||||||
var queryParams = {$and: [{_id: {$gte: startObj}},{"event": {$in: events}}]};
|
var queryParams = {$and: [{_id: {$gte: startObj}},{"event": {$in: events}}]};
|
||||||
var cursor = db['analytics.log.events'].find(queryParams);
|
var cursor = logDB['log'].find(queryParams);
|
||||||
|
|
||||||
// Map ordering: level, user, event, day
|
// Map ordering: level, user, event, day
|
||||||
var userDataMap = {};
|
var userDataMap = {};
|
||||||
|
@ -319,7 +320,7 @@ function getLevelSubscriptionCounts(startDay) {
|
||||||
{'event': 'Finished subscription purchase'}]
|
{'event': 'Finished subscription purchase'}]
|
||||||
}
|
}
|
||||||
]};
|
]};
|
||||||
var cursor = db['analytics.log.events'].find(queryParams);
|
var cursor = logDB['log'].find(queryParams);
|
||||||
|
|
||||||
// Map ordering: user, event, level, day
|
// Map ordering: user, event, level, day
|
||||||
// Map ordering: user, event, day
|
// Map ordering: user, event, day
|
||||||
|
|
Reference in a new issue