import pymongo | |
from datetime import datetime, timedelta | |
from repository_base import Repository | |
class MongoDBRepository(Repository): | |
def get_data(self,topic_name, numdays): | |
mongoClient=pymongo.MongoClient() | |
db=mongoClient.SensorData | |
yesterday=datetime.today() - timedelta(numdays) | |
cursor = db.home_data.find({"topic":topic_name,"time":{"$gte":yesterday}}).sort("time",pymongo.ASCENDING) | |
values = [] | |
labels = [] | |
for r in cursor: | |
values.append(r['value']) | |
labels.append(super(MongoDBRepository,self).date_formatted(r['time'])) | |
return labels, values |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment