view service/reasoning/oneShot @ 1414:1a277dba4cdc

oneShot can send to a dev instance Ignore-this: 37dfe0f67c01c221b861d2b3e3900051 darcs-hash:85955653cb2158901ccdc4bd204c78a2b0cf54c2
author drewp <drewp@bigasterisk.com>
date Wed, 24 Jul 2019 01:03:21 -0700
parents d8acab2b01f5
children c8562ace4917
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, os
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://%s/oneShot' % os.environ.get('REASONING', 'bang:9071'),
    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)