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” }, […]
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, […]
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 […]
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
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 […]
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) […]
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 […]
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 = […]
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”}}}]) { […]
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