カーソルからデータにアクセスする

Overview

このガイドでは、PyMongo を使用してカーソルからデータにアクセスする方法を学習できます。

カーソルは、読み取り操作の結果を反復可能なバッチで返すメカニズムです。 カーソルは一度にドキュメントのサブセットのみを保持するため、メモリ消費とネットワーク帯域幅使用量の両方が削減されます。

PyMongo が複数のドキュメントを返す読み取り操作を実行するたびに、それらのドキュメントをカーソルで自動的に返します。

カーソルの内容に反復的にアクセスする

カーソルの内容を反復処理するには、次の例に示すようにforループを使用します。

results = collection.find()
for document in results:
    print(document)

ドキュメントを個別に検索する

カーソルからドキュメントを個別に取得するには、 next()メソッドを呼び出します。

次の例では、 nameの値が"Dunkin' Donuts"である コレクション内のすべてのドキュメントを検索します。 次に、 next()メソッドを呼び出してカーソルの最初のドキュメントを出力します。

results = collection.find({ "name": "Dunkin' Donuts" })
print(results.next())

{'_id': ObjectId('...'), 'address': { ... }, 'borough': 'Bronx', 'cuisine': 'Donuts', 'grades': [...], 'name': "Dunkin' Donuts", 'restaurant_id': '40379573'}

すべてのドキュメントを検索する

カーソルからすべてのドキュメントを検索するには、次の例に示すように、カーソルをlistに変換します。

results = collection.find({ "name": "Dunkin' Donuts" })
all_results = list(results)
for document in all_results:
    print(document)

カーソルを閉じる

デフォルトでは、クライアントがカーソル内の結果をすべて使い切ると、MongoDB はカーソルを閉じます。 カーソルを明示的に閉じるには、次の例に示すようにclose()メソッドを呼び出します。

results = collection.find()
...
results.close()

テール可能カーソル

Capped コレクションをクエリする場合、クライアントがカーソルの結果を使い果たした後も開いたままになる 追尾可能 ( tailable) カーソルを使用できます。 Cappedコレクションを使用して追尾可能 (tailable) カーソルを作成するには、 find()メソッドのcursor_typeオプションでCursorType.TAILABLE_AWAITを指定します。

次の例では、 追尾可能 (tailable) カーソル を使用して、レプリカセット ノードの oplog を追跡します。

oplog = client.local.oplog.rs
first = 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)
    while cursor.alive:
        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)

追尾可能 (tailable) カーソルの詳細については、MongoDB Server マニュアルの 追尾可能 ( tailable) カーソル のガイド を参照してください。

トラブルシューティング

Exception ignored in: <function Cursor.__del__ at 0x1048129d8>
...
AttributeError: 'Cursor' object has no attribute '_Cursor__killed'
...
TypeError: __init__() got an unexpected keyword argument '<argument>'