event.py

#!/usr/bin/env python
# -*- coding: UTF-8 -*-

import logging
from time import sleep
from datetime import datetime

from sanji.core import Sanji
from sanji.connection.mqtt import Mqtt


class Event(Sanji):

    # This function will be executed after registered.
    def run(self):

        while True:
            time_str = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
            # event would not have response
            self.publish.event("/remote/sanji/events",
                               data={"message": "Time: %s" % time_str})
            sleep(5)


if __name__ == "__main__":
    FORMAT = "%(asctime)s - %(levelname)s - %(lineno)s - %(message)s"
    logging.basicConfig(level=0, format=FORMAT)
    logger = logging.getLogger('Event')

    event = Event(connection=Mqtt())
    event.start()