Mercurial > code > home > repos > light9

comparison bin/debug/collector_loadtest.py @ 2376:4556eebe5d73

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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/collector_loadtest.py@2c48e92ad5d3
children
comparison
equal deleted inserted replaced
2375:623836db99af 2376:4556eebe5d73
1 #!bin/python
2 import asyncio
3 import logging
4 import random
5 from rdflib import URIRef
6 import time
7
8 from light9.collector.collector_client_asyncio import sendToCollector
9 from light9.effect.settings import DeviceSettings
10 from light9.namespaces import DEV, L9
11 from light9.run_local import log
12
13 log.setLevel(logging.DEBUG)
14
15
16 async def loadTest():
17 print("scheduling loadtest")
18 n = 200000
19 period=.02
20 times = []
21 session = "loadtest%s" % time.time()
22 for i in range(n):
23 if i % 100 == 0:
24 log.info('sendToCollector %s', i)
25 start = time.time()
26 await sendToCollector(
27 "http://localhost:8202/",
28 session,
29 DeviceSettings(
30 graph=None,
31 settingsList=[
32 # [DEV["backlight1"], L9["color"], "#ffffff"], #
33 # [DEV["backlight2"], L9["color"], "#ffffff"],
34 # [DEV["backlight3"], L9["color"], "#ffffff"],
35 # [DEV["backlight4"], L9["color"], "#ffffff"],
36 # [DEV["backlight5"], L9["color"], "#ffffff"],
37 # [DEV["down2"], L9["color"], "#ffffff"],
38 # [DEV["down3"], L9["color"], "#ffffff"],
39 # [DEV["down4"], L9["color"], "#ffffff"],
40 [URIRef('http://light9.bigasterisk.com/theater/skyline/device/down1'), L9["brightness"], random.random()],
41 [DEV["backlight5"], L9["uv"], 0.011]
42 ]))
43 times.append(time.time() - start)
44 await asyncio.sleep(period)
45
46 print("loadtest done")
47 with open('/tmp/times', 'w') as f:
48 f.write(''.join('%s\n' % t for t in times))
49
50
51 if __name__ == '__main__':
52 asyncio.run(loadTest())