Munin contributed plugins

	except IOError:

		print 'Could not connect to the celerymon webserver'

		sys.exit(-1)

def check_web_server_status(api_url):

	try:

		request = urllib.urlopen(api_url)

# Values

def print_values(workers = None, api_url = None):

	data = get_data('tasks', api_url)

	counters = dict([(key, 0) for key in TASK_STATES])

	for task_name, task_data in data:

		state = task_data['state']

		hostname = task_data['worker']['hostname']

		if workers and hostname not in workers:

			continue

		counters[state] += 1

	for name in TASK_STATES:

		name_cleaned = clean_state_name(name)

		value = counters[name]

		print '%s.value %d' % (name_cleaned, value)

if __name__ == '__main__':

	workers = os.environ.get('workers', 'all')

	api_url = os.environ.get('api_url', API_URL)

	check_web_server_status(api_url)

	if workers in [None, '', 'all']:

		workers = None

	else:

		workers = workers.split(',')

	if len(sys.argv) > 1:

		if sys.argv[1] == 'config':

			print_config(workers)

			print 'yes'

	else:

		print_values(workers, api_url)