diff bin/attic/load_test_rdfdb @ 2376:4556eebe5d73

topdir reorgs; let pdm have its src/ dir; separate vite area from light9/
author drewp@bigasterisk.com
date Sun, 12 May 2024 19:02:10 -0700
parents bin/load_test_rdfdb@4718ca6f812e
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bin/attic/load_test_rdfdb	Sun May 12 19:02:10 2024 -0700
@@ -0,0 +1,40 @@
+#!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()