Integrations

Look for the following to monitor messages from the SQS function:

Suppose queue is empty,
logging.info("[AWSQueue] There are no messages in SQS, attempting to enqueue files
seen so far" 

Suppose function has run >=90% of allotted time, then
logging.warn('[AWSQueue]SQS Queue manager has run close to 90 percentage of max time.
Flushing files to queue before termination')
 

Suppose event file is skipped,
logging.warn('[AWSQueue] Skipping file since logs to be consumed is {}, but file is
{}'.format(LOGS_TO_CONSUME, file_path)) 

Suppose a read limit is reached, then
logging.warn('[AWSQueue] Have processed {} files and hence exiting'.format
(files_processed))Suppose event file is skipped,
logging.warn('[AWSQueue] Skipping file since logs to be consumed is {},
but file is {}'.format(LOGS_TO_CONSUME, file_path))