Comment faire évoluer et mettre à jour les documents avec PyMongo?

J'ai un simple client de l'installation de MongoDB et PyMongo 2.6.3. L'objectif est d'itérer sur chaque document de la collection collection et de mise à jour (save) chaque document dans le processus. L'approche, je suis en utilisant ressemble à peu près comme:

cursor = collection.find({})
index = 0
count = cursor.count()
while index != count:
    doc = cursor[index]
    print 'updating doc ' + doc['name']
    # modify doc ..
    collection.save(doc)
    index += 1
cursor.close()

Le problème est que save est apparemment la modification de l'ordre des documents dans le curseur. Par exemple, si ma collection est composé de 3 documents (ids omis pour plus de clarté):

{
    "name": "one"
}
{
    "name": "two"
}
{
    "name": "three"
}

le programme ci-sorties:

> updating doc one
> updating doc two
> updating doc two

Si, cependant, la ligne de collection.save(doc) est supprimé, la sortie devient:

> updating doc one
> updating doc two
> updating doc three

Pourquoi est-ce arrivé? Quelle est la bonne façon sécuritaire itérer et mise à jour des documents dans une collection?

  • Ce n'est pas une réponse. Mais essayez 1 + 999 is 1000 et `1 + 999 == 1000`.
  • thx était juste recréer pour des raisons de simplicité, toujours en apprentissage de python :). ok maintenant?
  • comment êtes-vous modifier les docs? est doc['name'] = 'newValue' assez?
InformationsquelleAutor paislee | 2013-12-15
  1. 13

    Trouvé la réponse dans MongoDB la documentation:

    Parce que le curseur n'est pas isolé au cours de sa vie, en intervenant opérations d'écriture sur un document peut entraîner un curseur qui renvoie un document plus d'une fois si ce document a changé. Pour gérer cette situation, voir les informations sur mode de capture instantanée.

    Mode de capture instantanée est activé sur le curseur, et fait un beau garantie:

    snapshot() parcourt l'index sur la _id matière et garantit que la requête doit retourner chaque document (par rapport à la valeur de la _id champ) pas plus d'une fois.

    Pour activer le mode snapshot avec PyMongo:

    cursor = collection.find(spec={},snapshot=True)

    comme par PyMongo find() la documentation. A confirmé que cela a réglé mon problème.

    InformationsquelleAutor paislee
  2. 5

    Instantané fait le travail.

    Mais sur pymongo 2.9 et au-delà, la syntaxe est légèrement différente.

    cursor = collection.find(modifiers={"$snapshot": True})

    ou pour n'importe quelle version,

    cursor = collection.find({"$snapshot": True})

    que par la PyMongo documentations

    InformationsquelleAutor Dhiresh Jain
  3. 1

    Je n'arrivais pas à recréer votre situation, mais peut-être que, du haut de ma tête, parce que aller chercher les résultats, comme vous le faites est un par un à partir de la db, vous êtes en réalité la création de plus comme vous allez (sauvegarder, puis aller chercher le prochain).

    Vous pouvez essayez de tenir le résultat dans une liste (de cette façon, l'extraction de tous les résultats à la fois - pourrait être lourd, en fonction de votre requête):

    cursor = collection.find({})
# index = 0
results = [res for res in cursor] #count = cursor.count()
cursor.close()
for res in results: # while index != count //This will iterate the list without you needed to keep a counter:
    # doc = cursor[index] //No need for this since 'res' holds the current record in the loop cycle
    print 'updating doc ' + res['name'] # print 'updating doc ' + doc['name']
    # modify doc ..
    collection.save(res)
    # index += 1 //Again, no need for counter

    Espère que cela aide

    InformationsquelleAutor wilfo