diff --git a/bin/load_test_rdfdb b/bin/load_test_rdfdb new file mode 100644 --- /dev/null +++ b/bin/load_test_rdfdb @@ -0,0 +1,37 @@ +#!bin/python +from run_local import log +from twisted.internet import reactor, task, defer +from rdflib import URIRef, Literal +from twisted.internet.defer import ensureDeferred +from rdfdb.syncedgraph import SyncedGraph +import time, logging + +from light9 import networking, showconfig +from light9.namespaces import L9 + +class BusyClient: + def __init__(self, subj, rate): + self.subj = subj + self.rate = rate + + self.graph = SyncedGraph(networking.rdfdb.url, "collector") + self.graph.initiallySynced.addCallback(self.go) + def go(self, _): + task.LoopingCall(self.loop).start(1 / self.rate) + + + def loop(self): + self.graph.patchObject(showconfig.showUri() + '/loadTestContext', + subject=self.subj, + predicate=L9['time'], + newObject=Literal(str(time.time()))) + +def main(): + log.setLevel(logging.INFO) + + clients = [BusyClient(L9['loadTest_%d' % i], 20) for i in range(10)] + reactor.run() + +if __name__ == "__main__": + main() +