string PageInfoCollectionCommand = "mongo analytics -eval \"db.createCollection(" + "\\" + '\u0022' + "TMP_DT" + "\\" + '\u0022' + ", {autoIndexId: false } );var result = db.Interactions.aggregate([{$match: {SaveDateTime: { $gt: ISODate(" + "\\" + '\u0022' + "2016-01-01T00:00:00.000Z" + "\\" + '\u0022' + ") }}},{ $project : {_id: 1 ,ContactId: 1 ,Pages: 1}},{ $unwind :" + "\\" + '\u0022' + "$Pages" + "\\" + '\u0022' + " }]);db." + "TMP_DT" + ".insert(result.toArray());";
string PageInfoExportCSVCommand = "mongoexport --db analytics --collection " + "TMP_DT" + " --type=csv --out " + "DLY_DATA" + "/INTERACTION-PAGE-INFO-DATA-" + "DLY_DATA" + ".csv" + " --fields fields name comma seperated ";
string PageInfoExportTempCollectionDeleteCommand = "mongo analytics -eval \"db." + "TMP_DT" + ".drop();" + '\u0022';
string Commands = @"cmd.exe /c cd c:\mongodb\bin & " + PageInfoCollectionCommand + '\u0022' + " & " + PageInfoExportCSVCommand + " & " + PageInfoExportTempCollectionDeleteCommand + " & mongoexport --db analytics --collection Interactions --type=csv --out " + "DLY_DATA" + "/INTERACTION-DATA-" + "DLY_DATA" + ".csv" + " --fields fields name comma seperated " + "--query " + '\u0022' + "{ " + '\u0027' + "SaveDateTime" + '\u0027' + ":{" + '\u0027' + "$gt" + '\u0027' + ":{ " + '\u0027' + "$date" + '\u0027' + ":" + '\u0027' + "2016-01-01T00:00:00.000Z" + '\u0027' + " }}}" + '\u0022' + "" + " --sort " + '\u0022' + "{SaveDateTime: 1}" + '\u0022';
Process cmd = new Process();
cmd.StartInfo.FileName = "cmd.exe";
cmd.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
cmd.StartInfo.Arguments = Commands;
cmd.Start();
cmd.WaitForExit();
string PageInfoExportCSVCommand = "mongoexport --db analytics --collection " + "TMP_DT" + " --type=csv --out " + "DLY_DATA" + "/INTERACTION-PAGE-INFO-DATA-" + "DLY_DATA" + ".csv" + " --fields fields name comma seperated ";
string PageInfoExportTempCollectionDeleteCommand = "mongo analytics -eval \"db." + "TMP_DT" + ".drop();" + '\u0022';
string Commands = @"cmd.exe /c cd c:\mongodb\bin & " + PageInfoCollectionCommand + '\u0022' + " & " + PageInfoExportCSVCommand + " & " + PageInfoExportTempCollectionDeleteCommand + " & mongoexport --db analytics --collection Interactions --type=csv --out " + "DLY_DATA" + "/INTERACTION-DATA-" + "DLY_DATA" + ".csv" + " --fields fields name comma seperated " + "--query " + '\u0022' + "{ " + '\u0027' + "SaveDateTime" + '\u0027' + ":{" + '\u0027' + "$gt" + '\u0027' + ":{ " + '\u0027' + "$date" + '\u0027' + ":" + '\u0027' + "2016-01-01T00:00:00.000Z" + '\u0027' + " }}}" + '\u0022' + "" + " --sort " + '\u0022' + "{SaveDateTime: 1}" + '\u0022';
Process cmd = new Process();
cmd.StartInfo.FileName = "cmd.exe";
cmd.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
cmd.StartInfo.Arguments = Commands;
cmd.Start();
cmd.WaitForExit();
No comments:
Post a Comment