Articles of mongodb

Búsqueda de MongoDB para cada dictado en la lista en la colección

Tengo una collection contiene una list de dicts y quiero buscar si algún dictado contiene dos key:values específicas key:values . Entonces, por ejemplo, quiero encontrar una en la que un dict contenga un nombre y un apellido específicos. Esta es mi colección: { “names”: [ { “firstName”: “bob”, “lastName”: “jones”, “age”: “34”, “gender”: “m” }, […]

MongoDB Spark Connector py4j.protocol.Py4JJavaError: Se produjo un error al llamar a o50.load

He podido cargar esta base de datos MongoDB antes, pero ahora estoy recibiendo un error que no he podido averiguar. Así es como empiezo mi sesión de Spark: spark = SparkSession.builder \ .master(“local[*]”) \ .appName(“collab_rec”) \ .config(“spark.mongodb.input.uri”, “mongodb://127.0.0.1/example.collection”) \ .config(“spark.mongodb.output.uri”, “mongodb://127.0.0.1/example.collection”) \ .getOrCreate() Ejecuto este script para poder interactuar con spark a través de ipython, […]

PyMongo aumenta no puede asignar la dirección solicitada después de un gran número de consultas

Tengo una colección de MongoDB con> 1,000,000 de documentos. Estoy realizando un .find({ my_query }) inicial .find({ my_query }) para devolver un subconjunto de esos documentos (~ 25,000 documentos), que luego puse en un objeto de list . Luego estoy haciendo un bucle sobre cada uno de los objetos, analizando algunos valores del documento devuelto […]

Cómo buscar documento por oid en mongoengine

Necesito obtener documentos de db por oid, como: Docs.objects(_id=’4f4381f4e779897a2c000009′) Pero cómo hacerlo, si _id requiere el objeto ObjectId e incluso bash establecer ObjectId desde pymongo no funciona. Docs.objects(_id=pymongo.objectid.ObjectId(‘4f4381f4e779897a2c000009’)) volver lista vacía

Usando mongo con FLASK y python

Estoy tratando de aprender python, mongodb y flask y estoy usando el blog MUY EXCELENTE de Miguel Grinberg, que proporciona un gran conjunto de tutoriales en blog.miguelgrinberg.com Tengo un pequeño servidor RESTful que funciona bien, pero ahora quiero sacar cosas de Mongo, no de mysql Puedo sacar un registro de mongo usando el código de […]

Serializando MongoDB find () regresa a una matriz JSON no anónima, usando PyMongo

Mi código de Python consulta un MongoDB y recupera una matriz de los siguientes objetos: { u’attribute’: u’value’, u’_id’: ObjectId(‘534776c66e5987041f6154bd’) } Lo que quiero lograr, es devolver el siguiente JSON: { ‘mycollectionkey’ : [ { ‘attribute’:’value’, ‘_id’: ObjectId(‘534776c66e5987041f6154bd’) }, …and so on. ] } Sin embargo, cuando lo hago: docs = mongodb.find(…query…) docs_json = bson.json_util.dumps(docs) […]

Optimización: Dumping JSON de una API de transmisión a Mongo

Antecedentes: tengo un módulo de python configurado para capturar objetos JSON de una API de transmisión y almacenarlos (inserción masiva de 25 a la vez) en MongoDB usando pymongo. A modo de comparación, también tengo un comando bash para curl desde la misma API de transmisión y pipe a mongoimport . Ambos enfoques almacenan los […]

Cómo conectar mongodb remoto con pymongo

Cuando uso MongoChef para conectar la base de datos remota de Mongo, uso los siguientes parámetros: Servidor Servidor: localhost Puerto: 27017 Túnel SSH Dirección SSH: 10.1.0.90 Puerto: 25 Nombre de usuario de SSH: nombre de usuario Contraseña SSH: contraseña Cuando me conecto con Pymongo, tengo el siguiente código: import pymongo MONGO_HOST = “10.1.0.90” MONGO_PORT = […]

Consulta agregada / grupo / sum de MongoDB traducida a consulta pymongo

Tengo un conjunto de entradas en la colección de goals que se ve así: {“user”: “adam”, “position”: “attacker”, “goals”: 8} {“user”: “bart”, “position”: “midfielder”, “goals”: 3} {“user”: “cedric”, “position”: “goalkeeper”, “goals”: 1} Quiero calcular una sum de todos los objectives. En el shell MongoDB lo hago así: > db.goals.aggregate([{$group: {_id: null, total: {$sum: “$goals”}}}]) { […]

Python Mogo ImportError: no se puede importar el nombre de la conexión

No puedo entender por qué esto no está funcionando. mogo==0.2.4 File “/Users/Sam/Envs/AdiosScraper/lib/python2.7/site-packages/mogo/connection.py”, line 3, in from pymongo import Connection as PyConnection ImportError: cannot import name Connection