Files
@ 2fc0e726a3c3
Branch filter:
Location: light9/bin/clientdemo - annotation
2fc0e726a3c3
1.1 KiB
text/plain
rdfdb alternate graph formats for timing tests
Ignore-this: 4aea5721454500c088927b10ca17aae
Ignore-this: 4aea5721454500c088927b10ca17aae
37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 5c158d37f1ce a38955ba6f40 904913de4599 904913de4599 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 a38955ba6f40 37d05bd17b10 5c158d37f1ce 5c158d37f1ce 5c158d37f1ce 5c158d37f1ce 5c158d37f1ce 5c158d37f1ce 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 37d05bd17b10 904913de4599 904913de4599 904913de4599 37d05bd17b10 37d05bd17b10 | #!bin/python
import os, sys
sys.path.append(".")
from twisted.internet import reactor
import cyclone.web, cyclone.httpclient, logging
from rdflib import Namespace, Literal, URIRef
from light9 import networking
from light9.rdfdb.patch import Patch
from light9.rdfdb.syncedgraph import SyncedGraph
if __name__ == "__main__":
logging.basicConfig(level=logging.DEBUG)
log = logging.getLogger()
g = SyncedGraph(networking.rdfdb.url, "clientdemo")
from light9.Submaster import PersistentSubmaster
sub = PersistentSubmaster(graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools"))
#get sub to show its updating name, then push that all the way into KC gui so we can see just names refresh in there
L9 = Namespace("http://light9.bigasterisk.com/")
def updateDemoValue():
v = list(g.objects(L9['demo'], L9['is']))
print "demo value is %r" % v
g.addHandler(updateDemoValue)
def adj():
g.patch(Patch(addQuads=[(L9['demo'], L9['is'], Literal(os.getpid()),
L9['clientdemo'])],
delQuads=[]))
reactor.callLater(2, adj)
reactor.run()
|