class_docstr: PayloadRecord for extracted records from within a payload
  
  Attributes:
      data (str|dict): Raw payload record data being parsed
      parser: Instance of classifier.parsers.ParserBase used to properly parse the data
      log_schema_type (str): Fully qualified log type (ie: osquery:diff)
      log_type (str): Top-level log type (ie: 'osquery' in osquery:diff)
      log_subtype (str): Log sub-type, if defined (ie: 'diff' in osquery:diff)
      parsed_records (list): List of successfully parsed records from this payload record
      invalid_records (list): If some records from this payload record parsed successfully,
          but others failed, this contains the list of failed records
class_docstr_tok: ["PayloadRecord","for","extracted","records","from","within","a","payload","Attributes",":","data","(","str|dict",")",":","Raw","payload","record","data","being","parsed","parser",":","Instance","of","classifier.parsers.ParserBase","used","to","properly","parse","the","data","log_schema_type","(","str",")",":","Fully","qualified","log","type","(","ie",":","osquery",":","diff",")","log_type","(","str",")",":","Top-level","log","type","(","ie",":","'osquery","'","in","osquery",":","diff",")","log_subtype","(","str",")",":","Log","sub-type",",","if","defined","(","ie",":","'diff","'","in","osquery",":","diff",")","parsed_records","(","list",")",":","List","of","successfully","parsed","records","from","this","payload","record","invalid_records","(","list",")",":","If","some","records","from","this","payload","record","parsed","successfully",",","but","others","failed",",","this","contains","the","list","of","failed","records"]
docstr: Return a dictionary for the SQS message. JSON serialization should be done by caller
docstr_tok: ["Return","a","dictionary","for","the","SQS","message",".","JSON","serialization","should","be","done","by","caller"]
code: def sqs_messages(self):
      """Return a dictionary for the SQS message. JSON serialization should be done by caller"""
      return [
          {  # TODO: consider adding a record UUID to this payload
              "cluster": os.environ["CLUSTER"],
              "log_schema_type": self.log_schema_type,
              "record": record,
              "service": self.service,
              "resource": self.resource,
              "data_type": self.data_type,
          }
          for record in self.parsed_records
      ]
  
imports: from abc import ABCMeta, abstractmethod, abstractproperty
  import json
  import logging
  import os
  from streamalert.shared.logger import get_logger
label_desc: Use image node_id 14 for calling the PayloadRecord obj's underlying member method code with example usage: obj.sqs_messages() and returns: unknown