NS feedback

Author: mcmorisi

source/includes/cursors/tailable-cursor.py

@@ -19,19 +19,19 @@
 
 # start-tailable-cursor-async
 oplog = client.local.oplog.rs
-first = oplog.find().sort('$natural', pymongo.ASCENDING).limit(-1).next()
+first = await oplog.find().sort('$natural', pymongo.ASCENDING).limit(-1).next()
 print(first)
 ts = first['ts']
 
 while True:
     cursor = oplog.find({'ts': {'$gt': ts}},
                         cursor_type=pymongo.CursorType.TAILABLE_AWAIT)
-    await while async cursor.alive:
+    while cursor.alive:
         async for doc in cursor:
             ts = doc['ts']
             print(doc)
 
         # You end up here if the find() method returns no documents, or if
         # no new documents are added to the collection for more than 1 second.
-        time.sleep(1)
+        await asyncio.sleep(1)
 # end-tailable-cursor-async

source/includes/read/distinct-async.py

@@ -1,7 +1,7 @@
 # start-distinct
 results = await restaurants.distinct("borough")
 
-async for restaurant in results:
+for restaurant in results:
     print(restaurant)
 # end-distinct
 
@@ -10,7 +10,7 @@
     "cuisine": "Italian"
 })
 
-async for restaurant in results:
+for restaurant in results:
     print(restaurant)
 # end-distinct-with-query
 

source/includes/usage-examples/retrieve-code-examples-async.py

@@ -26,9 +26,9 @@
 print(count)
 # end-estimated-count
 # start-distinct
-results = collection.distinct("<field name>")
+results = await collection.distinct("<field name>")
 
-async for document in results:
+for document in results:
     print(document)
 # end-distinct
 

source/includes/usage-examples/sample-app-async.py

@@ -1,19 +1,23 @@
+import asyncio
 import pymongo
 from pymongo import AsyncMongoClient
 
-try:
-    uri = "<connection string URI>"
-    client = AsyncMongoClient(uri)
+async def main():
+    try:
+        uri = "<connection string URI>"
+        client = AsyncMongoClient(uri)
 
-    database = client["<database name>"]
-    collection = database["<collection name>"]
+        database = client["<database name>"]
+        collection = database["<collection name>"]
 
-    # start example code here
+        # start example code here
 
-    # end example code here
+        # end example code here
 
-    client.close()
+        await client.close()
 
-except Exception as e:
-    raise Exception(
-        "The following error occurred: ", e)
+    except Exception as e:
+        raise Exception(
+            "The following error occurred: ", e)
+
+asyncio.run(main())