hazza/jupyterhub
1
0
Fork 0
mirror of https://github.com/jupyterhub/jupyterhub.git synced 2025-10-18 07:23:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Send metrics about running and active users

Browse Source 
Uses the standard user last-updated activity callback
This commit is contained in:
YuviPanda
2016-03-31 18:14:09 -07:00
parent 5a15d7a219
commit 4644e7019e
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
jupyterhub/app.py
View File

@@ -1134,6 +1134,8 @@ class JupyterHub(Application):
def update_last_activity(self): def update_last_activity(self):
"""Update User.last_activity timestamps from the proxy""" """Update User.last_activity timestamps from the proxy"""
routes = yield self.proxy.get_routes() routes = yield self.proxy.get_routes()
users_count = 0
active_users_count = 0
for prefix, route in routes.items(): for prefix, route in routes.items():
if 'user' not in route: if 'user' not in route:
# not a user route, ignore it # not a user route, ignore it
@@ -1147,6 +1149,12 @@ class JupyterHub(Application):
except Exception: except Exception:
dt = datetime.strptime(route['last_activity'], ISO8601_s) dt = datetime.strptime(route['last_activity'], ISO8601_s)
user.last_activity = max(user.last_activity, dt) user.last_activity = max(user.last_activity, dt)
# FIXME: Make this configurable duration. 30 minutes for now!
if (datetime.now() - user.last_activity).total_seconds() < 30 * 60:
active_users_count += 1
users_count += 1
self.statsd.gauge('users.running', users_count)
self.statsd.gauge('users.active', active_users_count)
self.db.commit() self.db.commit()
yield self.proxy.check_routes(self.users, routes) yield self.proxy.check_routes(self.users, routes)