Mercurial > code > home > repos > homeauto
view service/reasoning/oneShot @ 473:388769b5f8ff
stats support and maybe a no-op filtering logic change snuck in there
Ignore-this: d54125308243159b28ef11e2d09014f4
author | drewp@bigasterisk.com |
---|---|
date | Sat, 20 Apr 2019 23:51:02 -0700 |
parents | 79d041273e26 |
children | 0996e3a91c85 |
line wrap: on
line source
#!/usr/bin/python """ send a statement to the reasoning server for one update cycle. Args are s/p/o in n3 notation, with many prefixes predefined here. """ import sys, requests, time s, p, o = sys.argv[1:] prefixes = { '': 'http://projects.bigasterisk.com/room/', 'room' : 'http://projects.bigasterisk.com/room/', 'shuttle': 'http://bigasterisk.com/room/livingRoom/shuttlepro/', 'sensor': 'http://bigasterisk.com/homeauto/sensor/', } def expand(term): if ':' not in term or term.startswith(('<', '"', "'")): return term left, right = term.split(':', 1) if left in prefixes: return '<%s%s>' % (prefixes[left], right) return term stmt = '%s %s %s .' % (expand(s), expand(p), expand(o)) print "Sending: %s" % stmt t1 = time.time() ret = requests.post( 'http://bang:9071/oneShot', headers={"content-type": "text/n3"}, data=stmt.encode('ascii')) g = float(ret.headers['x-graph-ms']) print "%.1f ms for graph update; %.1f ms other overhead" % (g, 1000 * (time.time() - t1) - g)