Improving custom resoruce behavior and parameter path.

Author: EC2 Default User

lib/chembl-25-stack.ts

@@ -35,7 +35,7 @@ export class ChemblStack extends cdk.Stack{
 				"--job-bookmark-option": "job-bookmark-disable",
 				"--enable-metrics": "",
 				"--DL_BUCKET": props.dataLakeBucket.bucketName,
-				"--DL_PREFIX": "/chembl/25/",
+				"--DL_PREFIX": "/"+dataSetName+"/",
 				"--DL_REGION": cdk.Stack.of(this).region,
 				"--GLUE_SRC_DATABASE": "chembl_25_src"
 			}	    	

lib/opentargets-stack.ts

@@ -37,7 +37,7 @@ export class OpenTargetsStack extends cdk.Stack{
                 "--job-bookmark-option": "job-bookmark-disable",
                 "--enable-metrics": "",
                 "--DL_BUCKET": props.dataLakeBucket.bucketName,
-                "--DL_PREFIX": "/opentargets/19_11/",
+                "--DL_PREFIX": "/opentargets_1911/",
                 "--GLUE_SRC_DATABASE": "opentargets_1911_src"
             }
 	    });

scripts/lambda.activategluetigger.py

@@ -8,13 +8,23 @@
 
 def main(event, context):
 
-    print(event)
-
+    physical_id = 'startTrigger'
     log.getLogger().setLevel(log.INFO)
-    
-    triggerId = event['ResourceProperties']['TriggerId']
-    
-    response = glue.start_trigger(Name=triggerId);
-
-    cfnresponse.send(event, context, cfnresponse.SUCCESS, response, triggerId);
+    responseData = {}
+     
+    try:
+        log.info('Input event: %s', event)
 
+        if event['RequestType'] == 'Delete':
+            responseData['Complete'] = 'True';
+            resourceID = event['PhysicalResourceId']
+            cfnresponse.send(event, context, cfnresponse.SUCCESS, responseData, resourceID)
+        
+        if event['RequestType'] == 'Create':
+            
+            triggerId = event['ResourceProperties']['TriggerId']
+            response = glue.start_trigger(Name=triggerId);
+            cfnresponse.send(event, context, cfnresponse.SUCCESS, response, triggerId);
+    except Exception as e:
+        log.exception(e)
+        cfnresponse.send(event, context, cfnresponse.FAILED, {}, physical_id)