def process_sns_message()

in amazon_polly_async_batch/responseprocessor.py [0:0]


def process_sns_message(event, context):
    """
    Called after Polly has completed synthesizing text, updates the task record in DynamoDb with the success or failure
    reported by Polly, and updates the set record in DynamoDb with another success or failure count.

    :param event: a response from Polly
    :param context: Ignored
    """
    try:
        successes, failures = 0, 0
        for record in event['Records']:
            try:
                process_record(record)
                successes = successes + 1
            except Exception as e:
                logger.error(str(e))
                failures = failures + 1
        logger.info('Successfully processed {} responses; {} failures.'.format(successes, failures))
    except Exception as ex:
        logger.error('Failed to process Polly response because {}'.format(str(ex)))
        raise ex