supervisor

import xmlrpc.client import os # NOTE: This assumes a 'supervisord' instance is running # and its XML-RPC interface is accessible, e.g., on port 9001. # You might need to configure supervisord.conf for this. # Example: [inet_http_server] # port=*:9001 # username=user # password=123 rpc_url = os.environ.get('SUPERVISOR_RPC_URL', 'http://localhost:9001/RPC2') rpc_username = os.environ.get('SUPERVISOR_RPC_USERNAME', '') rpc_password = os.environ.get('SUPERVISOR_RPC_PASSWORD', '') if rpc_username and rpc_password: # Add credentials to the URL if specified auth_url = rpc_url.replace('http://', f'http://{rpc_username}:{rpc_password}@') proxy = xmlrpc.client.ServerProxy(auth_url) else: proxy = xmlrpc.client.ServerProxy(rpc_url) try: # Get basic information about processes all_processes = proxy.supervisor.getAllProcessInfo() print(f"Found {len(all_processes)} supervised processes:") for p in all_processes: print(f" - Name: {p['name']}, State: {p['statename']}, PID: {p['pid']}") # Example: Check API version api_version = proxy.supervisor.getAPIVersion() print(f"Supervisor API Version: {api_version}") # Example: Stop a process (replace 'my_program' with an actual process name) # try: # print(f"Attempting to stop 'my_program': {proxy.supervisor.stopProcess('my_program')}") # except xmlrpc.client.Fault as e: # print(f"Error stopping process: {e}") except ConnectionRefusedError: print(f"ERROR: Connection refused. Is supervisord running and its RPC interface listening on {rpc_url}?", flush=True) except xmlrpc.client.Fault as e: print(f"ERROR: XML-RPC Fault: {e}", flush=True) except Exception as e: print(f"An unexpected error occurred: {e}", flush=True)