2016-12-03 6 views
1

이 코드는 Pymongo에서 어떻게 사용하는지 보여줍니다.하지만 RMongo에서 그렇게하고 싶다면 어떻게해야합니까?RMongo를 사용하여 perticular 열의 평균을 계산하는 방법은 무엇입니까?

from pymongo import MongoClient 

connection = MongoClient() 
db = connection.mydb 
collection = db.transactions 

pipe = [{'$group': {'_id': 'TRANS_AMNT_AVG', 'average': {'$avg':'$TRANS_AMOUNT'}}}] 
result = collection.aggregate(pipeline=pipe) 

print(list(result)) 

connection.close() 

내 데이터 세트는 transactions라고하며 열 TRANS_AMOUNT라고합니다. 평균 TRANS_AMOUNT을 계산하고 싶습니다. R 작업을 MongoDB를하는

답변

0

나는 mongolite를 사용하는 것을 선호하고, 실제로 코드는

library(mongolite) 

mongo <- mongo(collection = "transaction", db = "test") 

## dummy data 
set.seed(2016) 
df <- data.frame(TRANS_AMOUNT = rnorm(10,0,1)) 

## insert into mongo 
mongo$insert(df) 


## run the aggregation query 
## note I've swapped single quotes for doubles, and vice versa 
pipe = '[{"$group": {"_id": "TRANS_AMNT_AVG", "average": {"$avg":"$TRANS_AMOUNT"}}}]' 

mongo$aggregate(pipeline = pipe) 
# Imported 1 records. Simplifying into dataframe... 
#    _id average 
# 1 TRANS_AMNT_AVG -0.3645931 

을 공급 한 것을 매우 유사하다