@@ -193,7 +193,9 @@ Resources:
193193 Variables :
194194 DatabaseName : !Ref CURDatabaseName
195195 TableName : !Ref CURTableName
196- ViewTemplatesUri : ' https://raw.githubusercontent.com/aws-samples/aws-cudos-framework-deployment/main/legacy/cudos/view-templates'
196+ ViewTemplatesUri : ' https://raw.githubusercontent.com/aws-samples/aws-cudos-framework-deployment/main/cid/builtin/core/data/queries'
197+ ViewMetadataUri : ' https://raw.githubusercontent.com/aws-samples/aws-cudos-framework-deployment/main/cfn-templates'
198+
197199 Code :
198200 ZipFile : |
199201 import os
@@ -216,6 +218,7 @@ Resources:
216218 database_name = os.environ["DatabaseName"]
217219 table_name = os.environ["TableName"]
218220 view_templates_uri = os.environ["ViewTemplatesUri"]
221+ view_metadata_uri = os.environ["ViewMetadataUri"]
219222
220223 def lambda_handler(event, context):
221224 logger.info(f"Cloud formation {event['RequestType']} event,"
@@ -262,18 +265,18 @@ Resources:
262265 else:
263266 query_mode = 'File'
264267 logger.info(f"Step {step} completed, query mode is '{query_mode}'")
265- step="Download View Metadata"
268+ step="Download View Metadata from " + f'{view_metadata_uri}/views_cid.json'
266269
267270 logger.info(f"Trying to {step}")
268- view_dict=json.loads(str(http.request('GET', f'{view_templates_uri}/views .json').data.decode('utf-8')))
271+ view_dict=json.loads(str(http.request('GET', f'{view_metadata_uri}/views_cid .json').data.decode('utf-8')))
269272 logger.info (f"Step '{step}' completed, the view metadata is: {view_dict}")
270273
271274 for key in view_dict["view_templates"]:
272275 sql_file_uri = view_templates_uri + '/' + view_dict["view_templates"][key][query_mode]
273276 step = "Downloading view " + sql_file_uri
274277 logger.info(step)
275278 view_template = str(http.request('GET', sql_file_uri).data.decode('utf-8'))
276- view_code = view_template.replace('${athena_cur_table_name }',table_name)
279+ view_code = view_template.replace('${cur_table_name }',table_name)
277280 logger.info('Completed %s', step)
278281 step = "Running athena query for view" + view_dict["view_templates"][key][query_mode]
279282 logger.info(step)
0 commit comments