Mercurial > code > home > repos > homeauto

comparison service/arduinoNode/arduinoNode.py @ 1110:6ee834a6f970

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
influx output for arduino, update web lib path Ignore-this: 76b7fb15db86563ed3fa1ec5322b918c darcs-hash:98a4e100e4951c3260bf5d713e2fa079b24af338
author drewp <drewp@bigasterisk.com>
date Fri, 16 Sep 2016 01:16:12 -0700
parents b5906f6fce3f
children a94f2a522d41
comparison
equal deleted inserted replaced
1109:77f6117e002f 1110:6ee834a6f970
158 raise ValueError("after poll, got %x instead of 'x'" % byte) 158 raise ValueError("after poll, got %x instead of 'x'" % byte)
159 elapsed = time.time() - t1 159 elapsed = time.time() - t1
160 if elapsed > 1.0: 160 if elapsed > 1.0:
161 log.warn('poll took %.1f seconds' % elapsed) 161 log.warn('poll took %.1f seconds' % elapsed)
162 162
163 self._influx.exportToInflux( 163 stmts = set()
164 set.union([set(v) for v in self._statementsFromInputs.values()])) 164 for v in self._statementsFromInputs.values():
165 stmts.update(v)
166 self._influx.exportToInflux(stmts)
165 167
166 def _sendOneshot(self, oneshot): 168 def _sendOneshot(self, oneshot):
167 body = (' '.join('%s %s %s .' % (s.n3(), p.n3(), o.n3()) 169 body = (' '.join('%s %s %s .' % (s.n3(), p.n3(), o.n3())
168 for s,p,o in oneshot)).encode('utf8') 170 for s,p,o in oneshot)).encode('utf8')
169 bang6 = 'fcb8:4119:fb46:96f8:8b07:1260:0f50:fcfa' 171 bang6 = 'fcb8:4119:fb46:96f8:8b07:1260:0f50:fcfa'