Files
@ a4052905ca7d
Branch filter:
Location: light9/bin/debug/clientdemo - annotation
a4052905ca7d
1.1 KiB
text/plain
notes about how rdfdb syncs, or should sync
4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 4556eebe5d73 | #!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 rdfdb.patch import Patch
from 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()
|