mongoDBから集められたデータを別のコレクションに書き戻します。

Question

私はいくつかのデータをmongodbに持っています。データのグループを見つけて、それを別のmongoコレクションに戻しています。これは私が試みたアプローチです。しかし、それは私にエラーを与えている。

from pymongo import MongoClient 
Client= MongoClient() 
db= Client["myntra"] 
collection= db["women.trouser"] 
pipeline=[] 
pipeline = [ 
    {'$group': 
     {'_id': 
       {'objectId':"$_id", 
       'styleOptions_skuAvailabilityDetailMap_availableCount':"$pdpData.styleOptions.skuAvailabilityDetailMap.19.availableCount", 
       'styleOptions_skuId':"$pdpData.styleOptions.skuId",} 
      } 
    } 
] 



cursor = db.women.duplicate.trouser.aggregate(pipeline,{'$out':'women.duplicate.trouser'})#{ 'allowDiskUse': True})) 
print cursor 

Answer 1

2つの問題：

まずaggregation operator $outは、パイプラインの一部です。 PyMongo aggregate()メソッドは、すべてのパイプラインステージを最初のパラメータとして受け取ります。

ですから、例えば、パイプラインの変数にあなたの$を組み合わせる必要があります。より多くの例については

pipeline = [ 
    {'$group': { ... } }, 
    {'$out': { ... } } 
] 

がPyMongo Aggregation Examples

セカンドを参照してください、あなたはと同じになるように、出力コレクションを指定しています入力コレクション。 $ out演算子replaces existing collectionに注意してください。 $out examples

を要約するも参照して、以下のコードは、いくつかの修正を超えている：

from pymongo import MongoClient 
client= MongoClient() 
collection= db["myntra"]["women.trouser"] 
pipeline = [ 
    {'$group': 
     {'_id': 
       {'objectId':"$_id",    
       'styleOptions_skuAvailabilityDetailMap_availableCount':"$pdpData.styleOptions.skuAvailabilityDetailMap.19.availableCount", 
       'styleOptions_skuId':"$pdpData.styleOptions.skuId",} 
      } 
    }, 
    {'$out': 'women.duplicate.trouser' } 
] 

cursor = db.collection.aggregate(pipeline, { 'allowDiskUse': True}) 
print cursor 

スニペットPyMongo v3.3のために書かれた上記とMongoDBは