import time import datetime from utils import dynamo_insert_async from utils import snowflake_fetch import config snowflake_start = time.time() product_metadata_list = snowflake_fetch.get_products_for_label(config.LABEL_ID) snowflake_end = time.time() dynamo_start = time.time() idynamo_insert_async.insert_items(product_metadata_list) dynamo_end = time.time() print('snowflake time: {} seconds'.format(round((snowflake_end - snowflake_start),2))) print('dynamo time: {} seconds'.format(round((dynamo_end - dynamo_start), 2))) print('inserted {} items'.format(len(product_metadata_list)))