update every minute

This commit is contained in:
Clint Armstrong
2015-07-13 10:59:26 -04:00
parent 4d832067a9
commit 9f1c2232f0

View File

@@ -209,7 +209,7 @@ dev_query = ('SELECT device_id,
poller_group) poller_group)
threads = 0 threads = 0
next_update = datetime.now() + timedelta(minutes=2) next_update = datetime.now() + timedelta(minutes=1)
devices_scanned = 0 devices_scanned = 0
while True: while True:
@@ -219,7 +219,7 @@ while True:
log.debug('DEBUG: {} threads currently active'.format(threads)) log.debug('DEBUG: {} threads currently active'.format(threads))
if next_update < datetime.now(): if next_update < datetime.now():
seconds_taken = (datetime.now() - (next_update - timedelta(minutes=2))).seconds seconds_taken = (datetime.now() - (next_update - timedelta(minutes=1))).seconds
update_query = ('INSERT INTO pollers(poller_name, ' update_query = ('INSERT INTO pollers(poller_name, '
' last_polled, ' ' last_polled, '
' devices, ' ' devices, '
@@ -235,7 +235,7 @@ while True:
cursor.fetchall() cursor.fetchall()
log.info('INFO: {} devices scanned in the last 5 minutes'.format(devices_scanned)) log.info('INFO: {} devices scanned in the last 5 minutes'.format(devices_scanned))
devices_scanned = 0 devices_scanned = 0
next_update = datetime.now() + timedelta(minutes=2) next_update = datetime.now() + timedelta(minutes=1)
while threading.active_count() >= amount_of_workers: while threading.active_count() >= amount_of_workers:
time.sleep(.5) time.sleep(.5)