measures.py 679 B

1234567891011121314151617181920212223242526272829
  1. from datetime import datetime
  2. from typing import List
  3. from database.mongo import mongo_measures
  4. def get_finca_measures(
  5. station_code: str, start_datetime: datetime, end_datetime: datetime
  6. ) -> List:
  7. finca_data = mongo_measures[station_code]
  8. _filter = {"date": {"$gt": start_datetime, "$lte": end_datetime}}
  9. query = finca_data.find(_filter, sort=(("date", 1),))
  10. measures = []
  11. for measure in query:
  12. measures.append(
  13. {
  14. "temp": measure["temp"],
  15. "hum": measure["hum"],
  16. "precip": measure["precip"],
  17. "date": measure["date"],
  18. }
  19. )
  20. return measures