added purge ixia db example

Author: katzy687

resource-scripts/ixia-bps-rest/__main__.py

@@ -0,0 +1,31 @@
+from cloudshell.helpers.scripts.cloudshell_scripts_helpers import get_reservation_context_details, get_api_session, \
+    get_resource_context_details
+from purge_ixia_db import purge_ixia_db_flow
+
+# get resource details from context
+api = get_api_session()
+sb_details = get_reservation_context_details()
+sb_id = sb_details.id
+resource_details = get_resource_context_details()
+
+# put interesting data into variables
+model = resource_details.model
+name = resource_details.name
+ip = resource_details.address
+
+# extract data from attributes
+attrs = resource_details.attributes
+user = attrs[f"{model}.User"]
+encrypted_password = attrs[f"{model}.Password"]
+
+# stored password needs to be decrypted
+decrypted_password = api.DecryptPassword(encryptedString=encrypted_password).Value
+
+# start flow
+api.WriteMessageToReservationOutput(reservationId=sb_id,
+                                    message=f"starting purge flow")
+
+purge_ixia_db_flow(ip, user, decrypted_password)
+
+# printing to std_out will be the return value of resource scripts
+print(f"Ixia Purge DB flow completed for '{name}'")

resource-scripts/ixia-bps-rest/purge_ixia_db.py

@@ -0,0 +1,49 @@
+from bps_restpy.bps import BPS
+from bps_restpy.bps_restpy_v1.bpsAdminRest import BPS_Storrage
+
+
+class IxiaCleanupException(Exception):
+    pass
+
+
+def validate_result(result: bool, action=""):
+    if not result:
+        msg = "Issue during Ixia action"
+        if action:
+            msg += f": '{action}'"
+        raise IxiaCleanupException(msg)
+
+
+def purge_ixia_db_flow(ip, user, password):
+    """
+    instantiate api session, purge and compact reports in ixia
+    :param str ip:
+    :param str user:
+    :param str password:
+    :return:
+    """
+    # Login to BPS box
+    bps = BPS(ip, user, password)
+
+    # get storage controller
+    bps_storage = BPS_Storrage(bps)
+
+    # login
+    bps_storage.login()
+
+    # purge reports
+    purge_result = bps_storage.purgeReports(versionId=None)
+    validate_result(purge_result, action="PURGE DB")
+
+    # compact storage
+    compact_result = bps_storage.compactStorage(versionId=None)
+    validate_result(compact_result, action="COMPACT DB")
+
+
+if __name__ == "__main__":
+    # bps system info
+    bps_system = '<BPS_BOX_IP/HOSTNAME>'
+    bpsuser = 'bps user'
+    bpspass = 'bps pass'
+
+    purge_ixia_db_flow(bps_system, bpsuser, bpspass)

resource-scripts/throw_error/__main__.py

@@ -0,0 +1,15 @@
+from cloudshell.helpers.scripts.cloudshell_scripts_helpers import get_reservation_context_details, get_api_session, \
+    get_resource_context_details
+
+api = get_api_session()
+sb_details = get_reservation_context_details()
+sb_id = sb_details.id
+
+resource_details = get_resource_context_details()
+name = resource_details.name
+ip = resource_details.address
+
+api.WriteMessageToReservationOutput(reservationId=sb_id,
+                                    message=f"Resource name: {name}, IP: {ip}")
+
+raise Exception(f"Resource {name} exploded during operation!!!")

resource-scripts/throw_error/requirements.txt

@@ -0,0 +1 @@
+cloudshell-automation-api