Mercurial > code > home > repos > homeauto

annotate lib/standardservice/scalessetup.py @ 1562:c2ed44ed1e3c dependabot/pip/service/collector/twisted-19.7.0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Bump twisted from 19.2.0 to 19.7.0 in /service/collector Bumps [twisted](https://github.com/twisted/twisted) from 19.2.0 to 19.7.0. - [Release notes](https://github.com/twisted/twisted/releases) - [Changelog](https://github.com/twisted/twisted/blob/trunk/NEWS.rst) - [Commits](https://github.com/twisted/twisted/compare/twisted-19.2.0...twisted-19.7.0) Signed-off-by: dependabot[bot] <support@github.com>
author dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
date Fri, 14 Feb 2020 10:01:26 +0000
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)