Modified preprocessing function to batch records

[cgeisel]

Modified the function to use put_record_batch() rather than put_record(). The function will recursively retry failed messages until they are all successful or the function execution time is exceeded.