Сглаживание выбросов показаний датчиков медианным фильтром.
[weathermon.git] / weathermon_cron
1 #!/usr/bin/python
2
3 from pprint import pprint
4 from os import system;
5
6 import pycurl
7 from urllib import urlencode
8 from StringIO import StringIO
9
10 import MySQLdb
11 import ConfigParser
12
13 import uuid
14
15 def print_log(str):
16   global logging,debug
17   if debug>0:
18     print str
19   if logging == "on":
20     system("logger -t weathermon \""+str+"\"")
21
22 def submit_narodmon():
23
24   global debug
25   
26   param = { 'ID':devid }
27
28   c = database.cursor()
29   c.execute(
30     '''
31 select nm_id,avg(value) from meteo.ext_sensors e,meteo.sensor_values v
32 where 
33 e.sensor_id=v.sensor_id and e.param_id=v.parameter_id 
34 and v.timestamp>DATE_SUB(CURRENT_TIMESTAMP(),INTERVAL 15 MINUTE)
35 and e.nm_id is not null
36 group by e.sensor_id,e.param_id,e.nm_id,e.owm_id
37     '''
38   )
39
40   queue=c.fetchall()
41
42   if debug>1:
43     pprint(queue)
44
45   for (sensor,value) in queue:
46     param[sensor] = value  
47   
48   if debug>1:
49     pprint (param)
50
51   url = "http://narodmon.ru/post.php"
52
53   try:
54       
55     response_buffer = StringIO()
56     curl = pycurl.Curl()
57                                               
58     curl.setopt(curl.URL, url)
59     curl.setopt(curl.WRITEFUNCTION, response_buffer.write)   
60     curl.setopt(curl.POST, 1)
61     curl.setopt(curl.POSTFIELDS, urlencode(param))
62                                                                   
63     curl.perform()
64     curl.close()  
65                                                                           
66     response_value = response_buffer.getvalue()
67                                                                               
68     print_log('Narodmon response: '+response_value)
69                                                                                   
70     return True
71                                                                                       
72   except:
73            
74     exc_type, exc_value, exc_traceback = sys.exc_info()
75     traceback.print_tb(exc_traceback, limit=1, file=sys.stdout)
76     traceback.print_exception(exc_type, exc_value, exc_traceback,
77                               limit=2, file=sys.stdout)  
78     return False  
79                                       
80 def submit_owm():
81
82   global debug
83
84   url = "http://openweathermap.org/data/post"
85   params = {'name':owm_station, 'lat':owm_lat, 'long':owm_lon}
86
87   c = database.cursor()
88   c.execute(
89     '''
90     select owm_id,value from
91     (
92     SELECT sensor_id,parameter_id,avg(timestamp) timestamp,round(avg(value),1) value FROM meteo.sensor_values
93     where 
94     timestamp>=date_sub(current_timestamp(), INTERVAL 15 MINUTE)
95     group by sensor_id,parameter_id
96     ) v,meteo.ext_sensors e
97     where v.sensor_id=e.sensor_id and v.parameter_id=e.param_id
98     and owm_id is not null
99     '''
100   )
101
102   queue=c.fetchall()
103
104   if debug>1:
105     pprint(queue)
106
107   for (sensor,value) in queue:
108     params[sensor]=value
109   if debug>1:  
110     pprint (params)
111
112   try:
113
114     response_buffer = StringIO()
115     curl = pycurl.Curl()
116
117     curl.setopt(curl.URL, url)
118     curl.setopt(curl.USERPWD, '%s:%s' % (owmuser, owmpasswd))
119     curl.setopt(curl.WRITEFUNCTION, response_buffer.write)
120     curl.setopt(curl.POST, 1)
121     curl.setopt(curl.POSTFIELDS, urlencode(params))
122
123     curl.perform()
124     curl.close()
125     
126     response_value = response_buffer.getvalue()
127     
128     print_log('Openweathermap response: '+response_value)
129   
130     return True
131   
132   except:
133
134     exc_type, exc_value, exc_traceback = sys.exc_info()
135     traceback.print_tb(exc_traceback, limit=1, file=sys.stdout)
136     traceback.print_exception(exc_type, exc_value, exc_traceback,
137                                   limit=2, file=sys.stdout)
138     return False  
139
140 def main():
141   submit_narodmon()
142   submit_owm()
143
144 def init():
145
146   global logging,debug;
147   global devid;
148   global dbhost,dbuser,dbpasswd;
149   global owmuser,owmpasswd,owm_temp,owm_pres,owm_humi,owm_lat,owm_lon,owm_station;
150
151   try:
152
153     cfg = ConfigParser.RawConfigParser(allow_no_value=True)
154     cfg.readfp(open('/etc/weathermon.conf'))
155
156     try:
157       logging = cfg.get("logging","enabled")
158     except:
159       logging = None
160     try:
161       debug = int(cfg.get("logging","debug"))
162     except:
163       debug = 0
164
165     dbhost = cfg.get("mysql","host")
166     dbuser = cfg.get("mysql","user")
167     dbpasswd = cfg.get("mysql","passwd")
168     try:
169       narmon = cfg.get("narodmon","enable")
170     except:
171       narmon = 'off'  
172     try:
173       devid = cfg.get("narodmon","devid")
174     except:
175       devid = "{:0>12X}".format(getnode())   
176     try:  
177       owmuser = cfg.get("openweathermap","user")
178       owmpasswd = cfg.get("openweathermap",'passwd')
179     except:
180       owmuser = None  
181     if owmuser:
182       try:
183         owm_station=cfg.get("openweathermap","station")
184         owm_lat=cfg.get("openweathermap","lat")
185         owm_lon=cfg.get("openweathermap","lon")
186       except:
187         None  
188         
189     global database
190     database = MySQLdb.connect(host=dbhost,user=dbuser,passwd=dbpasswd,use_unicode=True,connect_timeout=10)
191     database.set_character_set('utf8')
192     c = database.cursor()
193     c.execute('SET NAMES utf8;')
194     print_log("Database connected...")
195     connected = True 
196   
197   except:
198
199     print_log("Cannot intialize system")
200     exit() 
201   
202 if __name__ == "__main__":
203   import sys
204   reload(sys)
205   sys.setdefaultencoding('utf-8')
206   init()
207   main()