in src/batch_processor.py [0:0]
def batch_processing_job_update(productId, productName, productDescription, fileName, region, dbTableName):
try:
now = datetime.now()
date_time = now.strftime("%m-%d-%Y %H:%M:%S.%f")[:-3]
dynamodb = boto3.resource('dynamodb', region_name = region)
logMessage(fileName, "dbTableName - " + dbTableName, LOGTYPE_INFO)
table = dynamodb.Table(dbTableName)
table.put_item(
Item={
'ProductId': productId,
'Filename': fileName,
'CreatedTime': date_time,
'LastModified': date_time,
'ProductName': productName,
'ProductDescription': productDescription
}
)
except Exception as ex:
logMessage(fileName, "Error Updating DynamoDB:" + str(ex), LOGTYPE_ERROR)