Files
@ 1a7e5b07bf17
Branch filter:
Location: light9/bin/load_test_rdfdb - annotation
1a7e5b07bf17
1.0 KiB
text/plain
use my greplin fork's stats/ code instead of an old local one
Ignore-this: f0935bd61f0b982e544c1991e14fb51e
Ignore-this: f0935bd61f0b982e544c1991e14fb51e
713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 713e56e8e2b9 | #!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()
|