nongxiaohe/model/data.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
    demeter database
    name:data.py
    author:rabin
"""
from base import Base

class Data(Base):
	__table__ = 'data'
	__type__ = 'influxdb'

	def insert(self, data):
		json = self.model_insert(data)
		self.db.write_points(json)
		self.select()

	def model_insert(self, data):
		if 'farm' in data:
			json = self.model_farm(data)
		else:
			json = self.model_json(data)
		return json

	def model_json(self, data):
		return data

	def model_farm(self, data):
		json = [
		{
			"measurement": self.table,
			"tags": {
				"farm": data['farm'],
				"method": data['method'],
				"gateway": data['gateway'],
				"device": data['device']
			},
			#"time": data['time'],
			"fields": {
				data['type']: data['value']
			}
		}]
		return json

	def select(self):
		result = self.db.query('select * from ' + self.table)    
		print("Result: {0}".format(result))