Merge pull request #22 from swevm/Support-remote-syslog-configuration

Support remote syslog configuration
swevm · Jun 7, 2015 · 61ec16c · 61ec16c
2 parents 9874b58 + aa019bf
commit 61ec16c
Show file tree

Hide file tree

Showing 3 changed files with 343 additions and 13 deletions.
diff --git a/examples/install-cluster-syslog.py b/examples/install-cluster-syslog.py
@@ -0,0 +1,167 @@
+from scaleiopy import im
+from scaleiopy import scaleioobject as sioobj
+#from scaleio import installerfsm as instfsm
+import time
+import json
+from pprint import pprint
+
+###########################
+# Create a ScaleIO System #
+###########################
+#
+# Prereq: 3 x CentOS 6.5 or RHEL 6.5
+#
+# Flow:
+# Create Nodes
+# Create basic info. mdmPass, liaPass and some others
+# Construct MDM and TB and basic info
+# Create list of SDS
+# Create list of SDC
+
+
+###################
+# Construct nodes #
+###################
+nodeUsername = 'root' # Username for ScaleIO Node OS (these machines need to be pre installed)
+nodePassword = 'vagrant' # Password for ScaleIO Node OS
+node1 = sioobj.ScaleIO_Node_Object(None, None, ['192.168.102.11'], None, 'linux', nodePassword, nodeUsername)
+node2 = sioobj.ScaleIO_Node_Object(None, None, ['192.168.102.12'], None, 'linux', nodePassword, nodeUsername)
+node3 = sioobj.ScaleIO_Node_Object(None, None, ['192.168.102.13'], None, 'linux', nodePassword, nodeUsername)
+
+##########################################
+# Construct basic info for System_Object #
+##########################################
+mdmIPs = ['192.168.102.12','192.168.102.13']
+sdcList = []
+sdsList = []
+mdmPassword = 'Scaleio123'
+liaPassword = 'Scaleio123'
+licenseKey = None
+installationId = None
+
+# Remote logging parameters
+remoteSyslogServer = '192.168.102.1' # IP address to remote syslog server (uses TCP to connect)
+remoteSyslogTcpPort = '514' # Remote syslog server TCP port
+remoteSyslogFacility = 16 # Syslog Facility
+
+# Callhome parameters
+callhomeEmailFrom = 'scaleio@localhost' # If a from email box is needed, set it here
+callhomeMdmUsername = 'admin' # This is the MDM admin username to use to connect/poll status
+callhomeMdmPassword = mdmPassword # Same as MDM password defined above
+callhomeCustomerName = 'Customer' # Customer name
+callhomeHost = 'localhost' # IP or hostname to SMTP server
+callhomePort = '25' # TCP port of SMTP server
+callhomeTls = True # Encryption method. (True or False)
+callhomeSmtpUsername = 'root' # If a username is needed to connect to SMTP server, set it here
+callhomeSmtpPassword = 'password' 
+callhomeAlertEmailTo = 'root@localhost' # Commaseparated list of email addresses as alert recipients
+callhomeSeverity = 'ERROR' # What severity level of events should trigger sending emails (investigate format)
+
+
+########################################
+# Create MDMs and TB for System_Object #
+########################################
+primaryMdm = sioobj.Mdm_Object(json.loads(node2.to_JSON()), None, None, node2.nodeIPs)
+secondaryMdm = sioobj.Mdm_Object(json.loads(node3.to_JSON()), None, None, node3.nodeIPs)
+tb = sioobj.Tb_Object(json.loads(node1.to_JSON()), None, node1.nodeIPs)
+callHomeConfiguration = sioobj.Call_Home_Configuration_Object(callhomeEmailFrom,
+                                                       callhomeMdmUsername,
+                                                       callhomeMdmPassword,
+                                                       callhomeCustomerName,
+                                                       callhomeHost,
+                                                       callhomePort,
+                                                       callhomeTls,
+                                                       callhomeSmtpUsername,
+                                                       callhomeAlertEmailTo,
+                                                       callhomeSeverity
+                                                       )
+#callHomeConfiguration = None
+
+remoteSyslogConfiguration = sioobj.Remote_Syslog_Configuration_Object(remoteSyslogServer,remoteSyslogTcpPort, remoteSyslogFacility)
+#remoteSyslogConfiguration = None # Set to None if you dont need remote logging for SIO
+
+################################################################
+#Create SDS objects - To be added to SDS list in System_Object #
+################################################################
+# Adjust addDevice() to match local block device you have in your node
+# Define SDS that belong to a FaultSet - Not tested!
+#sds1 = sioobj.Sds_Object(json.loads(node1.to_JSON()), None, 'SDS_' + str(node1.nodeIPs[0]), 'default', 'faultset1', node1.nodeIPs, None, None, None, False, '7072')
+
+sds1 = sioobj.Sds_Object(json.loads(node1.to_JSON()), None, 'SDS_' + str(node1.nodeIPs[0]), 'default', None, node1.nodeIPs, None, None, None, False, '7072')
+sds1.addDevice("/home/vagrant/scaleio1", None, None)
+sds2 = sioobj.Sds_Object(json.loads(node2.to_JSON()), None, 'SDS_' + str(node2.nodeIPs[0]), 'default', None, node2.nodeIPs, None, None, None, False, '7072')
+sds2.addDevice("/home/vagrant/scaleio1", None, None)
+sds3 = sioobj.Sds_Object(json.loads(node3.to_JSON()), None, 'SDS_' + str(node3.nodeIPs[0]), 'default', None, node3.nodeIPs, None, None, None, False, '7072')
+sds3.addDevice("/home/vagrant/scaleio1", None, None)
+sdsList.append(json.loads(sds1.to_JSON()))
+sdsList.append(json.loads(sds2.to_JSON()))
+sdsList.append(json.loads(sds3.to_JSON()))
+
+#############################################################
+# Create SDC objects - To be added as list to System_Object #
+#############################################################
+# Decide which nodes in your cluster should become a SDC
+"""
+node=None,
+nodeInfo=None,
+splitterRpaIp=None
+"""
+sdc1 = sioobj.Sdc_Object(json.loads(node1.to_JSON()), None, None)
+sdc2 = sioobj.Sdc_Object(json.loads(node2.to_JSON()), None, None)
+sdc3 = sioobj.Sdc_Object(json.loads(node3.to_JSON()), None, None)
+
+sdcList.append(json.loads(sdc1.to_JSON()))
+sdcList.append(json.loads(sdc2.to_JSON()))
+sdcList.append(json.loads(sdc3.to_JSON()))
+
+######################################################
+# Construct a complete ScaleIO cluster configuration #
+######################################################
+sioobj = sioobj.ScaleIO_System_Object(installationId,
+                               mdmIPs,
+                               mdmPassword,
+                               liaPassword,
+                               licenseKey,
+                               json.loads(primaryMdm.to_JSON()),
+                               json.loads(secondaryMdm.to_JSON()),
+                               json.loads(tb.to_JSON()),
+                               sdsList,
+                               sdcList,
+                               callHomeConfiguration,
+                               remoteSyslogConfiguration
+                               )
+
+# Export sioobj to JSON (should upload clean in IM)s
+
+
+###########################################################################
+# Push System_Object JSON - To be used by IM to install ScaleIO on nodes #
+###########################################################################
+
+
+
+#######################
+# LOGIN TO SCALEIO IM #
+#######################
+imconn = im.Im("https://192.168.102.12","admin","Scaleio123",verify_ssl=False) # "Password1!") # HTTPS must be used as there seem to be an issue with 302 responses in Requests when using POST
+imconn._login()
+
+### UPLOAD RPM PACKAGES TO BE DEPLOYED BY IM ###
+imconn.uploadPackages('/Users/swevm/Downloads/RHEL6_1277/') # Adjust to your needs. All RPMs for RHEL6 should exist in this dir except for GUI and Gateway
+#imconn.uploadPackages('/Users/swevm/Downloads/RHEL6_132_402_1/') # ScaleIO 1.32 FnF for RHEL6 (This is 1.32 GA build)
+
+####################
+# INSTALLER STAGES #
+####################
+
+# Initialize Installer
+im_installer = im.InstallerFSM(imconn, True)
+
+time.sleep(5) # Wait a few seconds before continuing - Not necessary
+
+#print "Create cluster as Python objects"
+#pprint(sioobj.to_JSON())
+imconn.push_cluster_configuration(sioobj.to_JSON())
+
+print "Start Install process!!!"
+im_installer.Execute() # Start install process
diff --git a/examples/install-cluster-syslog_v1_32.py b/examples/install-cluster-syslog_v1_32.py
@@ -0,0 +1,167 @@
+from scaleiopy import im
+from scaleiopy import scaleioobject as sioobj
+#from scaleio import installerfsm as instfsm
+import time
+import json
+from pprint import pprint
+
+###########################
+# Create a ScaleIO System #
+###########################
+#
+# Prereq: 3 x CentOS 6.5 or RHEL 6.5
+#
+# Flow:
+# Create Nodes
+# Create basic info. mdmPass, liaPass and some others
+# Construct MDM and TB and basic info
+# Create list of SDS
+# Create list of SDC
+
+
+###################
+# Construct nodes #
+###################
+nodeUsername = 'root' # Username for ScaleIO Node OS (these machines need to be pre installed)
+nodePassword = 'vagrant' # Password for ScaleIO Node OS
+node1 = sioobj.ScaleIO_Node_Object(None, None, ['192.168.102.11'], None, 'linux', nodePassword, nodeUsername)
+node2 = sioobj.ScaleIO_Node_Object(None, None, ['192.168.102.12'], None, 'linux', nodePassword, nodeUsername)
+node3 = sioobj.ScaleIO_Node_Object(None, None, ['192.168.102.13'], None, 'linux', nodePassword, nodeUsername)
+
+##########################################
+# Construct basic info for System_Object #
+##########################################
+mdmIPs = ['192.168.102.12','192.168.102.13']
+sdcList = []
+sdsList = []
+mdmPassword = 'Scaleio123'
+liaPassword = 'Scaleio123'
+licenseKey = None
+installationId = None
+
+# Remote logging parameters
+remoteSyslogServer = '192.168.102.1' # IP address to remote syslog server (uses TCP to connect)
+remoteSyslogTcpPort = '514' # Remote syslog server TCP port
+remoteSyslogFacility = 16 # Syslog Facility
+
+# Callhome parameters
+callhomeEmailFrom = 'scaleio@localhost' # If a from email box is needed, set it here
+callhomeMdmUsername = 'admin' # This is the MDM admin username to use to connect/poll status
+callhomeMdmPassword = mdmPassword # Same as MDM password defined above
+callhomeCustomerName = 'Customer' # Customer name
+callhomeHost = 'localhost' # IP or hostname to SMTP server
+callhomePort = '25' # TCP port of SMTP server
+callhomeTls = True # Encryption method. (True or False)
+callhomeSmtpUsername = 'root' # If a username is needed to connect to SMTP server, set it here
+callhomeSmtpPassword = 'password' 
+callhomeAlertEmailTo = 'root@localhost' # Commaseparated list of email addresses as alert recipients
+callhomeSeverity = 'ERROR' # What severity level of events should trigger sending emails (investigate format)
+
+
+########################################
+# Create MDMs and TB for System_Object #
+########################################
+primaryMdm = sioobj.Mdm_Object(json.loads(node2.to_JSON()), None, None, node2.nodeIPs)
+secondaryMdm = sioobj.Mdm_Object(json.loads(node3.to_JSON()), None, None, node3.nodeIPs)
+tb = sioobj.Tb_Object(json.loads(node1.to_JSON()), None, node1.nodeIPs)
+callHomeConfiguration = sioobj.Call_Home_Configuration_Object(callhomeEmailFrom,
+                                                       callhomeMdmUsername,
+                                                       callhomeMdmPassword,
+                                                       callhomeCustomerName,
+                                                       callhomeHost,
+                                                       callhomePort,
+                                                       callhomeTls,
+                                                       callhomeSmtpUsername,
+                                                       callhomeAlertEmailTo,
+                                                       callhomeSeverity
+                                                       )
+#callHomeConfiguration = None
+
+remoteSyslogConfiguration = sioobj.Remote_Syslog_Configuration_Object(remoteSyslogServer,remoteSyslogTcpPort, remoteSyslogFacility)
+#remoteSyslogConfiguration = None # Set to None if you dont need remote logging for SIO
+
+################################################################
+#Create SDS objects - To be added to SDS list in System_Object #
+################################################################
+# Adjust addDevice() to match local block device you have in your node
+# Define SDS that belong to a FaultSet - Not tested!
+#sds1 = sioobj.Sds_Object(json.loads(node1.to_JSON()), None, 'SDS_' + str(node1.nodeIPs[0]), 'default', 'faultset1', node1.nodeIPs, None, None, None, False, '7072')
+
+sds1 = sioobj.Sds_Object(json.loads(node1.to_JSON()), None, 'SDS_' + str(node1.nodeIPs[0]), 'default', None, node1.nodeIPs, None, None, None, False, '7072')
+sds1.addDevice("/dev/loop0", None, None)
+sds2 = sioobj.Sds_Object(json.loads(node2.to_JSON()), None, 'SDS_' + str(node2.nodeIPs[0]), 'default', None, node2.nodeIPs, None, None, None, False, '7072')
+sds2.addDevice("/dev/loop0", None, None)
+sds3 = sioobj.Sds_Object(json.loads(node3.to_JSON()), None, 'SDS_' + str(node3.nodeIPs[0]), 'default', None, node3.nodeIPs, None, None, None, False, '7072')
+sds3.addDevice("/dev/loop0", None, None)
+sdsList.append(json.loads(sds1.to_JSON()))
+sdsList.append(json.loads(sds2.to_JSON()))
+sdsList.append(json.loads(sds3.to_JSON()))
+
+#############################################################
+# Create SDC objects - To be added as list to System_Object #
+#############################################################
+# Decide which nodes in your cluster should become a SDC
+"""
+node=None,
+nodeInfo=None,
+splitterRpaIp=None
+"""
+sdc1 = sioobj.Sdc_Object(json.loads(node1.to_JSON()), None, None)
+sdc2 = sioobj.Sdc_Object(json.loads(node2.to_JSON()), None, None)
+sdc3 = sioobj.Sdc_Object(json.loads(node3.to_JSON()), None, None)
+
+sdcList.append(json.loads(sdc1.to_JSON()))
+sdcList.append(json.loads(sdc2.to_JSON()))
+sdcList.append(json.loads(sdc3.to_JSON()))
+
+######################################################
+# Construct a complete ScaleIO cluster configuration #
+######################################################
+sioobj = sioobj.ScaleIO_System_Object(installationId,
+                               mdmIPs,
+                               mdmPassword,
+                               liaPassword,
+                               licenseKey,
+                               json.loads(primaryMdm.to_JSON()),
+                               json.loads(secondaryMdm.to_JSON()),
+                               json.loads(tb.to_JSON()),
+                               sdsList,
+                               sdcList,
+                               callHomeConfiguration,
+                               remoteSyslogConfiguration
+                               )
+
+# Export sioobj to JSON (should upload clean in IM)s
+
+
+###########################################################################
+# Push System_Object JSON - To be used by IM to install ScaleIO on nodes #
+###########################################################################
+
+
+
+#######################
+# LOGIN TO SCALEIO IM #
+#######################
+imconn = im.Im("https://192.168.102.12","admin","Scaleio123",verify_ssl=False) # "Password1!") # HTTPS must be used as there seem to be an issue with 302 responses in Requests when using POST
+imconn._login()
+
+### UPLOAD RPM PACKAGES TO BE DEPLOYED BY IM ###
+#imconn.uploadPackages('/Users/swevm/Downloads/RHEL6_1277/') # Adjust to your needs. All RPMs for RHEL6 should exist in this dir except for GUI and Gateway
+imconn.uploadPackages('/Users/swevm/Downloads/RHEL6_132_402_1/') # ScaleIO 1.32 FnF for RHEL6 (This is 1.32 GA build)
+
+####################
+# INSTALLER STAGES #
+####################
+
+# Initialize Installer
+im_installer = im.InstallerFSM(imconn, True)
+
+time.sleep(5) # Wait a few seconds before continuing - Not necessary
+
+#print "Create cluster as Python objects"
+#pprint(sioobj.to_JSON())
+imconn.push_cluster_configuration(sioobj.to_JSON())
+
+print "Start Install process!!!"
+im_installer.Execute() # Start install process