azure-servicefabric

import os from azure.servicefabric import ServiceFabricClient from msrest.service_fabric import ServiceFabricCredential # Connect to a secure Service Fabric cluster using client certificates # Replace with your cluster endpoint and certificate paths cluster_endpoint = os.environ.get('SF_CLUSTER_ENDPOINT', 'https://your_cluster_fqdn:19080') cert_file = os.environ.get('SF_CLIENT_CERT_FILE', 'path/to/your/client.pem') key_file = os.environ.get('SF_CLIENT_KEY_FILE', 'path/to/your/client.key') # or .pfx if combined if not all([cluster_endpoint, cert_file, key_file]): print("Please set SF_CLUSTER_ENDPOINT, SF_CLIENT_CERT_FILE, and SF_CLIENT_KEY_FILE environment variables.") print("Example: export SF_CLUSTER_ENDPOINT='https://mycluster.westus.cloudapp.azure.com:19080'") print("Example: export SF_CLIENT_CERT_FILE='/etc/sf/client.pem'") print("Example: export SF_CLIENT_KEY_FILE='/etc/sf/client.key'") else: try: # Service Fabric client expects a tuple of (cert_file, key_file) for ServiceFabricCredential credentials = ServiceFabricCredential((cert_file, key_file)) client = ServiceFabricClient(base_url=cluster_endpoint, credentials=credentials) print(f"Connecting to Service Fabric cluster at: {cluster_endpoint}") # Example: List all nodes in the cluster nodes = client.nodes.get_node_list() print(f"Found {len(nodes)} nodes in the cluster:") for node in nodes: print(f"- Node Name: {node.name}, Status: {node.health_state}, Type: {node.type}") except Exception as e: print(f"An error occurred: {e}") print("Ensure the certificate paths are correct and the cluster endpoint is reachable.")