Advertisement
Guest User

Consulta Map/Reduce en Python y MongoDB

a guest
Jan 6th, 2011
446
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 1.05 KB | None | 0 0
  1. from pymongo import Connection
  2. from bson.code import Code
  3.  
  4.  
  5. print "Conectando al Servidor de Base de Datos Local..."
  6. conexion = Connection() # Conexion local por defecto
  7. ##conexion = Connection('miServidor', 30500) # Conexion remota a puerto 30500
  8.  
  9. #creando/obteniendo un objeto que referencie a la base de datos.
  10. db = conexion['bdregistrodetransferencias']
  11.  
  12. #creando/obteniendo un objeto que referencie a la coleccion.
  13. collbajada = db['bajada']
  14. collsubida = db['subida']
  15.  
  16.  
  17. ms = Code("""function() {
  18.     emit("Subida", this.subida);
  19. }""")
  20.  
  21. rs = Code("""function(k, v) {
  22.     var i, sum = 0;
  23.     for (i in v) {
  24.         sum += v[i];
  25.     }
  26.     return sum;
  27. }""")
  28.  
  29.  
  30. mb = Code("""function() {
  31.     emit("Bajada", this.bajada);
  32. }""")
  33.  
  34. rb = Code("""function(k, v) {
  35.     var i, sum = 0;
  36.     for (i in v) {
  37.         sum += v[i];
  38.     }
  39.     return sum;
  40. }""")
  41.  
  42. print "Sumatoria de SUBIDA"
  43. result = collsubida.map_reduce(ms, rs)
  44.  
  45. for subida in result.find():
  46.     print subida
  47.  
  48.  
  49. print "Sumatoria de BAJADA"
  50. result = collbajada.map_reduce(mb, rb)
  51.  
  52. for bajada in result.find():
  53.     print bajada
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement