Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from pymongo import Connection
- from bson.code import Code
- print "Conectando al Servidor de Base de Datos Local..."
- conexion = Connection() # Conexion local por defecto
- ##conexion = Connection('miServidor', 30500) # Conexion remota a puerto 30500
- #creando/obteniendo un objeto que referencie a la base de datos.
- db = conexion['bdregistrodetransferencias']
- #creando/obteniendo un objeto que referencie a la coleccion.
- collbajada = db['bajada']
- collsubida = db['subida']
- ms = Code("""function() {
- emit("Subida", this.subida);
- }""")
- rs = Code("""function(k, v) {
- var i, sum = 0;
- for (i in v) {
- sum += v[i];
- }
- return sum;
- }""")
- mb = Code("""function() {
- emit("Bajada", this.bajada);
- }""")
- rb = Code("""function(k, v) {
- var i, sum = 0;
- for (i in v) {
- sum += v[i];
- }
- return sum;
- }""")
- print "Sumatoria de SUBIDA"
- result = collsubida.map_reduce(ms, rs)
- for subida in result.find():
- print subida
- print "Sumatoria de BAJADA"
- result = collbajada.map_reduce(mb, rb)
- for bajada in result.find():
- print bajada
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement