커서에서 데이터 액세스

개요

이 가이드에서는 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()

테일 커서(tailable cursor)

고정 사이즈 컬렉션 을 쿼리할 때 클라이언트가 커서에서 결과를 모두 사용한 후에도 계속 열려 있는 테일 커서( tailable cursor )를 사용할 수 있습니다. 고정 사이즈 컬렉션으로 테일 커서(tailable cursor)를 만들려면 find() 메서드의 cursor_type 옵션에 CursorType.TAILABLE_AWAIT 를 지정합니다.

다음 예제에서는 테일 커서(tailable cursor)를 사용하여 복제본 세트 멤버의 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 cursor)에 대해 자세히 알아보려면 매뉴얼의 테일 커서(tailable cursor) 가이드 를 MongoDB Server 참조하세요.

문제 해결

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