Twój problem nie dotyczy skip() i limit(); to działa dobrze. Problem dotyczy twojej ogólnej logiki; iterujesz wszystkie 39 kolekcji w pierwszej pętli, a następnie dołączasz każdy wynik agregacji do cursor_list .
Nie mogę zrozumieć logiki tego, co próbujesz zrobić, ponieważ pierwszy przykład szuka w kolekcji słów, a drugi szuka we wszystkich kolekcjach pola słów; Mając to na uwadze, prawdopodobnie możesz uprościć swoje podejście do czegoś takiego:
offset = 0
per_page = 10
collections = db.list_collection_names()
#
# Add some logic on the collections array to filter what is needed
#
print(collections[offset:offset+per_page])
EDYTUJ, aby odzwierciedlić komentarze. Pełen przepracowany przykład funkcji do wykonania tego. Nie ma potrzeby wykonywania zapytania agregującego — to zwiększa złożoność.
from pymongo import MongoClient
from random import randint
db = MongoClient()['testdatabase1']
# Set up some data
for i in range(39):
coll_name = f'collection{i}'
db[coll_name].delete_many({}) # Be careful; testing only; this deletes your data
for k in range (randint(0, 2)):
db[coll_name].insert_one({'word': '123456'})
# Main function
def test(offset, per_page, word_to_find):
found = []
collections = db.list_collection_names()
for collection in sorted(collections):
if db[collection].find_one({word_to_find: { '$exists': True}}) is not None:
found.append(collection)
print(found[offset:offset+per_page])
test(offset=0, per_page=10, word_to_find='word')
