Mercurial > code > home > repos > homeauto

annotate lib/standardservice/scalessetup.py @ 1428:56e07d3f0930

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
frontdoor configs; move device class timing to greplin stats Ignore-this: f32495ae0d3b4c6f50fe1ba46c57abcd darcs-hash:c8b6f8460b858868837dc9c98f844528531fe98c
author drewp <drewp@bigasterisk.com>
date Thu, 08 Aug 2019 16:50:14 -0700
parents 2e0c4ba9d7cf
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1390
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
1 import time
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
2 from greplin import scales
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
3 from twisted.internet import task
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
4 import psutil
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
5
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
6 def gatherProcessStats():
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
7 procStats = scales.collection('/process',
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
8 scales.DoubleStat('time'),
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
9 scales.DoubleStat('cpuPercent'),
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
10 scales.DoubleStat('memMb'),
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
11 )
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
12 proc = psutil.Process()
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
13 lastCpu = [0.]
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
14 def updateTimeStat():
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
15 now = time.time()
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
16 procStats.time = round(now, 3)
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
17 if now - lastCpu[0] > 3:
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
18 procStats.cpuPercent = round(proc.cpu_percent(), 6) # (since last call)
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
19 lastCpu[0] = now
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
20 procStats.memMb = round(proc.memory_info().rss / 1024 / 1024, 6)
2e0c4ba9d7cf new scalessetup
drewp <drewp@bigasterisk.com>
parents:
diff changeset
21 task.LoopingCall(updateTimeStat).start(.1)