Articles of pymongo

MapReduce en PyMongo

Mi colección de Mongo: Impressions tiene documentos en el siguiente formato: – { _uid: 10, “impressions”: [ { “pos”: 6, “id”: 123, “service”: “furniture” }, { “pos”: 0, “id”: 128, “service”: “electronics” }, { “pos”: 2, “id”: 127, “service”: “furniture” }, { “pos”: 2, “id”: 125, “service”: “electronics” }, { “pos”: 10, “id”: 124, “service”: […]

Múltiples $ donde consultas en MongoDB

Intenté juntar la siguiente consulta, pero no funciona: db.sss.find({ “pos”: { “$gte”: 200000, “$lt”: 2000000 }, “$where”: “(this.chr.letter != “X” && this.chr.no == 5) && (this.chr.letter != “X” && this.chr.no == 6) && (this.chr.letter != this.chr.letter)” }) La condición anterior arriba traté de explicar a continuación: chr.no = 5 y chr.no = 6 chr.letter entre […]

¿Cómo obtengo una lista de los ObjectId que usan pymongo?

Tengo el siguiente código: client = MongoClient() data_base = client.hkpr_restre agents_collection = data_base.agents agent_ids = agents_collection.find({},{“_id”:1}) Esto me da un resultado de: {u’_id’: ObjectId(‘553020a8bf2e4e7a438b46d9′)} {u’_id’: ObjectId(‘553020a8bf2e4e7a438b46da’)} {u’_id’: ObjectId(‘553020a8bf2e4e7a438b46db’)} ¿Cómo llego a ObjectId’s para poder usar cada ID para buscar otra colección?

Cómo consultar un elemento de una lista en pymongo.

pymongo me lanza un error al intentar consultar y elementos de las tags db.users.find({“pseudo”:”alucaard”}).distinct(“produit_up”) Out[1]: [{u’abus’: 0, u’avctype’: u’image/jpeg’, u’date’: u’2012-09-15′, u’description’: u’le fameux portable solide’, u’id’: u’alucaard134766932677′, u’namep’: u’nokia 3310′, u’nombre’: 1, u’orientation’: u’portrait’, u’photo’: ObjectId(‘5053cd4e3a5f3a0990da8a61′), u’prix’: 1000, u’tags’: [u’solide’, u’le’, u’fameux’, u’portable’], u’vendu’: False}] list(db.users.find({“solide”:{“$in”:{“document_up.tags”}}})) Traceback (most recent call last): File “C:\Python27\lib\site-packages\IPython\core\interactiveshell.py”, line […]

Acelerando las inserciones de pymongo en este bucle.

Necesito integrar algo más de medio terabyte de datos en MongoDB (alrededor de 525 GB). Son visitas a mi sitio web, cada línea del archivo es una cadena delimitada por tabuladores Este es mi bucle principal: f = codecs.open(directoryLocation+fileWithData, encoding=’utf-8′) count = 0 #start the line counter for line in f: print line line = […]

pymongo guardando objectIds incrustados, InvalidDocumentError

Al usar el controlador pymongo pelado para conectar python a mongodb, ¿por qué usar una instancia de ObjectId como clave para un documento incrustado genera un error InvalidDocument? Estoy tratando de vincular documentos utilizando Objectids y parece que no entiendo por qué querría convertirlos en cadenas cuando las creadas automáticamente para el controlador son instancias […]

grupo pymongo por fecha y hora

Estoy tratando de buscar en una colección y agrupar registros por fecha, que es una fecha y hora. Sé que pymongo los convierte al tipo adecuado en el fondo (ISODate o algo así). La pregunta es, ya que los objetos datetime tienen fecha, hora, zona horaria … ¿cómo puedo decirle al operador del grupo que […]

La ejecución de reducción de mapa falló con pymongo pero el éxito en mongo shell

Tengo un problema con mongo map reduce, mi map map puede ejecutarse correctamente en mongo shell pero cuando bash ejecutar use pymongo obtuve los siguientes errores. El siguiente json es mi ejemplo de formato de colecciones JSON { “_id” : ObjectId( “4e41661ecacbd10e00012600” ), “timestamp” : “20110809”, “variants” : { “407” : { “number_of_ad_clicks” : 101, […]

Frasco es lento para consultar Mongdb

Uso flaks para construir un sitio web de administración para monitorear los datos de usuario de MongoDB. Mi consulta está funcionando pero es muy lenta … Se tarda aproximadamente 3 ~ 5 segundos para cargar HTML. He probado la consulta de inserción y funciona menos de 0,5 segundos. No creo que sea un problema del […]

comando cursor ‘objeto no es suscriptable

Soy nuevo en Python y MongoDB y estoy comenzando un nuevo proyecto con flask-python y MongoDB. Cuando bash devolver datos usando la función aggregate() , me da el siguiente error: comando cursor ‘objeto no es suscriptable. Aquí está mi código para la consulta: Data = db.mytable.aggregate([ { “$group”: {“_id”: “$Name” ,”count”: { “$sum”: 1 }}}]) […]