db.py 609 B

1234567891011121314151617181920
  1. from dbadapter import ADEIAdapter
  2. from katrin import status
  3. import time
  4. status_configs = status.configs
  5. status_adapters = []
  6. t0 = time.time()
  7. for i, c in enumerate(status.configs):
  8. status_adapters.append( cache.ram('katrinStatus'+str(i),
  9. lambda: cache.disk('katrinStatus'+str(i),
  10. lambda: ADEIAdapter(c),
  11. time_expire=24*3600),
  12. time_expire=600) )
  13. t1 = time.time()
  14. logger.debug(t1-t0)
  15. # group, senosrs = status_configs[0].get('group'), status_configs[0].get('sensors')
  16. # print status_adapters[0].read_sensors(status_configs[0].get('sensors'), group)