def batch_processing_job_update()

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)