Iterate einen Pymongo-Cursor von MLab

Question

Warum wird der Cursor nicht iterieren? Ich bin sicher, dass eine einfache Lösung sein sollte.

Ich habe mehrere Stack-Überlauf Antworten versucht, und die Dokumentation für MongoDB https://docs.mongodb.com/getting-started/python/query/

Der Code nach unten:

from pymongo import MongoClient 

#Connect to Mongo Client 
client = MongoClient('mongodb://the_username:the_password@ds047124.mlab.com:47124/politicians_from_theage') 
db = client.politicians_from_theage #define database used 

# Define Collection 
collection = db.posts 
print collection 

Ergebnis:

Collection(Database(MongoClient(host=['ds047124.mlab.com:47124'], document_class=dict, tz_aware=False, connect=True), u'politicians_from_theage'), u'posts') 

Dann wird der Cursor wird seinen Standort drucken:

# Define Cursor 
my_cursor = collection.find() 
print my_cursor 

Ergebnis:

<pymongo.cursor.Cursor object at 0x0000000003247518> 

dann über den Cursor, um zu versuchen und iterieren ein Timeout:

# Perform query 
    cursor = db.posts.find() 
    #Iterate the cursor and print the documents. 
for document in cursor: 
    print(document) #No Luck 

Traceback Fehler oder eine Iteration:

Traceback (most recent call last): 
    File "C:\PythonC\PythonWebScraping\17_MongoInterface\mongoget.py", line 18, in <module> 
    for result_object in my_cursor: 
    File "C:\Python27\lib\site-packages\pymongo\cursor.py", line 1090, in next 
    if len(self.__data) or self._refresh(): 
    File "C:\Python27\lib\site-packages\pymongo\cursor.py", line 1012, in _refresh 
    self.__read_concern)) 
    File "C:\Python27\lib\site-packages\pymongo\cursor.py", line 850, in __send_message 
    **kwargs) 
    File "C:\Python27\lib\site-packages\pymongo\mongo_client.py", line 827, in _send_message_with_response 
    server = topology.select_server(selector) 
    File "C:\Python27\lib\site-packages\pymongo\topology.py", line 210, in select_server 
    address)) 
    File "C:\Python27\lib\site-packages\pymongo\topology.py", line 186, in select_servers 
    self._error_message(selector)) 
pymongo.errors.ServerSelectionTimeoutError: ds047124.mlab.com:47124: timed out 

Ich habe versucht, auf 'cursor', 'my_cursor' und 'collection' zu iterieren, von denen jede einen Trace-Back-Fehler des Server-Timeouts liefert. Jede Hilfe/insight stark

geschätzt Sie würden

Answer 1

Dies kann helfen: -

# Perform query 
cursor = db.posts.find().toAray(function(err, result){ 
    #Iterate the cursor and print the documents. 
    for document in result: 
    print(document); 
}) //Will give you array of objects. 

Lassen Sie mich wissen, ob es funktioniert.

Answer 2

Die Antwort gefunden, ich konzentrierte mich auf den Cursor, anstatt das Objekt vom Cursor von JSON auf eine Liste von JSON zu laden.

Schluss Code ist unten (Entfernen der URI)

import json 
from datetime import date, timedelta 
from pymongo import MongoClient 
from bson import json_util 

#Connect to Mongo Client 
client = MongoClient('mongodb://user:pword@ds047124.mlab.com:47124/politicians_from_theage') 
db = client.politicians_from_theage #define database used 
print db 
# Define Collection 
collection = db.posts 
print collection # print Collection(Database(MongoClient(host=['ds047124.mlab.com:47124']... 


cursor = collection.find() 
print cursor 

# Obtain json 
json_docs = [] 
for doc in cursor: 
    json_doc = json.dumps(doc, default=json_util.default) 
    json_docs.append(json_doc) 
print json_docs #json result 

# List Comprehension version 
#json_docs = [json.dumps(doc, default=json_util.default) for doc in cursor] 

#To get back from json again as string list 
docs = [json.loads(j_doc, object_hook=json_util.object_hook) for j_doc in json_docs] 
print docs 

print 'kitty terminates program'