クエリ

1
import pymongo
2
from pymongo import MongoClient
3
4
try:
5
    uri = "<connection string URI>"
6
    client = MongoClient(uri)
7
8
    database = client["<database name>"]
9
    collection = database["<collection name>"]
10
11
    # start example code here
12
13
    # end example code here
14
15
    client.close()
16
17
except Exception as e:
18
    raise Exception(
19
        "The following error occurred: ", e)

1
import asyncio
2
import pymongo
3
from pymongo import AsyncMongoClient
4
5
async def main():
6
    try:
7
        uri = "<connection string URI>"
8
        client = AsyncMongoClient(uri)
9
10
        database = client["<database name>"]
11
        collection = database["<collection name>"]
12
13
        # start example code here
14
15
        # end example code here
16
17
        await client.close()
18
19
    except Exception as e:
20
        raise Exception(
21
            "The following error occurred: ", e)
22
23
asyncio.run(main())

results = collection.find_one({ "<field name>" : "<value>" })
print(results)

results = await collection.find_one({ "<field name>" : "<value>" })
print(results)

results = collection.find({ "<field name>" : "<value>" })
for document in results:
    print(document)

results = collection.find({ "<field name>" : "<value>" })
async for document in results:
    print(document)

count = collection.count_documents({})
print(count)

count = await collection.count_documents({})
print(count)

count = collection.count_documents({ "<field name>": "<value>" })
print(count)

count = await collection.count_documents({ "<field name>": "<value>" })
print(count)

count = collection.estimated_document_count()
print(count)

count = await collection.estimated_document_count()
print(count)

results = collection.distinct("<field name>")
for document in results:
    print(document)

results = await collection.distinct("<field name>")
for document in results:
    print(document)

with collection.watch() as stream:
    for change in stream:
        print(change)

async with await collection.watch() as stream:
    async for change in stream:
        print(change)