import time

from utils import snowflake_fetch
from utils import dynamo_insert_async

import config

snowflake_start = time.time()
product_isrc_items = snowflake_fetch.get_isrcs_on_product_for_label(config.LABEL_ID)
snowflake_end = time.time()

# product_isrc_items = [dict(t) for t in {tuple(d.items()) for d in product_isrc_items}]

dynamo_start = time.time()
dynamo_insert_async.insert_items(product_isrc_items)
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_isrc_items)))