etl - Tweaked version of sending message

tweaked.py

# replaces _get_json_message()
def _get_json_messages_simulated(json_message):
    msg = {}
    if json_message is None:
        return msg

    if os.path.exists(json_message) and os.path.isfile(json_message):
        try:
            list_of_events = []
            with open(json_message, 'r') as f:
                for line in f:
                    # Using yaml package instead of json due to unicode issues
                    # in Python 2
                    list_of_events.append(yaml.safe_load(line))
                    msg = list_of_events
        except OSError as ose:
            log.error("OSError while reading JSON Message file. {0}".format(
                ose))

    return msg

# Overrides previous override of the ElfPoster.run()
def run(self):
    msg_list = _get_json_messages_simulated(self.json_message)
    start = datetime.datetime.now()
    finish = start + datetime.timedelta(seconds=self.duration)
    for msg in msg_list:
        s = json.dumps(msg, separators=(', ', ': '))
        # publish a JSON equivalent of this Thing's message with a
        # timestamp
        log.info("ELF {0} posted a {1} bytes message: {2} on topic: {3}".format(
            self.thing_name, len(s.encode("utf8")), s, self.topic))
        self.mqttc.publish(self.topic, s, self.message_qos)
        # Check if the posting should stop
        time.sleep(1)  # wait a second between publishing iterations
        if finish < datetime.datetime.now():
            break